完全版 ESQL/C资料二(11) _云知道

break;
} else if (strlen(sqlInput) == 0) {
/* Don"t process the statement */
printf ("tNo characters entered.n");
} else if (sqlInput[strlen(sqlInput) - 1] == "") {
/* 查看是否有续行 */
strcpy (st, "");
do {
strncat (st, sqlInput, strlen(sqlInput) -1);
gets (sqlInput);
} while (sqlInput[strlen(sqlInput) - 1] == "");
strcat (st, sqlInput);
/* 处理SQL语句 */
rc = process_statement (st);
} else {
strcpy (st, sqlInput);
/* 处理输入的SQL语句*/
rc = process_statement (st);
} /* end if */
} /* end while */
printf ("Enter "c" to COMMIT or Any Other key to ROLLBACK the transaction :n");
Transaction = getc(stdin);
if (Transaction == "c") {
printf("COMMITING the transactions.n");
/提交结果*/
EXEC SQL COMMIT;
CHECKERR ("COMMIT");
} else {
/* 撤消语句的执行结果*/
printf("ROLLING BACK the transactions.n");
EXEC SQL ROLLBACK;
CHECKERR ("ROLLBACK");
}; /* endif */
/*断开数据库的连接*/
EXEC SQL CONNECT RESET;
CHECKERR ("CONNECT RESET");
return 0;
}
/************************************************************************
* 函数 : process_statement
* This function processes the inputted statement and then prepares the
* procedural SQL implementation to take place.
*************************************************************************/
int process_statement (char sqlInput[1000]) {
int counter = 0;
struct sqlda *sqldaPointer;
short sqlda_d ; /* Total columns */
short idx;
char buffer[4096];
char varname[1024];
char colnamelist[4096];
/*声明一个宿主变量，用于存放SQL语句*/
EXEC SQL BEGIN DECLARE SECTION;
char st[1000];
EXEC SQL END DECLARE SECTION;
/*向宿主变量中存放SQL语句*/
strcpy(st, sqlInput);
/* 分配SQLDA空间，以存放查询结果 */
init_da (&sqldaPointer, 1);
EXEC SQL PREPARE statement1 from :st;
if (CHECKERR ("PREPARE") != 0) return SQLCODE;
/*获得返回结果的描述信息，填入SQLDA结构*/
EXEC SQL DESCRIBE statement1 INTO :*sqldaPointer;
/* 判断DESCRIBE是否正确执行*/
if (SQLCODE != 0 &&
SQLCODE != SQL_RC_W236 &&
SQLCODE != SQL_RC_W237 &&
SQLCODE != SQL_RC_W238 &&
SQLCODE != SQL_RC_W239) {
/* An unexpected warning/error has occured. Check the SQLCA. */
if (CHECKERR ("DESCRIBE") != 0) return SQLCODE;
} /* end if */
/*如果SQLDA结构中的sqld大于0，则表明是一个SELECT语句，sqld值是列的个数*/
if (sqldaPointer->sqld > 0) {
/*判断是否有LOB列，若是，则需要双倍的SQLDA空间*/
if (strncmp(SQLSTATE, "01005", sizeof(SQLSTATE)) == 0) {
/* this output contains columns that need a DOUBLED SQLDA */
SETSQLDOUBLED (sqldaPointer, SQLDOUBLED);
init_da (&sqldaPointer, sqldaPointer->sqld * 2);
} else {
/*否则，只需要一个SQLDA */
init_da (&sqldaPointer, sqldaPointer->sqld);
} /* end if */
/* 对SQLDA 重新赋值*/
EXEC SQL DESCRIBE statement1 INTO :*sqldaPointer;
if (CHECKERR ("DESCRIBE") != 0) return SQLCODE;
/* 给SQLDA分配合适的内存空间*/
alloc_host_vars (sqldaPointer);
/* 声明游标*/
EXEC SQL DECLARE pcurs CURSOR FOR statement1;
/*打开游标*/
EXEC SQL OPEN pcurs;
if (CHECKERR ("OPEN") != 0) return SQLCODE;
/*查询一行，存放在SQLDA中*/
EXEC SQL FETCH pcurs USING DESCRIPTOR :*sqldaPointer;
if (CHECKERR ("FETCH") != 0) return SQLCODE;
/* 从SQLDA中获得列标题信息，并显示之*/
colnamelist[0] = 0;
for ( idx=0; idx< sqlda_d; idx)
{
strcat(colnamelist, readColName(sqldaPointer, idx, buffer));
If (idx < sqlda_d -1)
strcat(colnamelist, ",");
}
printf(“%sn”,colnamelist);
/*显示所有的行数据*/
while ( SQLCODE == 0 ) {
counter;
for ( idx=0; idx< sqlda_d; idx)
printf(“%s”,readCol(sqldaPointer, idx, buffer));
EXEC SQL FETCH pcurs USING DESCRIPTOR :*sqldaPointer ;
} /* endwhile */
/*关闭游标*/
EXEC SQL CLOSE pcurs;
if (CHECKERR ("CLOSE CURSOR") != 0) return SQLCODE;

完全版 ESQL/C资料二(11)

推荐阅读

老年机亲情号码设置

柠檬怎么晒干柠檬怎么晒干收藏

小学生家长会演讲稿模板集合五篇

樊姓的来源

翡翠吊坠女带什么好女人翡翠吊坠带什么好

ppt没有保存关闭找回怎么办 ppt没有保存关闭找回

喷雾什么时候用什么时候使用喷雾

塔西佗陷阱是什么意思塔西佗陷阱百科

减重最有效方法

槐花不能与哪些食物一起吃,蒸槐花菜需要蒸几分钟

传说徽章怎么获得,幽系徽章怎么打

O型血真的是万能血吗。

狗瘟是怎么造成的

血压突然升到130到93危险吗血压突然升到135怎么回事

摩托罗拉xt535刷机包,XT535刷机

六月花有哪些花六月花有哪些