下载sqlite3
我们下载sqlite源码包,只需要其中的sqlite3.c、sqlite.h即可。
最简单的一个创建表操作
#include"sqlite3.h"
intmain( intargc,char*argv[]){
const char*sql_create_table="createtablet(idintprimarykey,msgvarchar(128))";
char*errmsg=0;
intret=0;
sqlite3*db=0;
ret=sqlite3_open("./sqlite3-demo.db",&db);
if(ret!=sqlITE_OK){
fprintf(stderr,"Cannotopendb:%s\n",sqlite3_errmsg(db));
return1;
}
printf("Opendatabase\n");
ret=sqlite3_exec(db,sql_create_table,NULL,&errmsg);
}
sqlite3_free(errmsg);
sqlite3_close(db);
printf("Closedatabase\n");
return0;
}
在这个操作中我们执行了如下操作:
当然这中间会有一些状态的判断以及内存指针的释放等。
打开数据库的API如下:
char*filename,128,0)">/* Databasefilename(UTF-8) */
sqlite3**ppDb OUT:sqlitedbhandle */
);
打开数据库除了这种形式意外,还有sqlite3_open、sqlite3_open16、sqlite3_open_v2几种形式,基本上类似。
大部分sql操作都可以通过sqlite3_exec来完成,它的API形式如下:
sqlite3*,0)">Anopendatabase */
char*sql,0)">sqltobeevaluated int(*callback)( void*,255)">int,255)">char**,255)">char**),0)">Callbackfunction 1stargumenttocallback char**errmsg Errormsgwrittenhere */
);
各个参数的意义为:
每一个参数意义如下:
通常情况下callback在select操作中会使用到,尤其是处理每一行记录数。返回的结果每一行记录都会调用下“回调函数”。 如果回调函数返回了非0,那么sqlite3_exec将返回sqlITE_ABORT,并且之后的回调函数也不会执行,同时未执行的子查询也不会继续执行。
对于更新、删除、插入等不需要回调函数的操作,sqlite3_exec的第三、第四个参数可以传入0或者NULL。
通常情况下sqlite3_exec返回sqlITE_OK=0的结果,非0结果可以通过errmsg来获取对应的错误描述。
Windows下编译:
D:\home\dev\c>cl /nologo /TC sqlite3-demo.c sqlite3.c
GCC下编译:
$ gcc -o sqlite3-demo.bin sqlite3-demo.c sqlite3.c
删除表操作
简单的删除操作可以直接使用sqlite3_exec即可。这里不需要回调函数以及回调函数的参数。 当然需要可以关注sqlite3_exec返回的结果是否为sqlITE_OK的值。
sqlite3_exec(db,sql_drop_table,&errmsg);
sqlite3_exec(db,&errmsg);
插入数据
插入第一条数据
printf("Insertarecord%s\n",ret==sqlITE_OK?"OK":"FAIL");
返回值ret为sqlITE_OK即操作成功。
插入多条数据,并删除数据
ret=sqlite3_exec(db,msg)values(2,'IMXYLZ')","deletefromtwhereid<3",&errmsg);
printf("Deleterecords:%s\n",ret==sqlITE_OK?"OK":"FAIL");
预编译操作
sqlite3_stmt*stmt;
charca[255];
// preparestatement
sqlite3_prepare_v2(db,msg)values(?,?)",-1,&stmt,0);
for(i=10;i<20;i++){
sprintf(ca,"HELLO#%i",i);
sqlite3_bind_int(stmt,1,i);
sqlite3_bind_text(stmt,2,ca,strlen(ca),NULL);
sqlite3_step(stmt);
sqlite3_reset(stmt);
}
sqlite3_finalize(stmt);
- 通过sqlite3_prepare_v2()创建一个sqlite3_stmt对象
- 通过sqlite3_bind_*()绑定预编译字段的值
- 通过sqlite3_step()执行sql语句
- 通过sqlite3_reset()重置预编译语句,重复操作2多次
- 通过sqlite3_finalize()销毁资源
sqlite3_prepare_v2()有个多种类似的形式,完整的API语法是:
sqlite3*db,0)">Databasehandle char*zsql,0)">sqlstatement,UTF-8encoded intnByte,0)">Maximumlengthofzsqlinbytes. */
sqlite3_stmt**ppStmt,0)">OUT:Statementhandle char**pzTail OUT:Pointertounusedportionofzsql
各个参数的定义为:
绑定参数sqlite3_bind_*有多种形式,分别对应不同的数据类型:
intsqlite3_bind_double(sqlite3_stmt*,255)">double);
intsqlite3_bind_int(sqlite3_stmt*,255)">int);
intsqlite3_bind_int64(sqlite3_stmt*,sqlite3_int64);
intsqlite3_bind_null(sqlite3_stmt*,255)">intsqlite3_bind_text(sqlite3_stmt*,255)">char*,255)">intsqlite3_bind_text16(sqlite3_stmt*,255)">intsqlite3_bind_value(sqlite3_stmt*,255)">constsqlite3_value*);
intsqlite3_bind_zeroblob(sqlite3_stmt*,255)">intn);
预编译sql语句中可以包含如下几种形式:
-
- ?
- ?NNN
- :VVV
- @VVV
- $VVV
NNN代表数字,VVV代表字符串。
如果是?或者?NNN,那么可以直接sqlite3_bind_*()进行操作,如果是字符串,还需要通过sqlite3_bind_parameter_index()获取对应的index,然后再调用sqlite3_bind_*()操作。这通常用于构造不定条件的sql语句(动态sql语句)。
查询操作
int print_record(void *,int,char **,char **);
inti;
for(i=0;i<n_column;i++){
printf("\t%s",column_value[i]);
}
printf("\n");
return0;
}
不使用回调的查询操作
定义使用的变量
char **dbresult; int j,nrow,ncolumn,index;
查询操作
ret=sqlite3_get_table(db,&dbresult,&nrow,&ncolumn,255)">if(ret==sqlITE_OK){
printf("query%irecords.\n",nrow);
index=ncolumn;
for(i=0;i<nrow;i++){
printf("[%2i]",i);
for(j=0;j<ncolumn;j++){
printf("%s",dbresult[index]);
index++;
}
printf("\n");
}
}
sqlite3_free_table(dbresult);
sqlite3_get_table的API语法:
sqlite3*db,255)">char***pazResult,0)">Resultsofthequery int*pnRow,0)">Numberofresultrowswrittenhere int*pnColumn,0)">Numberofresultcolumnswrittenhere char**pzErrmsg */
);
voidsqlite3_free_table( char**result);
其中:
由于sqlite3_get_table是sqlite3_exec的包装,因此返回的结果和sqlite3_exec类似。
pazResult是一个(pnRow+1)*pnColumn结果集的字符串数组,其中前pnColumn个结果是字段的名称,后pnRow行记录是真实的字段值,如果某个字段为空,则对应值为NULL。
最后需要通过sqlite3_free_table()释放完整的结果集。
更新操作
sqlite3_exec(db,"update t set msg='MESSAGE#10' where id=10",&errmsg);
当然了,我们也可以使用预编译方法进行更新操作。
受影响的记录数
我们可以使用sqlite3_change(sqlite3 *)的API来统计上一次操作受影响的记录数。
ret = sqlite3_exec(db,"delete from t",&errmsg); if(ret == sqlITE_OK){ printf("delete records: %i\n",sqlite3_changes(db)); }
总结
这里我们接触了sqlITE3的13个API:
事实上截止到sqlITE3.7.14(2012/09/03) 一共提供了204个API函数(http://www.sqlite.org/c3ref/funclist.html)。
但最精简的API函数大概有6个:
核心API也就10个(在精简API基础上增加4个):
因此掌握起来还是比较容易的。
代码地址包含sqlite3:http://download.csdn.net/detail/kaitiren/7796981