dbclass.cpp

ORACLE数据库的批量插入例子

{
  struct sqlexd sqlstm;
  sqlstm.sqlvsn = 10;
  sqlstm.arrsiz = 0;
  sqlstm.sqladtp = &sqladt;
  sqlstm.sqltdsp = &sqltds;
  sqlstm.iters = (unsigned int  )1;
  sqlstm.offset = (unsigned int  )5;
  sqlstm.cud = sqlcud0;
  sqlstm.sqlest = (unsigned char  *)&sqlca;
  sqlstm.sqlety = (unsigned short)256;
  sqlstm.occurs = (unsigned int  )0;
  sqlcxt(&m_context, &sqlctx, &sqlstm, &sqlfpn);
}


  if (convert_Connected_Database == DATABASE_STATUS_CONNECTED) {
		char db_disconnect[200];
  	memset(db_disconnect,0,sizeof(db_disconnect));
  	sprintf(db_disconnect,"Convert Oracle Disconnect");
		DisplayConvertInGUI(db_disconnect);
  }
	convert_Connected_Database = DATABASE_STATUS_DISCONNECTED;	
	return 0;
}

void CDbClass::convert_sql_error()
{
	on_error();
}

int CDbClass::InsertIntoRoarMsg(char* time1,char* time2)
{
	/* EXEC SQL BEGIN DECLARE SECTION; */ 

		char temp1[3000][7];
		  char temp2[3000][7];
		  char temp3[3000][7];
		  char temp4[3000][7];
		  char temp5[3000][7];
		  char temp6[3000][7];
		  char temp7[3000][7];
		  char temp8[3000][7];
		  char temp9[3000][7];
		  char temp10[3000][7];
		  char temp11[3000][7];
		  char temp12[3000][7];
		  char temp13[3000][7];
		  char temp14[3000][7];
		  char temp15[3000][7];
		  char temp16[3000][7];
		  char temp17[3000][7];
		  char temp18[3000][7];
		  char temp19[3000][7];
		  char temp20[3000][7];
		  char temp21[3000][7];
		  char temp22[3000][7];
		  int  rec_count;
 	/* EXEC SQL END DECLARE SECTION; */ 

	
	/* EXEC SQL CONTEXT USE :m_context; */ 

	/* EXEC SQL WHENEVER SQLERROR DO convert_sql_error(); */ 

	/* EXEC SQL WHENEVER NOT FOUND goto error; */ 


  Randomize();
  int j;
  char p[7];
  for (int i=0;i<3000;i++) {
    j = random(50000);
    itoa(j,p,10);
    strcpy(temp1[i],p);
    strcpy(temp2[i],p);
    strcpy(temp3[i],p);
    strcpy(temp4[i],p);
    strcpy(temp5[i],p);
    strcpy(temp6[i],p);
    strcpy(temp7[i],p);
    strcpy(temp8[i],p);
    strcpy(temp9[i],p);
    strcpy(temp10[i],p);
    strcpy(temp11[i],p);
    strcpy(temp12[i],p);
    strcpy(temp13[i],p);
    strcpy(temp14[i],p);
    strcpy(temp15[i],p);
    strcpy(temp16[i],p);
    strcpy(temp17[i],p);
    strcpy(temp18[i],p);
    strcpy(temp19[i],p);
    strcpy(temp20[i],p);
    strcpy(temp21[i],p);
    strcpy(temp22[i],p);
  }
	rec_count = 3000;
	
	time_t t;
	time(&t);
	struct tm *tblock = localtime(&t);
	strftime(time1, 20, "%Y-%m-%d %H:%M:%S", tblock);

	convert_error_flag = 0;
	/* EXEC SQL for :rec_count Insert into ROAR_MSG(MSG_ID,NLEN,BDCSID,WSTARTYEAR,BSTARTMON,BSTARTDAY,START_TIME,SPC_TYPE,OPC,DPC,CALLING_SSN,CALLED_SSN,CALLING_GT,CALLED_GT,IMSI,MSISDN,HLR,VLR,OPERATE_CODE,ERROR,RESP_TIME,STATUS)
		VALUES(:temp1,:temp2,:temp3,:temp4,:temp5,:temp6,:temp7,:temp8,:temp9,:temp10,:temp11,:temp12,:temp13,:temp14,:temp15,:temp16,:temp17,:temp18,:temp19,:temp20,:temp21,:temp22); */

{
 struct sqlexd sqlstm;
 sqlstm.sqlvsn = 10;
 sqlstm.arrsiz = 22;
 sqlstm.sqladtp = &sqladt;
 sqlstm.sqltdsp = &sqltds;
 sqlstm.stmt = "insert into ROAR_MSG (MSG_ID,NLEN,BDCSID,WSTARTYEAR,BSTARTM\
ON,BSTARTDAY,START_TIME,SPC_TYPE,OPC,DPC,CALLING_SSN,CALLED_SSN,CALLING_GT,CA\
LLED_GT,IMSI,MSISDN,HLR,VLR,OPERATE_CODE,ERROR,RESP_TIME,STATUS) values (:b1,\
:b2,:b3,:b4,:b5,:b6,:b7,:b8,:b9,:b10,:b11,:b12,:b13,:b14,:b15,:b16,:b17,:b18,\
:b19,:b20,:b21,:b22)";
 sqlstm.iters = (unsigned int  )rec_count;
 sqlstm.offset = (unsigned int  )20;
 sqlstm.cud = sqlcud0;
 sqlstm.sqlest = (unsigned char  *)&sqlca;
 sqlstm.sqlety = (unsigned short)256;
 sqlstm.occurs = (unsigned int  )0;
 sqlstm.sqhstv[0] = (         void  *)temp1;
 sqlstm.sqhstl[0] = (unsigned int  )7;
 sqlstm.sqhsts[0] = (         int  )7;
 sqlstm.sqindv[0] = (         void  *)0;
 sqlstm.sqinds[0] = (         int  )0;
 sqlstm.sqharm[0] = (unsigned int  )0;
 sqlstm.sqharc[0] = (unsigned int   *)0;
 sqlstm.sqadto[0] = (unsigned short )0;
 sqlstm.sqtdso[0] = (unsigned short )0;
 sqlstm.sqhstv[1] = (         void  *)temp2;
 sqlstm.sqhstl[1] = (unsigned int  )7;
 sqlstm.sqhsts[1] = (         int  )7;
 sqlstm.sqindv[1] = (         void  *)0;
 sqlstm.sqinds[1] = (         int  )0;
 sqlstm.sqharm[1] = (unsigned int  )0;
 sqlstm.sqharc[1] = (unsigned int   *)0;
 sqlstm.sqadto[1] = (unsigned short )0;
 sqlstm.sqtdso[1] = (unsigned short )0;
 sqlstm.sqhstv[2] = (         void  *)temp3;
 sqlstm.sqhstl[2] = (unsigned int  )7;
 sqlstm.sqhsts[2] = (         int  )7;
 sqlstm.sqindv[2] = (         void  *)0;
 sqlstm.sqinds[2] = (         int  )0;
 sqlstm.sqharm[2] = (unsigned int  )0;
 sqlstm.sqharc[2] = (unsigned int   *)0;
 sqlstm.sqadto[2] = (unsigned short )0;
 sqlstm.sqtdso[2] = (unsigned short )0;
 sqlstm.sqhstv[3] = (         void  *)temp4;
 sqlstm.sqhstl[3] = (unsigned int  )7;
 sqlstm.sqhsts[3] = (         int  )7;
 sqlstm.sqindv[3] = (         void  *)0;
 sqlstm.sqinds[3] = (         int  )0;
 sqlstm.sqharm[3] = (unsigned int  )0;
 sqlstm.sqharc[3] = (unsigned int   *)0;
 sqlstm.sqadto[3] = (unsigned short )0;
 sqlstm.sqtdso[3] = (unsigned short )0;
 sqlstm.sqhstv[4] = (         void  *)temp5;
 sqlstm.sqhstl[4] = (unsigned int  )7;
 sqlstm.sqhsts[4] = (         int  )7;
 sqlstm.sqindv[4] = (         void  *)0;
 sqlstm.sqinds[4] = (         int  )0;
 sqlstm.sqharm[4] = (unsigned int  )0;
 sqlstm.sqharc[4] = (unsigned int   *)0;
 sqlstm.sqadto[4] = (unsigned short )0;
 sqlstm.sqtdso[4] = (unsigned short )0;
 sqlstm.sqhstv[5] = (         void  *)temp6;
 sqlstm.sqhstl[5] = (unsigned int  )7;
 sqlstm.sqhsts[5] = (         int  )7;
 sqlstm.sqindv[5] = (         void  *)0;
 sqlstm.sqinds[5] = (         int  )0;
 sqlstm.sqharm[5] = (unsigned int  )0;
 sqlstm.sqharc[5] = (unsigned int   *)0;
 sqlstm.sqadto[5] = (unsigned short )0;
 sqlstm.sqtdso[5] = (unsigned short )0;
 sqlstm.sqhstv[6] = (         void  *)temp7;
 sqlstm.sqhstl[6] = (unsigned int  )7;
 sqlstm.sqhsts[6] = (         int  )7;
 sqlstm.sqindv[6] = (         void  *)0;
 sqlstm.sqinds[6] = (         int  )0;
 sqlstm.sqharm[6] = (unsigned int  )0;
 sqlstm.sqharc[6] = (unsigned int   *)0;
 sqlstm.sqadto[6] = (unsigned short )0;
 sqlstm.sqtdso[6] = (unsigned short )0;
 sqlstm.sqhstv[7] = (         void  *)temp8;
 sqlstm.sqhstl[7] = (unsigned int  )7;
 sqlstm.sqhsts[7] = (         int  )7;
 sqlstm.sqindv[7] = (         void  *)0;
 sqlstm.sqinds[7] = (         int  )0;
 sqlstm.sqharm[7] = (unsigned int  )0;
 sqlstm.sqharc[7] = (unsigned int   *)0;
 sqlstm.sqadto[7] = (unsigned short )0;
 sqlstm.sqtdso[7] = (unsigned short )0;
 sqlstm.sqhstv[8] = (         void  *)temp9;
 sqlstm.sqhstl[8] = (unsigned int  )7;
 sqlstm.sqhsts[8] = (         int  )7;
 sqlstm.sqindv[8] = (         void  *)0;
 sqlstm.sqinds[8] = (         int  )0;
 sqlstm.sqharm[8] = (unsigned int  )0;
 sqlstm.sqharc[8] = (unsigned int   *)0;
 sqlstm.sqadto[8] = (unsigned short )0;
 sqlstm.sqtdso[8] = (unsigned short )0;
 sqlstm.sqhstv[9] = (         void  *)temp10;
 sqlstm.sqhstl[9] = (unsigned int  )7;
 sqlstm.sqhsts[9] = (         int  )7;
 sqlstm.sqindv[9] = (         void  *)0;
 sqlstm.sqinds[9] = (         int  )0;
 sqlstm.sqharm[9] = (unsigned int  )0;
 sqlstm.sqharc[9] = (unsigned int   *)0;
 sqlstm.sqadto[9] = (unsigned short )0;
 sqlstm.sqtdso[9] = (unsigned short )0;
 sqlstm.sqhstv[10] = (         void  *)temp11;
 sqlstm.sqhstl[10] = (unsigned int  )7;
 sqlstm.sqhsts[10] = (         int  )7;
 sqlstm.sqindv[10] = (         void  *)0;
 sqlstm.sqinds[10] = (         int  )0;
 sqlstm.sqharm[10] = (unsigned int  )0;
 sqlstm.sqharc[10] = (unsigned int   *)0;
 sqlstm.sqadto[10] = (unsigned short )0;
 sqlstm.sqtdso[10] = (unsigned short )0;
 sqlstm.sqhstv[11] = (         void  *)temp12;
 sqlstm.sqhstl[11] = (unsigned int  )7;
 sqlstm.sqhsts[11] = (         int  )7;
 sqlstm.sqindv[11] = (         void  *)0;
 sqlstm.sqinds[11] = (         int  )0;
 sqlstm.sqharm[11] = (unsigned int  )0;
 sqlstm.sqharc[11] = (unsigned int   *)0;
 sqlstm.sqadto[11] = (unsigned short )0;
 sqlstm.sqtdso[11] = (unsigned short )0;
 sqlstm.sqhstv[12] = (         void  *)temp13;
 sqlstm.sqhstl[12] = (unsigned int  )7;
 sqlstm.sqhsts[12] = (         int  )7;
 sqlstm.sqindv[12] = (         void  *)0;
 sqlstm.sqinds[12] = (         int  )0;
 sqlstm.sqharm[12] = (unsigned int  )0;
 sqlstm.sqharc[12] = (unsigned int   *)0;
 sqlstm.sqadto[12] = (unsigned short )0;
 sqlstm.sqtdso[12] = (unsigned short )0;
 sqlstm.sqhstv[13] = (         void  *)temp14;
 sqlstm.sqhstl[13] = (unsigned int  )7;
 sqlstm.sqhsts[13] = (         int  )7;
 sqlstm.sqindv[13] = (         void  *)0;
 sqlstm.sqinds[13] = (         int  )0;
 sqlstm.sqharm[13] = (unsigned int  )0;
 sqlstm.sqharc[13] = (unsigned int   *)0;
 sqlstm.sqadto[13] = (unsigned short )0;
 sqlstm.sqtdso[13] = (unsigned short )0;
 sqlstm.sqhstv[14] = (         void  *)temp15;
 sqlstm.sqhstl[14] = (unsigned int  )7;
 sqlstm.sqhsts[14] = (         int  )7;
 sqlstm.sqindv[14] = (         void  *)0;
 sqlstm.sqinds[14] = (         int  )0;
 sqlstm.sqharm[14] = (unsigned int  )0;
 sqlstm.sqharc[14] = (unsigned int   *)0;
 sqlstm.sqadto[14] = (unsigned short )0;
 sqlstm.sqtdso[14] = (unsigned short )0;
 sqlstm.sqhstv[15] = (         void  *)temp16;
 sqlstm.sqhstl[15] = (unsigned int  )7;
 sqlstm.sqhsts[15] = (         int  )7;
 sqlstm.sqindv[15] = (         void  *)0;
 sqlstm.sqinds[15] = (         int  )0;
 sqlstm.sqharm[15] = (unsigned int  )0;
 sqlstm.sqharc[15] = (unsigned int   *)0;
 sqlstm.sqadto[15] = (unsigned short )0;
 sqlstm.sqtdso[15] = (unsigned short )0;
 sqlstm.sqhstv[16] = (         void  *)temp17;
 sqlstm.sqhstl[16] = (unsigned int  )7;
 sqlstm.sqhsts[16] = (         int  )7;
 sqlstm.sqindv[16] = (         void  *)0;
 sqlstm.sqinds[16] = (         int  )0;
 sqlstm.sqharm[16] = (unsigned int  )0;
 sqlstm.sqharc[16] = (unsigned int   *)0;
 sqlstm.sqadto[16] = (unsigned short )0;
 sqlstm.sqtdso[16] = (unsigned short )0;
 sqlstm.sqhstv[17] = (         void  *)temp18;
 sqlstm.sqhstl[17] = (unsigned int  )7;
 sqlstm.sqhsts[17] = (         int  )7;
 sqlstm.sqindv[17] = (         void  *)0;
 sqlstm.sqinds[17] = (         int  )0;
 sqlstm.sqharm[17] = (unsigned int  )0;
 sqlstm.sqharc[17] = (unsigned int   *)0;
 sqlstm.sqadto[17] = (unsigned short )0;
 sqlstm.sqtdso[17] = (unsigned short )0;
 sqlstm.sqhstv[18] = (         void  *)temp19;
 sqlstm.sqhstl[18] = (unsigned int  )7;
 sqlstm.sqhsts[18] = (         int  )7;
 sqlstm.sqindv[18] = (         void  *)0;
 sqlstm.sqinds[18] = (         int  )0;
 sqlstm.sqharm[18] = (unsigned int  )0;
 sqlstm.sqharc[18] = (unsigned int   *)0;
 sqlstm.sqadto[18] = (unsigned short )0;
 sqlstm.sqtdso[18] = (unsigned short )0;
 sqlstm.sqhstv[19] = (         void  *)temp20;
 sqlstm.sqhstl[19] = (unsigned int  )7;
 sqlstm.sqhsts[19] = (         int  )7;
 sqlstm.sqindv[19] = (         void  *)0;
 sqlstm.sqinds[19] = (         int  )0;
 sqlstm.sqharm[19] = (unsigned int  )0;
 sqlstm.sqharc[19] = (unsigned int   *)0;
 sqlstm.sqadto[19] = (unsigned short )0;
 sqlstm.sqtdso[19] = (unsigned short )0;
 sqlstm.sqhstv[20] = (         void  *)temp21;
 sqlstm.sqhstl[20] = (unsigned int  )7;
 sqlstm.sqhsts[20] = (         int  )7;
 sqlstm.sqindv[20] = (         void  *)0;
 sqlstm.sqinds[20] = (         int  )0;
 sqlstm.sqharm[20] = (unsigned int  )0;
 sqlstm.sqharc[20] = (unsigned int   *)0;
 sqlstm.sqadto[20] = (unsigned short )0;
 sqlstm.sqtdso[20] = (unsigned short )0;
 sqlstm.sqhstv[21] = (         void  *)temp22;
 sqlstm.sqhstl[21] = (unsigned int  )7;
 sqlstm.sqhsts[21] = (         int  )7;
 sqlstm.sqindv[21] = (         void  *)0;
 sqlstm.sqinds[21] = (         int  )0;
 sqlstm.sqharm[21] = (unsigned int  )0;
 sqlstm.sqharc[21] = (unsigned int   *)0;
 sqlstm.sqadto[21] = (unsigned short )0;
 sqlstm.sqtdso[21] = (unsigned short )0;
 sqlstm.sqphsv = sqlstm.sqhstv;
 sqlstm.sqphsl = sqlstm.sqhstl;
 sqlstm.sqphss = sqlstm.sqhsts;
 sqlstm.sqpind = sqlstm.sqindv;
 sqlstm.sqpins = sqlstm.sqinds;
 sqlstm.sqparm = sqlstm.sqharm;
 sqlstm.sqparc = sqlstm.sqharc;
 sqlstm.sqpadto = sqlstm.sqadto;
 sqlstm.sqptdso = sqlstm.sqtdso;
 sqlcxt(&m_context, &sqlctx, &sqlstm, &sqlfpn);
 if (sqlca.sqlcode == 1403) goto error;
 if (sqlca.sqlcode < 0) convert_sql_error();
}


	if(convert_error_flag == -1)
	{
		return -1;
	}
	/* EXEC SQL COMMIT; */ 

{
 struct sqlexd sqlstm;
 sqlstm.sqlvsn = 10;
 sqlstm.arrsiz = 22;
 sqlstm.sqladtp = &sqladt;
 sqlstm.sqltdsp = &sqltds;
 sqlstm.iters = (unsigned int  )1;
 sqlstm.offset = (unsigned int  )123;
 sqlstm.cud = sqlcud0;
 sqlstm.sqlest = (unsigned char  *)&sqlca;
 sqlstm.sqlety = (unsigned short)256;
 sqlstm.occurs = (unsigned int  )0;
 sqlcxt(&m_context, &sqlctx, &sqlstm, &sqlfpn);
 if (sqlca.sqlcode < 0) convert_sql_error();
}


	time(&t);
	tblock = localtime(&t);
	strftime(time2, 20, "%Y-%m-%d %H:%M:%S", tblock);
	return 0;		

error:
	/* EXEC SQL ROLLBACK; */ 

{
 struct sqlexd sqlstm;
 sqlstm.sqlvsn = 10;
 sqlstm.arrsiz = 22;
 sqlstm.sqladtp = &sqladt;
 sqlstm.sqltdsp = &sqltds;
 sqlstm.iters = (unsigned int  )1;
 sqlstm.offset = (unsigned int  )138;
 sqlstm.cud = sqlcud0;
 sqlstm.sqlest = (unsigned char  *)&sqlca;
 sqlstm.sqlety = (unsigned short)256;
 sqlstm.occurs = (unsigned int  )0;
 sqlcxt(&m_context, &sqlctx, &sqlstm, &sqlfpn);
 if (sqlca.sqlcode < 0) convert_sql_error();
}


	char str[255]="********插入roar_msg表不成功*******:";
	strcat(str,"\n");
	DisplayConvertInGUI(str);
	return -1;
}