请教两段C代码,关于sqlite数据库操作的
使用valgrind进行内存泄漏,发现sqlite3_get_table处有泄漏,泄漏代码如下:
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;
}
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_t.result), &(tb_t.row), &(tb_t.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;
}
tb->result = tb_t.result;
tb->row = tb_t.row;
tb->col = tb_t.col;
sqlite3_free_table(tb_t.result);
return 0;
}
[解决办法]
valgrind误报?