配色: 字号:
用sqlite执行标准SQL语法
2022-10-24 | 阅:  转:  |  分享 
  
用sqlite执行标准SQL语法

1. 执行sql语句



int sqlite3_exec(sqlite3, const char sql, sqlite3_callback, void , char errmsg );

这就是执行一条 sql 语句的函数。

第1个参数不再说了,是前面open函数得到的指针。说了是关键数据结构。

第2个参数const char sql 是一条 sql 语句,以/0结尾。

第3个参数sqlite3_callback 是回调,当这条语句执行之后,sqlite3会去调用你提供的这个函数。

第4个参数void 是你所提供的指针,你可以传递任何一个指针参数到这里,这个参数最终会传到回调函数里面,这个指针比较重要,可以用来作参数的传递。如果不需要传递指针给回调函数,可以填NULL。等下我们再看回调函数的写法,以及这个参数的使用。

第5 个参数char errmsg 是错误信息。注意是指针的指针。sqlite3里面有很多固定的错误信息。执行 sqlite3_exec 之后,执行失败时可以查阅这个指针(直接 printf(“%s/n”,errmsg))得到一串字符串信息,这串信息告诉你错在什么地方。sqlite3_exec函数通过修改你传入的指针的指 针,把你提供的指针指向错误提示信息,这样sqlite3_exec函数外面就可以通过这个 char得到具体错误提示。

说明:通常, sqlite3_callback 和它后面的 void 这两个位置都可以填 NULL。填NULL表示你不需要回调。比如你做 insert 操作,做 delete 操作,就没有必要使用回调。而当你做 select 时,就要使用回调,因为 sqlite3 把数据查出来,得通过回调告诉你查出了什么数据。



2.exec 的回调



typedef int (sqlite3_callback)(void,int,char, char);

你的回调函数必须定义成上面这个函数的类型。下面给个简单的例子:

// sqlite 每查到一条记录,就调用一次这个回调

int LoadMyInfo( void para, int n_column, char column_value, char column_name )

{

//para是你在 sqlite3_exec 里传入的 void 参数

//通过para参数,你可以传入一些特殊的指针(比如类指针、结构指针),然后在这里面强制转换成对应的类型(这里面是void类型,必须强制转换成你的类型才可用)。然后操作这些数据

//n_column是这一条记录有多少个字段 (即这条记录有多少列)

// char column_value 是个关键值,查出来的数据都保存在这里,它实际上是个1维数组(不要以为是2维数组),每一个元素都是一个 char 值,是一个字段内容(用字符串来表示,以/0结尾)

//char column_name 跟 column_value是对应的,表示这个字段的字段名称

//这里,我不使用 para 参数。忽略它的存在.

int i;

printf( “记录包含 %d 个字段/n”, n_column );

for( i = 0 ; i < n_column; i )

{

printf( “字段名:%s ?> 字段值:%s/n”, column_name[i], column_value[i] );

}

printf( “------------------/n“ );

return 0;

}



int main( int , char )

{

sqlite3 db;

int result;

char errmsg = NULL;

result = sqlite3_open( “c://Dcg_database.db”, &db );

if( result != SQLITE_OK )

{

//数据库打开失败

return -1;

}

//数据库操作代码

//创建一个测试表,表名叫 MyTable_1,有2个字段: ID 和 name。其中ID是一个自动增加的类型,以后insert时可以不去指定这个字段,它会自己从0开始增加

result = sqlite3_exec( db, “create table MyTable_1( ID integer primary key autoincrement, name nvarchar(32) )”, NULL, NULL, &errmsg );

if(result != SQLITE_OK )

{

printf( “创建表失败,错误码:%d,错误原因:%s/n”, result, errmsg );

}

//插入一些记录

result = sqlite3_exec( db, “insert into MyTable_1( name ) values ( ‘走路’ )”, 0, 0, &errmsg );



if(result != SQLITE_OK )

{

printf( “插入记录失败,错误码:%d,错误原因:%s/n”, result, errmsg );

}



result = sqlite3_exec( db, “insert into MyTable_1( name ) values ( ‘骑单车’ )”, 0, 0, &errmsg );

if(result != SQLITE_OK )

{

printf( “插入记录失败,错误码:%d,错误原因:%s/n”, result, errmsg );

}



result = sqlite3_exec( db, “insert into MyTable_1( name ) values ( ‘坐汽车’ )”, 0, 0, &errmsg );

if(result != SQLITE_OK )

{

printf( “插入记录失败,错误码:%d,错误原因:%s/n”, result, errmsg );

}



//开始查询数据库

result = sqlite3_exec( db, “select from MyTable_1”, LoadMyInfo, NULL, &errmsg );



//关闭数据库

sqlite3_close( db );

return 0;

}



通过上面的例子,应该可以知道如何打开一个数据库,如何做数据库基本操作。

有这些知识,基本上可以应付很多数据库操作了。



3. 不使用回调查询数据库



上面介绍的 sqlite3_exec 是使用回调来执行 select 操作。还有一个方法可以直接查询而不需要回调。但是,我个人感觉还是回调好,因为代码可以更加整齐,只不过用回调很麻烦,你得声明一个函数,如果这个函数 是类成员函数,你还不得不把它声明成 static 的(要问为什么?这又是C 基础了。C 成员函数实际上隐藏了一个参数:this,C 调用类的成员函数的时候,隐含把类指针当成函数的第一个参数 传递进去。结果,这造成跟前面说的 sqlite 回调函数的参数不相符。只有当把成员函数声明成 static 时,它才没有多余的隐含的this参数)。

虽然回调显得代码整齐,但有时候你还是想要非回调的 select 查询。这可以通过 sqlite3_get_table 函数做到。

int sqlite3_get_table(sqlite3, const char sql, char resultp, int nrow, int ncolumn, char errmsg );

第1个参数不再多说,看前面的例子。

第2个参数是 sql 语句,跟 sqlite3_exec 里的 sql 是一样的。是一个很普通的以/0结尾的char 字符串。

第3个参数是查询结果,它依然一维数组(不要以为是二维数组,更不要以为是三维数组)。它内存布局是:第一行是字段名称,后面是紧接着是每个字段的值。下面用例子来说事。

第4个参数是查询出多少条记录(即查出多少行)。

第5个参数是多少个字段(多少列)。

第6个参数是错误信息,跟前面一样,这里不多说了。

下面给个简单例子:



int main( int , char )

{

sqlite3 db;

int result;

char errmsg = NULL;

char dbResult; //是 char 类型,两个号

int nRow, nColumn;

int i , j;

int index;



result = sqlite3_open( “c://Dcg_database.db”, &db );



if( result != SQLITE_OK )

{

//数据库打开失败

return -1;

}



//数据库操作代码

//假设前面已经创建了 MyTable_1 表

//开始查询,传入的 dbResult 已经是 char ,这里又加了一个 & 取地址符,传递进去的就成了 char

result = sqlite3_get_table( db, “select from MyTable_1”, &dbResult, &nRow, &nColumn, &errmsg );

if( SQLITE_OK == result )

{

//查询成功

index = nColumn; //前面说过 dbResult 前面第一行数据是字段名称,从 nColumn 索引开始才是真正的数据

printf( “查到%d条记录/n”, nRow );



for( i = 0; i < nRow ; i )

{

printf( “第 %d 条记录/n”, i 1 );

for( j = 0 ; j < nColumn; j )

{

printf( “字段名:%s ?> 字段值:%s/n”, dbResult[j], dbResult [index] );

index; // dbResult 的字段值是连续的,从第0索引到第 nColumn - 1索引都是字段名称,从第 nColumn 索引开始,后面都是字段值,它把一个二维的表(传统的行列表示法)用一个扁平的形式来表示

}

printf( “-------/n” );

}

}



//到这里,不论数据库查询是否成功,都释放 char 查询结果,使用 sqlite 提供的功能来释放

sqlite3_free_table( dbResult );



//关闭数据库

sqlite3_close( db );

return 0;

}



到这个例子为止,sqlite3 的常用用法都介绍完了。

用以上的方法,再配上 sql 语句,完全可以应付绝大多数数据库需求。

但有一种情况,用上面方法是无法实现的:需要insert、select 二进制。当需要处理二进制数据时,上面的方法就没办法做到。下面这一节说明如何插入二进制数据

(2)操作二进制



sqlite 操作二进制数据需要用一个辅助的数据类型:sqlite3_stmt 。

这 个数据类型记录了一个“sql语句”。为什么我把 “sql语句” 用双引号引起来?因为你可以把 sqlite3_stmt 所表示的内容看成是 sql语句,但是实际上它不是我们所熟知的sql语句。它是一个已经把sql语句解析了的、用sqlite自己标记记录的内部数据结构。

正因为这个结构已经被解析了,所以你可以往这个语句里插入二进制数据。当然,把二进制数据插到 sqlite3_stmt 结构里可不能直接 memcpy ,也不能像 std::string 那样用 号。必须用 sqlite 提供的函数来插入。



献花(0)
+1
(本文系shouhuyanya...原创)