访问www.tomcoding.com网站,学习Oracle内部数据结构,详细文档说明,下载Oracle的exp/imp,DUL,logminer,ASM工具的源代码,学习高技术含量的内容。

在前面我们介绍了向数据库表中插入数据的方法,在例子中一次插入一条数据,对于处理大量数据的场景这种方式显然效率低下。幸运的是OCI提供了让我们批量插入大量数据的方法,这就是数组插入。

数组插入的步骤与单条插入时基本一样,只是在绑定占位符时,输入的是一个数组地址,而不是一个单独的变量地址,indp,alenp,rcodep也都指向一个数组。调用完OCIBindByPos()函数后,还要调用一个OCIBindArrayOfStruct()函数,这个函数定义每个变量跳过的字节个数,以便从开始能找到后续变量的地址。函数原型和参数如下。

sword OCIBindArrayOfStruct ( OCIBind *bindp,
    OCIError *errhp,
    ub4 pvskip,
    ub4 indskip,
    ub4 alskip,
    ub4 rcskip );

bindp是一个输入/输出参数,是一个绑定句柄,由前一个函数OCIBindByPos()隐式分配得来。

errhp是一个输入/输出参数,是个错误句柄,用于获取错误码和错误信息文本。

pvskip是一个输入参数,是绑定的数据数组值要跳过的字节数。

indskip是一个输入参数,是指示变量要跳过的字节数。

alskip是一个输入参数,是实际的数据长度跳过的字节数。

rcskip是一个输入参数,是字段级出错返回码跳过的字节数。

下面来看看这个函数的用法,还是举一个例子来说明,先看一下我们前面创建的test_tab表,表结构如下。CREATE TABLE test_tab (ID NUMBER, NAME CHAR(30), ADD VARCHAR2(200))。假如我们只向表中插入ID字段的数据,插入10条记录,我们先定义一个整数数组int id[10],用于存放插入的数据,然后定义三个数组sb2 ind_id[10],ub2 alen_id[10],ub2 rcode_id[10]分别用于指示变量,实际长度和返回码。我们先来看一下OCIBindArrayOfStruct()函数中跳过参数的取值,先看插入的数值,id[0]的地址与数组首地址id是一样的,id[1]的地址是id+sizeof(int),id[2]的地址是id+2*sizeof(int),可以看到每个元素相对于前一个元素跳过的字节数是sizeof(int),就是pvskip的值。再看指示变量,ind_id[0]的地址与数组首地址ind_id一样,ind_id[1]的地址是ind_id+sizeof(sb2),当前元素相对与前一个元素跳过的字节数是sizeof(sb2),就是indskip的值。同样我们可以判断alskip和rcskip的值。

下面我们看一个完整的例子,用数组在test_tab表中插入10条数据。

OCIEnv		  *envhp = NULL;
OCIError	  *errhp = NULL;
OCIServer	  *svrhp = NULL;
OCISession	*usrhp = NULL;
OCISvcCtx	  *svchp = NULL;
OCIStmt		  *smthp = NULL;/* 数组插入10条数据 */
int insert_array(void){int     i;sword	  rc;int		  slen;sb2		  ind_id[10];sb2		  ind_name[10];sb2		  ind_addr[10];ub2		  alen_id[10];ub2		  alen_name[10];ub2		  alen_addr[10];ub2		  rcode_id[10];ub2		  rcode_name[10];ub2		  rcode_addr[10];int32_t	id[10];char		name[10][32];char		addr[10][256];OCIBind	*bndp;char		sqltxt[1024];/* 分配OCI语句句柄 */rc = OCIHandleAlloc((void *)envhp,(void **)&smthp,OCI_HTYPE_STMT,0,(void **)NULL);if (rc != OCI_SUCCESS) {fprintf(stderr, "OCIHandleAlloc() - allocate statement handle error !\n");return (-1);}/* 生成SQL语句文本 */strcpy(sqltxt, "INSERT INTO test_tab (ID, NAME, ADDR) VALUES (:1, :2, :3)");slen = strlen(sqltxt);/* 准备语句 */if (check_oci_error(errhp,OCIStmtPrepare(smthp, errhp, (const OraText *)sqltxt, slen,OCI_NTV_SYNTAX, OCI_DEFAULT)) < 0)return (-1);/* 绑定第一个占位符ID,绑定数组地址 */if (check_oci_error(errhp,OCIBindByPos((OCIStmt *)smthp,(OCIBind **)&bndp,errhp,(ub4)1,	            /* position */(void *)id,         /* valuep */(sb4)4,             /* value_sz */(ub2)SQLT_INT,      /* dty */(void *)ind_id,     /* indp */(ub2 *)alen_id,     /* alenp */(ub2 *)rcode_id,    /* column return code pointer */(ub4)0,             /* maxarr_len */(ub4 *)NULL,        /* curelep */(ub4)OCI_DEFAULT)   /* mode */) < 0)return (-1);/* 指定绑定参数跳过的字节数 */if (check_oci_error(errhp,OCIBindArrayOfStruct(bndp,sizeof(int32_t),sizeof(sb2),sizeof(ub2),sizeof(ub2))) < 0)return (-1);/* 绑定第二个占位符NAME */if (check_oci_error(errhp,OCIBindByPos((OCIStmt *)smthp,(OCIBind **)&bndp,errhp,(ub4)2,             /* position */(void *)name,       /* valuep */(sb4)30,            /* value_sz */(ub2)SQLT_STR,      /* dty */(void *)ind_name,   /* indp */(ub2 *)alen_name,   /* alenp */(ub2 *)rcode_name,  /* column return code pointer */(ub4)0,             /* maxarr_len */(ub4 *)NULL,        /* curelep */(ub4)OCI_DEFAULT)   /* mode */) < 0)return (-1);/* 指定绑定参数跳过的字节数,name定义的长度为32 */if (check_oci_error(errhp,OCIBindArrayOfStruct(bndp,32,sizeof(sb2),sizeof(ub2),sizeof(ub2))) < 0)return (-1);/* 绑定第三个占位符ADDR */if (check_oci_error(errhp,OCIBindByPos((OCIStmt *)smthp,(OCIBind **)&bndp,errhp,(ub4)3,             /* position */(void *)addr,       /* valuep */(sb4)200,           /* value_sz */(ub2)SQLT_STR,      /* dty */(void *)ind_addr,   /* indp */(ub2 *)alen_addr,   /* alenp */(ub2 *)rcode_addr,  /* column return code pointer */(ub4)0,             /* maxarr_len */(ub4 *)NULL,        /* curelep */(ub4)OCI_DEFAULT)   /* mode */) < 0)return (-1);/* 指定绑定参数跳过的字节数,addr定义的长度为256 */if (check_oci_error(errhp,OCIBindArrayOfStruct(bndp,256,sizeof(sb2),sizeof(ub2),sizeof(ub2))) < 0)return (-1);/* 赋值绑定的变量数据 */for (i=0; i<10; i++) {id[i] = i+10;memset(name[i], 'a', 10);memset(addr[i], 'b', 20);name[i][10] = '\0';addr[i][20] = '\0';/* 指示符赋值为0,插入非NULL数据 */ind_id[i]    = 0;ind_name[i]  = 0;ind_addr[i]  = 0;/* 赋值变量的真实数据长度 */alen_id[i]   = sizeof(int32_t);alen_name[i] = strlen(name[i]) + 1;alen_addr[i] = strlen(addr[i]) + 1;}/* 执行OCI语句,这里iters要赋值为10,表示插入数组中的10条记录 */if (check_oci_error(errhp,OCIStmtExecute(svchp,smthp,              /* stmthp */errhp,              /* errhp */10,                 /* iters */0,                  /* rowoff */NULL,               /* snap_in */NULL,               /* snap_out */OCI_DEFAULT)        /* mode */) < 0)return (-1);/* 提交改变的数据 */if (check_oci_error(errhp,OCITransCommit(svchp, errhp, OCI_DEFAULT)) < 0)return (-1);return (0);
}

要注意的是在OCIStmtExecute()函数中iters的值要输入10,才能插入数组中的10条数据,如果写成1,虽然数组中有10条记录,也只能插入1条。