C＃：将用户定义的类型传递给Oracle存储过程

参考Oracle：存储过程的可变参数数量

我有存储过程将多个用户插入到User表中。 该表定义如下：

CREATE TABLE "USER" ( "Name" VARCHAR2(50), "Surname" VARCHAR2(50), "Dt_Birth" DATE, ) 

插入多个用户的存储过程是：

 type userType is record ( name varchar2(100), ... ); type userList is table of userType index by binary_integer; procedure array_insert (p_userList in userList) is begin forall i in p_userList.first..p_userList.last insert into users (username) values (p_userList(i) ); end array_insert; 

如何从C＃调用存储过程传递userType的userList？ 谢谢

Answer 1

这是我在Oracle中使用存储过程的助手：

 internal class OracleDataHelper { #region Variables private static readonly string _connectionString; #endregion #region Constructors static OracleDataHelper() { //_connectionString = ConfigurationManager.ConnectionStrings["..."] // .ConnectionString; } #endregion public static object ExecuteScalar(string query) { object result; using (OracleConnection conn = new OracleConnection(ConnectionString)) { conn.Open(); OracleCommand command = new OracleCommand(query, conn); command.CommandType = CommandType.Text; result = command.ExecuteScalar(); command.Dispose(); conn.Close(); } return result; } public static object ExecuteScalar( string query, params object[] parameters) { object result; using (OracleConnection conn = new OracleConnection(ConnectionString)) { conn.Open(); OracleCommand command = new OracleCommand(query, conn); command.CommandType = CommandType.Text; command.Parameters.AddRange( ConvertParameters(parameters) ); result = command.ExecuteScalar(); command.Dispose(); conn.Close(); } return result; } public static int ExecuteNonQuery(string query) { return ExecuteNonQuery(query, new List()); } public static int ExecuteNonQuery( string query, List parameters) { int result = 0; using (OracleConnection conn = new OracleConnection(ConnectionString)) { conn.Open(); OracleCommand command = new OracleCommand(query, conn); command.CommandType = CommandType.Text; command.BindByName = true; command.Parameters.AddRange( ConvertParameters(parameters.ToArray()) ); result = command.ExecuteNonQuery(); command.Dispose(); conn.Close(); } return result; } public static int ExecuteNonQuery( string query, params object[] parameters) { int result = 0; using (OracleConnection conn = new OracleConnection(ConnectionString)) { conn.Open(); OracleCommand command = new OracleCommand(query, conn); command.BindByName = true; command.CommandType = CommandType.Text; command.Parameters.AddRange(ConvertParameters(parameters)); result = command.ExecuteNonQuery(); command.Dispose(); conn.Close(); } return result; } public static OracleDataReader ExecuteReader( OracleConnection conn, string commandText ) { OracleCommand command = new OracleCommand(commandText, conn); return command.ExecuteReader(); } public static IDataReader ExecuteReader( OracleConnection conn, string spName, out List outParameters, params object[] parameters) { throw new NotImplementedException(); } public static int ExecuteProcedure( string spName, out OutputParameters outputParameters, params object[] parameters) { int result = 0; using (OracleConnection conn = new OracleConnection(ConnectionString)) { conn.Open(); OracleCommand command = new OracleCommand(spName, conn); command.CommandType = CommandType.StoredProcedure; command.Parameters.AddRange(ConvertParameters(parameters)); result = command.ExecuteNonQuery(); outputParameters = GetOutputParameters(command.Parameters); command.Dispose(); conn.Close(); } return result; } public static int ExecuteProcedure( string spName, params object[] parameters) { int result = 0; using (OracleConnection conn = new OracleConnection(ConnectionString)) { conn.Open(); OracleCommand command = new OracleCommand(spName, conn); command.CommandType = CommandType.StoredProcedure; command.Parameters.AddRange(ConvertParameters(parameters)); result = command.ExecuteNonQuery(); command.Dispose(); conn.Close(); } return result; } public static OracleDataReader ExecuteProcedure( OracleConnection conn, string spName, out OutputParameters outputParameters, params object[] parameters ) { OracleCommand command = new OracleCommand(spName, conn); command.CommandType = CommandType.StoredProcedure; command.Parameters.AddRange(ConvertParameters(parameters)); OracleDataReader reader = command.ExecuteReader(); outputParameters = GetOutputParameters(command.Parameters); command.Dispose(); return reader; } public static OracleDataReader ExecuteProcedure( OracleConnection conn, string spName, params object[] parameters ) { OracleCommand command = new OracleCommand(spName, conn); command.CommandType = CommandType.StoredProcedure; command.Parameters.AddRange(ConvertParameters(parameters)); OracleDataReader reader = command.ExecuteReader(); command.Dispose(); return reader; } private static OracleParameter[] ConvertParameters(object[] parameters) { parameters = parameters ?? new object[] { }; int parametersCount = parameters.Length; OracleParameter[] parametersArray = new OracleParameter[parametersCount]; for (int i = 0; i < parametersCount; i++) { object parameter = parameters[i]; OracleParameter oracleParameter; if (parameter is OracleParameter) { oracleParameter = (OracleParameter)parameter; if (null == oracleParameter.Value) { oracleParameter.Value = DBNull.Value; } } else { oracleParameter = new OracleParameter(); oracleParameter.Value = parameter == null ? DBNull.Value : parameter; } // adding udt mapping for the parameter if (oracleParameter.Value != null && oracleParameter.Value is IOracleCustomTypeFactory) { MemberInfo info = oracleParameter.Value.GetType(); OracleCustomTypeMappingAttribute[] attributes = info.GetCustomAttributes( typeof(OracleCustomTypeMappingAttribute), false ) as OracleCustomTypeMappingAttribute[]; if (null != attributes && attributes.Length > 0) { oracleParameter.UdtTypeName = attributes[0].UdtTypeName; } } parametersArray[i] = oracleParameter; } return parametersArray; } private static OutputParameters GetOutputParameters( OracleParameterCollection parameters) { OutputParameters outputParameters = new OutputParameters(); foreach (OracleParameter parameter in parameters) { if (parameter.Direction == ParameterDirection.Output) outputParameters.Add(parameter); } return outputParameters; } internal static string ConnectionString { get { return _connectionString; } } } 

这些方法可以与UDT一起使用，也可以使用简单的参数。

以下是UDT实体的示例：

 [Serializable] [OracleCustomTypeMappingAttribute("MDSYS.SDO_GEOMETRY")] public class SdoGeometry : IOracleCustomTypeFactory, IOracleCustomType, ICloneable, INullable { #region Variables private int _sdoGType; private int _sdoSrid; private SdoPoint _sdoPoint; private SdoElemInfo _sdoElemInfo; private SdoOrdinates _sdoOrdinate; private bool _sdoGTypeIsNull; private bool _sdoSridIsNull; #endregion #region Properties [OracleObjectMappingAttribute("SDO_GTYPE")] public int SdoGType { get { return _sdoGType; } set { _sdoGType = value; _sdoGTypeIsNull = false; } } public SdoGeometryType SdoGeometryType { get { return (Entities.Geometry.SdoGeometryType)(SdoGType % 100); } } public int Dimensions { get { return (int)(SdoGType / 1000); } } public int LrsDimensions { get { return (int)((SdoGType / 100) % 10); } } [OracleObjectMappingAttribute("SDO_SRID")] public int SdoSrid { get { return _sdoSrid; } set { _sdoSrid = value; _sdoSridIsNull = false; } } [OracleObjectMappingAttribute("SDO_POINT")] public SdoPoint SdoPoint { get { return _sdoPoint; } set { _sdoPoint = value; } } [OracleObjectMappingAttribute("SDO_ELEM_INFO")] public SdoElemInfo SdoElemInfo { get { return _sdoElemInfo; } set { _sdoElemInfo = value; } } [OracleObjectMappingAttribute("SDO_ORDINATES")] public SdoOrdinates SdoOrdinates { get { return _sdoOrdinate; } set { _sdoOrdinate = value; } } public static SdoGeometry Null { get { SdoGeometry obj = new SdoGeometry(); return obj; } } #endregion #region Constructors public SdoGeometry() { _sdoGTypeIsNull = true; _sdoSridIsNull = true; _sdoElemInfo = SdoElemInfo.Null; _sdoOrdinate = SdoOrdinates.Null; _sdoPoint = SdoPoint.Null; } public SdoGeometry(SdoGeometry obj) { if (obj != null && this != obj) { SdoGType = obj.SdoGType; SdoSrid = obj.SdoSrid; SdoPoint = (SdoPoint)obj.SdoPoint.Clone(); SdoElemInfo = (SdoElemInfo)obj.SdoElemInfo.Clone(); SdoOrdinates = (SdoOrdinates)obj.SdoOrdinates.Clone(); } } public SdoGeometry( int gType, int srid, SdoPoint point, SdoElemInfo elemInfo, SdoOrdinates ordinate) { SdoGType = gType; SdoSrid = srid; SdoPoint = (SdoPoint)point.Clone(); SdoElemInfo = (SdoElemInfo)elemInfo.Clone(); SdoOrdinates = (SdoOrdinates)ordinate.Clone(); } #endregion #region ICloneable Members public object Clone() { return new SdoGeometry(this); } #endregion #region IOracleCustomType Members public void FromCustomObject(OracleConnection con, IntPtr pUdt) { if (!_sdoGTypeIsNull) OracleUdt.SetValue(con, pUdt, "SDO_GTYPE", SdoGType); if (!SdoOrdinates.IsNull) OracleUdt.SetValue(con, pUdt, "SDO_ORDINATES", SdoOrdinates); if (!SdoElemInfo.IsNull) OracleUdt.SetValue(con, pUdt, "SDO_ELEM_INFO", SdoElemInfo); if (!_sdoSridIsNull) OracleUdt.SetValue(con, pUdt, "SDO_SRID", SdoSrid); else OracleUdt.SetValue(con, pUdt, "SDO_SRID", DBNull.Value); if (!SdoPoint.IsNull) OracleUdt.SetValue(con, pUdt, "SDO_POINT", SdoPoint); } public void ToCustomObject(OracleConnection con, IntPtr pUdt) { object sdoGType = OracleUdt.GetValue(con, pUdt, "SDO_GTYPE"); _sdoGTypeIsNull = sdoGType == null || sdoGType is DBNull; if (!_sdoGTypeIsNull) SdoGType = (int)sdoGType; SdoOrdinates = (SdoOrdinates)OracleUdt.GetValue(con, pUdt, "SDO_ORDINATES"); SdoElemInfo = (SdoElemInfo)OracleUdt.GetValue(con, pUdt, "SDO_ELEM_INFO"); object sdoSrid = OracleUdt.GetValue(con, pUdt, "SDO_SRID"); if (!(sdoSrid == null || sdoSrid is DBNull)) SdoSrid = (int)sdoSrid; SdoPoint = (SdoPoint)OracleUdt.GetValue(con, pUdt, "SDO_POINT"); } #endregion #region INullable Members public bool IsNull { get { return _sdoGTypeIsNull; } } #endregion #region IOracleCustomTypeFactory Members public IOracleCustomType CreateObject() { return new SdoGeometry(); } #endregion } 

PS在我的项目中，Oracle发布了3个版本的ODP.NET。 有趣的是：适用于2.111.6.10版本的Oracle.DataAcess.dll的代码根本不适用于2.111.6.20！

不知道现在哪个版本的ODP.NET是实际的，但我上面发布的样本与2.111.6.10配合得很好。

希望这可以帮助。 祝好运！

Answer 2

在许多错误的开始之后，这篇文章在这里保存了我的培根（绑定到VARTAR2的TABLE OF VARCHAR2(100)的UDT TABLE OF VARCHAR2(100) ）。

突出点

• 创建一个类来保存嵌套/ UDT类型的数组（即varchar2(100)的字符串数组）
  • 该类必须实现IOracleCustomType和INullable接口。
  • 它还需要一个属性来保存数组（即string[] ），并且必须使用OracleArrayMapping属性标记该属性。
• 创建第二个UDT Factory类，它实现IOracleArrayTypeFactory ， IOracleCustomTypeFactory接口。 它需要以下方法
  • CreateObject – 创建存储类的新对象
  • CreateArray – 分配要在存储类中设置的字符串数组
  • CreateStatusArray – 保留每行的状态
• 工厂类还必须标记为OracleCustomTypeMapping("SCHEMA.UDT_TYPE") ，其中SCHEMA.UDT_TYPE与您的UDT类型匹配，即CREATE TYPE SCHEMA.UDT_TYPE AS TABLE OF VARCHAR2(100)

相比之下，参数的绑定很简单：

  var oracleArray = new MyArrayStorageClass { Array = new string[] {"Hello", "World"} }; command.CommandType = CommandType.StoredProcedure; var param = new OracleParameter("ip_parameterName", OracleDbType.Array) { // Case sensitive match to the `OracleCustomTypeMapping` on the factory UdtTypeName = "SCHEMA.UDT_TYPE", Value = oracleArray, Direction = ParameterDirection.Input, }; command.Parameters.Add(param); 

Answer 3

ODP.net支持用户定义的类型。 http://www.oracle.com/technology/tech/windows/odpnet/index.html

谷歌的例子或阅读手册。