Chinaunix

标题: （附代码）关于OCI的一个问题 [打印本页]

作者: leeleec 时间: 2006-12-20 17:16
标题: （附代码）关于OCI的一个问题
代码如下：
#define BATCHRECORDNUM 5       //批量插入的记录条数
#define DATASIZE 8192                      //预分配空间的大小

char ***pBuffer;                                     //数据缓冲区指针
int colNum;                                                             //记录字段个数

....

pBuffer = (char ***) malloc(sizeof(char **) * BATCHRECORDNUM);
for(i = 0; i < BATCHRECORDNUM; i++)
{
      pBuffer[i] = (char **) malloc(sizeof(char *) * colNum);
}

...
for (Rec = 0; Rec < BATCHRECORDNUM; Rec++)
{
      for(i = 0; i < colNum; i++)
      {
            ...
      pBuffer[Rec][i] = (char *) malloc(sizeof(char) * DATASIZE);
      memset(pBuffer[Rec][i], '\0', sizeof(char) * DATASIZE);
      }
}
...

//取数据
for (Rec = 0; Rec< Result.RecordNum; Rec++)
{
      for(i = 0; i < colNum; i++)
      {
            //此处取出数据存入pBuffer[Rec][i]
            ...
            buffsize = DATASIZE - 1;

      }

      //当读取BATCHRECORDNUM条记录时，导入一次
      if(Rec % BATCHRECORDNUM == BATCHRECORDNUM-1)
      {
            checkerr(myerrhp, OCIHandleAlloc( (dvoid *) myenvhp, (dvoid **) &stmthp, OCI_HTYPE_STMT, 0, 0));

            checkerr(myerrhp, OCIStmtPrepare(stmthp, myerrhp, (text *) chInsertTemplate, (ub4)strlen(chInsertTemplate), OCI_NTV_SYNTAX, OCI_DEFAULT));

            for(j = 0; j < colNum; j++)
            {
                     checkerr( myerrhp, OCIBindByPos(stmthp, &bndp[j], myerrhp, j + 1, (dvoid *)pBuffer[0][j],
            (sword) sizeof(pBuffer[0][j]), colType[j], 0, 0, 0, 0, 0, OCI_DEFAULT));
                     checkerr(myerrhp, OCIBindArrayOfStruct(bndp[j] , myerrhp, sizeof(pBuffer[0][j]), 0, 0, 0));
            }


      //！！！此处出错
      if((status = OCIStmtExecute(mysvchp, stmthp, myerrhp, (ub4) BATCHRECORDNUM, (ub4) 0, (OCISnapshot *) NULL, (OCISnapshot *) NULL, OCI_DEFAULT)))
      {
      exporterr("Execute batch insert task error!", __FILE__, (char *)__FUNCTION__, __LINE__);
      checkerr(myerrhp, status);
      return -1;
      }

nImportFlag = 0;
      }

}

if(Rec % BATCHRECORDNUM != BATCHRECORDNUM-1 && nImportFlag == 1)
{
      checkerr(myerrhp, OCIHandleAlloc( (dvoid *) myenvhp, (dvoid **) &stmthp, OCI_HTYPE_STMT, 0, 0));

      checkerr(myerrhp, OCIStmtPrepare(stmthp, myerrhp, (text *) chInsertTemplate, (ub4)strlen(chInsertTemplate), OCI_NTV_SYNTAX, OCI_DEFAULT));

      for(j = 0; j < colNum; j++)
      {
            checkerr( myerrhp, OCIBindByPos(stmthp, &bndp[j], myerrhp, j + 1, (dvoid *)pBuffer[0][j],
            (sword) sizeof(pBuffer[0][j]), colType[j], 0, 0, 0, 0, 0, OCI_DEFAULT));
            checkerr(myerrhp, OCIBindArrayOfStruct(bndp[j] , myerrhp, sizeof(pBuffer[0][j]), 0, 0, 0));
      }


if((status = OCIStmtExecute(mysvchp, stmthp, myerrhp, (ub4) ((Result.RecordNum)%1000), (ub4) 0,
      (OCISnapshot *) NULL, (OCISnapshot *) NULL, OCI_DEFAULT)))
{
      exporterr("Execute batch insert task error!", __FILE__, (char *)__FUNCTION__, __LINE__);
      checkerr(myerrhp, status);
      return -1;
      }
nImportFlag = 0;
}

/* Commit the change. */
if (status = OCITransCommit(mysvchp, myerrhp, 0))
{
      checkerr(myerrhp, status);
}

用GDB跟踪取数据的部分没有问题，总是执行到OCIStmtExecute报错，判断是OCIBINDBYPOS错误，但是找不到错误在哪里，请教一下高手！

作者: gangjh 时间: 2006-12-21 08:25
樓主代碼貼得也不全
也有點亂,
有心測試一下也只好放棄了

作者: 我要学C 时间: 2006-12-21 10:32
欢迎linux下C程序员及爱好C编程的进取人士！号是：29697377

作者: leeleec 时间: 2006-12-21 16:31
呵呵，谢谢二楼的。
我目前简化了问题，改成了一条一操作的方式。
现在的问题是当有DATE字段时，插入出错！读取的数据是字符串，如"1997.01.01",报
Error - ORA-01483: invalid length for DATE or NUMBER bind variable
的错误，请教如何将DATE类型数据通过OCIbindbypos插入数据库，非要
使用insert into temp(date1, char1) values(to_date(:date1, "YYYY-MM-DD", :char1)进行绑定才可以吗？
这种方式的弊端在于对于输入的日期数据格式有了限制，不够灵活啊！
谁能给点建议？谢谢

欢迎光临 Chinaunix (http://bbs.chinaunix.net/)