在.Net中使用Oracle的表类型和对象类型

简介:

在一般的数据存取操作过程中,如果要对一个主表和对应的子表进行插入操作,那么我们最常见的写法就是写两个存储过程或者SQL语句,一个负责主表数据插入,一个负责子表数据插入,然后在一个事务中实现主表和子表数据的插入。

现在遇到一个问题是,能否在一个存储过程中实现主表和子表数据的插入呢?那么就需要将一对多的数据作为存储过程的参数传入。这种情况下就需要使用表类型。下面以一个学生和班级的例子来说明:

先建立一个班级表和一个学生表,一个班级里面有多个学生。


复制代码
ExpandedBlockStart.gif 代码
CREATE   TABLE  CLASS
(
   CLASSID     
NUMBER  ( 38 PRIMARY   KEY ,
   CLASSNAME   
VARCHAR2  ( 50  BYTE)  NOT   NULL
);

CREATE   TABLE  STUDENT
(
  STUID        
NUMBER ( 38 PRIMARY   KEY ,
  CLASSID      
NUMBER ( 38 )                        NOT   NULL ,
  STUNAME      NVARCHAR2(
50 )                     NOT   NULL ,
  STUGENDER    
CHAR ( 1  BYTE),
  STUBIRTHDAY  DATE,
  DESCRIPTION  NVARCHAR2(
2000 )
);

CREATE  SEQUENCE CLASSID;

CREATE  SEQUENCE STUDENTID;
复制代码

首先我们需要在Oracle中创建一个学生的对象类型,这个对象类型中就是学生的属性:

复制代码
CREATE   OR   REPLACE  type StudentType  as  object
(
       StuName nvarchar2(
50 ),
       StuGender 
char ( 1 ),
       StuBirthday date,
       StuDescription nvarchar2(
2000 )
);
复制代码

 

接下来是将这个学生类型创建成表类型:

CREATE   OR   REPLACE  type StuList  as   table   of  StudentType;

接下来就是写我们的一个插入存储过程,将班级和学生列表作为参数传入,具体脚本为:


复制代码
ExpandedBlockStart.gif 代码
CREATE   OR   REPLACE   PROCEDURE  ZY.AddClassStudent(

ClassName 
in   varchar2 ,
Students 
in  StuList
IS

BEGIN
   
insert   into  Class  values (classid.nextval,ClassName);
   
insert   into  Student(StuID,ClassID,StuName,Stugender,Stubirthday,Description)
   
select  studentid.nextval,classid.currval,StuName,StuGender,StuBirthday,studescription
   
from   TABLE (Students);
   EXCEPTION
     
WHEN  NO_DATA_FOUND  THEN
       
NULL ;
     
WHEN  OTHERS  THEN
       RAISE;
END  AddClassStudent;
复制代码

现在Oracle服务器上的各个对象已经创建完成,接下来就是要编写C#代码,连接到Oracle数据库,插入数据了。

在C#项目中添加Oracle.DataAccess的引用,这是Oracle为.Net开发的类库,可以从官网下载。添加引用后,再添加命名空间:

using  Oracle.DataAccess.Types;
using  Oracle.DataAccess.Client;

 

然后再创建Student对应的类:


复制代码
ExpandedBlockStart.gif 代码
public   class  Student : IOracleCustomType
    {
        
#region  IOracleCustomType Members

        
public   void  FromCustomObject(Oracle.DataAccess.Client.OracleConnection con, IntPtr pUdt)
        {
            
if  (StudentName  !=   null )
                OracleUdt.SetValue(con, pUdt, 
" STUNAME " , StudentName);
            
else
                
throw   new  NullReferenceException( " STUNAME is null " );
            OracleUdt.SetValue(con, pUdt, 
" STUGENDER " , Gender);
            OracleUdt.SetValue(con, pUdt, 
" STUBIRTHDAY " , Birthday);
            OracleUdt.SetValue(con, pUdt, 
" STUDESCRIPTION " , Description);
        }

        
public   void  ToCustomObject(Oracle.DataAccess.Client.OracleConnection con, IntPtr pUdt)
        {
            StudentName 
=  (String)OracleUdt.GetValue(con, pUdt,  " STUNAME " );
            Gender 
=  (String)OracleUdt.GetValue(con, pUdt,  " STUGENDER " );
            Birthday 
=  (DateTime)OracleUdt.GetValue(con, pUdt,  " STUBIRTHDAY " );
            Description 
=  (String)OracleUdt.GetValue(con, pUdt,  " STUDESCRIPTION " );
        }

        
#endregion

        [OracleObjectMappingAttribute(
" STUNAME " )]
        
public  String StudentName {  get set ; }

        [OracleObjectMapping(
" STUGENDER " )]
        
public   string  Gender {  get set ; }

        [OracleObjectMapping(
" STUBIRTHDAY " )]
        
public  DateTime Birthday {  get set ; }

        [OracleObjectMapping(
" STUDESCRIPTION " )]
        
public   string  Description {  get set ; }

    }
复制代码

并添加Student类对应Oracle对象类型的映射,通过Attribute来指定:


复制代码
ExpandedBlockStart.gif 代码
[OracleCustomTypeMappingAttribute( " STUDENTTYPE " )]
public   class  StudentFactory : IOracleCustomTypeFactory
{
    
#region  IOracleCustomTypeFactory Members

    
public  IOracleCustomType CreateObject()
    {
        
return   new  Student();
    }

    
#endregion
}
复制代码

现在StudentType类型已经创建完成,接下来就是创建StuList类型对应的类:


复制代码
ExpandedBlockStart.gif 代码
[OracleCustomTypeMappingAttribute( " STULIST " )]
public   class  StudentList_TabFactory : IOracleArrayTypeFactory
{
    
#region  IOracleArrayTypeFactory Members

    
public  Array CreateArray( int  numElems)
    {
        
return   new  Student[numElems];
    }

    
public  Array CreateStatusArray( int  numElems)
    {
        
return   null ;
    }

    
#endregion
}
复制代码

这里可以看到,返回的是Student的数组。现在准备工作都已经完成,接下来就是初始化一点数据,然后调用存储过程了,代码如下:


复制代码
ExpandedBlockStart.gif 代码
Student s1  =   new  Student() { StudentName  =   " 张三 " , Birthday  =  Convert.ToDateTime( " 1984/12/29 " ), Gender  =   " M " , Description  =   " HAHA。 "  };
           Student s2 
=   new  Student() { StudentName  =   " 李四 " , Birthday  =  Convert.ToDateTime( " 1982/12/29 " ), Gender  =   " F " , Description  =   " A。 "  };
           Student s3 
=   new  Student() { StudentName  =   " 王五 " , Birthday  =  Convert.ToDateTime( " 1982/1/29 " ), Gender  =   " M " , Description  =   " B。 "  };
           Student s4 
=   new  Student() { StudentName  =   " 小月月 " , Birthday  =  Convert.ToDateTime( " 1985/10/11 " ), Gender  =   " F " , Description  =   " C。 "  };
           List
< Student >  ss1  =   new  List < Student > ();
           ss1.Add(s1);
           ss1.Add(s2);
           ss1.Add(s3);
           ss1.Add(s4);

           
string  conn  =   " Data Source=BRDWDEV;User Id=zy;Password=123; " ;
           
using  (OracleConnection oc  =   new  OracleConnection(conn))
           {
               oc.Open();

               OracleCommand cmd 
=  oc.CreateCommand();
               cmd.CommandType 
=  System.Data.CommandType.StoredProcedure;

               cmd.CommandText 
=   " ZY.ADDCLASSSTUDENT " ;

               OracleParameter p0 
=   new  OracleParameter();
               p0.OracleDbType 
=  OracleDbType.Varchar2;
               p0.UdtTypeName 
=   " CLASSNAME " ;
               p0.Value 
=   " 测试班级名 " ;
               p0.Direction 
=  ParameterDirection.Input;
               cmd.Parameters.Add(p0);

               OracleParameter p1 
=   new  OracleParameter();
               p1.OracleDbType 
=  OracleDbType.Array;
               p1.Direction 
=  ParameterDirection.Input;
               p1.UdtTypeName 
=   " STULIST " ; // 注意这里是类型,而不是参数名
               p1.Value  =  ss1.ToArray(); // 注意这里应该是数组
               cmd.Parameters.Add(p1);

               
int  count  =  cmd.ExecuteNonQuery();
               Console.WriteLine(count);
               oc.Close();
           }
复制代码

以此类推,其实还可以把班级建立对象类型,然后再建立班级列表类型,这样就可在一个存储过程中插入多个班级,每个班级多个学生的数据。

目录
相关文章
|
2月前
|
开发框架 Oracle 关系型数据库
ASP.NET实验室LIS系统源码 Oracle数据库
LIS是HIS的一个组成部分,通过与HIS的无缝连接可以共享HIS中的信息资源,使检验科能与门诊部、住院部、财务科和临床科室等全院各部门之间协同工作。 
37 4
|
4月前
|
SQL Oracle 关系型数据库
java往oracle存clob类型的值时,字符长度过长怎么办?
java往oracle存clob类型的值时,字符长度过长怎么办?
70 1
|
3月前
|
Oracle 关系型数据库 数据库
Oracle查询优化-复制表的定义及数据
【1月更文挑战第5天】【1月更文挑战第14篇】在Oracle数据库中,复制表定义和复制表数据是两个常见的操作。
51 1
|
7月前
|
存储 SQL Oracle
Oracle数据库批量删除表、视图、序列、存储过程、函数脚本
Oracle数据库批量删除表、视图、序列、存储过程、函数脚本
68 0
|
1月前
|
存储 Oracle 关系型数据库
Oracle系列之七:表的创建与管理
Oracle系列之七:表的创建与管理
|
2月前
|
Oracle 关系型数据库 数据库
Flink Sink to Oracle 存在字段CLOB类型,如何处理错误”ORA-01461: 仅能绑定要插入LONG的LONG值“
做Flink CDC同步数据过程中,目标是Oracle数据库,其中某个字段较大被设置为CLOB类型,其中会遇到异常,”ORA-01461: 仅能绑定要插入LONG的LONG值“
|
3月前
|
SQL Oracle 关系型数据库
Oracle PL/SQL 第五章–复合类型
Oracle PL/SQL 第五章–复合类型
|
4月前
|
Oracle 关系型数据库 数据管理
.NET医院检验系统LIS源码,使用了oracle数据库,保证数据的隔离和安全性
LIS系统实现了实验室人力资源管理、标本管理、日常事务管理、网络管理、检验数据管理(采集、传输、处理、输出、发布)、报表管理过程的自动化,使实验室的操作人员和管理者从繁杂的手工劳作中解放出来,提高了检验人员的工作效率和效益,降低了劳动成本和差错发生率。
|
4月前
|
Oracle 关系型数据库
Oracle - 表操作语句
Oracle - 表操作语句
25 0
|
5月前
|
Oracle 关系型数据库 数据库
在Flink CDC中,使用Oracle 11g数据库的NUMBER类型作为主键
在Flink CDC中,使用Oracle 11g数据库的NUMBER类型作为主键
48 1