日期:2014-05-16 浏览次数:20959 次
void EXE_Send2Low_Ent()
{
char buf[1000]; //数据库操作
char DataID[20]; //指令ID号
char OrderTxt[200]; //指令类容
nt_Table tb;
sprintf( buf, "select * from Send2Low_Enterprise order by DataID ASC"); //获取数据库中第一条命令
if( SqlDbase( &tb, buf ) == -1){
return; //操作失败
}
if( (tb.row) == 0){ //没有需要处理的命令
return;
}
if((tb.row) > OrderMax_Ent){ //指令堆积,删除指令后退出
sprintf( buf, "delete from Send2Low_Enterprise");
ExecDbase( buf ); //删除表中所有指令
return ;
}
strcpy(DataID, tb.result[2]); //获取要处理指令的编号(第一条指令)
strcpy(OrderTxt,tb.result[3]); //获取要处理指令的内容
#ifdef DEBUG_TEST
printf("The EXE_Send2Low_Ent ID is %s\n", DataID);
printf("The EXE_Send2Low_Ent OrderTxt is %s\n", OrderTxt);
#endif
sprintf( buf, "delete from Send2Low_Enterprise where DataID = %s", DataID);
if( ExecDbase( buf ) ) { //删除该条命令记录
return ;
}
sqlite3_free_table( tb.result ); //释放查询结果
EXE_Send2Low_Handle(OrderTxt); //处理该命令
return;
}
int SqlDbase( nt_Table * tb, char * sql )
{
char *pErrMsg;
//nt_Table tb_t;
if(db.pdb == NULL)
{
return -1;
}
pthread_mutex_lock(&dbase_lock) ; // 数据库上锁
sqlite3_get_table(db.pdb, sql, &(tb->result), &(tb->row), &(tb->col), &pErrMsg);
pthread_mutex_unlock(&dbase_lock); // 数据库解锁
if(pErrMsg != NULL)
{
printf("error: sql %s, %s\n", sql, pErrMsg );
sqlite3_free(pErrMsg);
//pErrMsg = NULL;
return -1;
}
return 0;
}