Oracle存储过程（Stored Procedure）使用自定义类实体参数

如何在Oracle存储过程使用自定义类实体参数呢？

语言：C#

1.首先新建表、Sequence、存储过程、以及Oracle自定义Type

--新建dog表
create table tbl_dog
(
id number,
DogName nvarchar2(20),
DogColor nvarchar2(20),
DogAge number
);
--为dog表新建sequence为ID使用
create sequence seq_dog
minvalue 1
maxvalue 999999
start with 1
increment by 1
cache 50
cycle;
--新建oracle的type，与C#的Dog类对应
create or replace type dog_type as object(
       DogName nvarchar2(20),
       DogColor nvarchar2(20),
       DogAge nvarchar2(50)
);
--新建oracle的type，存放Dog类型的数组
create or replace type dog_type_array as table of dog_type;
--测试存储过程，主要功能是将传入的dog数组逐条写入数据库
create or replace procedure sp_insert_dog(dogList in dog_type_array) as
begin
  for i in 1 .. dogList.count loop 
    insert into tbl_dog(
                       id,
                       DogName,
                       DogColor,
                       DogAge
                      )
                      values
                      (
                       seq_dog.nextval,
                       dogList(i).DogName,
                       dogList(i).DogColor,
                       dogList(i).DogAge
                      );
  end loop;
end sp_insert_dog;

2.然后我们定义一个Dog类，需要实现IOracleCustomType接口（引用Oracle.DataAccess.dll）

    [DataContract]
    public class Dog : IOracleCustomType
    {
        [DataMember]
        [OracleObjectMappingAttribute("DOGNAME")]
        public string DogName { get; set; }
        [DataMember]
        [OracleObjectMappingAttribute("DOGCOLOR")]
        public string DogColor { get; set; }
        [DataMember]
        [OracleObjectMappingAttribute("DOGAGE")]
        public Int64 DogAge { get; set; }

        #region IOracleCustomType Members
        public void FromCustomObject(Oracle.DataAccess.Client.OracleConnection con, IntPtr pUdt)
        {
            OracleUdt.SetValue(con, pUdt, "DOGNAME", DogName);
            OracleUdt.SetValue(con, pUdt, "DOGCOLOR", DogColor);
            OracleUdt.SetValue(con, pUdt, "DOGAGE", DogAge);
        }

        public void ToCustomObject(Oracle.DataAccess.Client.OracleConnection con, IntPtr pUdt)
        {
            DogName = (String)OracleUdt.GetValue(con, pUdt, "DOGNAME");
            DogColor = (String)OracleUdt.GetValue(con, pUdt, "DOGCOLOR");
            DogAge = (Int64)OracleUdt.GetValue(con, pUdt, "DOGAGE");
        }

        #endregion
    }

    [OracleCustomTypeMappingAttribute("DOG_TYPE")]
    public class DogFactory : IOracleCustomTypeFactory
    {
        public IOracleCustomType CreateObject()
        {
            return new Dog();
        }
    }

    [OracleCustomTypeMappingAttribute("DOG_TYPE_ARRAY")]
    public class DogListFactory : IOracleArrayTypeFactory
    {
        public Array CreateArray(int numElems)
        {
            return new Dog[numElems];
        }
        public Array CreateStatusArray(int numElems)
        {
            return null;
        }
    }

3.执行存储过程的函数

    public class ExcuteStoreProcedure
    {
        public static int ExecuteDogs(List<Dog> dogList)
        {
            try
            {
                const string conn = @"此处为Oracle链接字符串";
                using (var oc = new Oracle.DataAccess.Client.OracleConnection(conn))
                {
                    oc.Open();
                    Oracle.DataAccess.Client.OracleCommand cmd = oc.CreateCommand();
                    cmd.CommandType = CommandType.StoredProcedure;
                    cmd.CommandText = "SP_INSERT_DOG";

                    var p1 = new Oracle.DataAccess.Client.OracleParameter
                    {
                        OracleDbType = Oracle.DataAccess.Client.OracleDbType.Array,
                        Direction = ParameterDirection.Input,
                        UdtTypeName = "DOG_TYPE_ARRAY"
                    };
                    if (dogList != null)
                    {
                        p1.Value = dogList.ToArray();
                    }
                    cmd.Parameters.Add(p1);
                    return cmd.ExecuteNonQuery();
                }
            }
            catch (Exception)
            {
                return -1;
            }
        }
    }

4.执行入口

        private static void Main()
        {
            var dogs = new List<Dog>
            {
                new Dog {DogAge = 1, DogColor = "Red", DogName = "红牛"},
                new Dog {DogAge = 2, DogColor = "Black", DogName = "黑旋风"},
                new Dog {DogAge = 3, DogColor = "Green", DogName = "绿帽子"},
                new Dog {DogAge = 4, DogColor = "White", DogName = "白鹤"},
                new Dog {DogAge = 5, DogColor = "Blue", DogName = "布鲁"},
                new Dog {DogAge = 6, DogColor = "Yellow", DogName = "皇帝"}
            };
            ExcuteStoreProcedure.ExecuteDogs(dogs);
        }

5.看一下执行结果，可以看到数据已经插进去了。

6.那么如何使用PL/SQL Developer调试这种参数的存储过程呢？

很简单，可以参考下面SQL代码：

declare
  -- Non-scalar parameters require additional processing 
  doglist dog_type_array:= dog_type_array(dog_type('一黑','Black',8),
  dog_type('二黑','Black',8),
  dog_type('三黑','Black',8),
  dog_type('四黑','Black',8));
begin
  -- Call the procedure
  sp_insert_dog(doglist => doglist);
end;

执行一下，数据入库。