*sqlite3_column_blob()
*sqlite3_column_bytes()
*sqlite3_column_bytes16()
*sqlite3_column_count()
*sqlite3_column_double()
*sqlite3_column_int()
*sqlite3_column_int64()
*sqlite3_column_text()
*sqlite3_column_text16()
*sqlite3_column_type()
*sqlite3_column_value()
* sqlite3_finalize()该接口销毁之前调用sqlite3_prepare()创建的预处理语句。每一个预处理语句都必须调用这个接口进行销毁以避免内存泄
漏。
*sqlite3_close()该接口关闭一个由之前调用sqlite3_open()创建的数据库连接。所有与该连接相关的预处理语句都必须在关闭连接之前销毁。
2.4扩展sqlite
sqlite包含一些可用于扩展其功能的一些其他接口,这些接口包括:
* sqlite3_create_collation()
* sqlite3_create_function()
* sqlite3_create_module()
sqlite3_create_collation()接口用于为索引文本创建新的对照序列。sqlite3_create_module()接口用于注册新的续表实现接口。
sqlite3_create_function()接口创建新的sql函数-即可以是单一的也可以是组合的接口。新的函数实现通常利用下列的辅助接口:
sqlite3_aggregate_context()
* sqlite3_result()
* sqlite3_user_data()
* sqlite3_value()
sqlite中所有内建的sql函数接口也是通过这些相同的接口实现的。查看sqlite源代码,尤其是date.c和func.c两个文件就有许多这方面的例子。
四、在VC下使用sqlite
#include "../sqlite3_lib/sqlite3.h"
#pragma comment(lib,"../sqlite3_lib/sqlite3.lib")
static int _sql_callback(void * notused,int argc,char ** argv,char ** szColName)
{
int i;
for ( i=0; i < argc; i++ )
{
printf( "%s = %s\n",szColName[i],argv[i] == 0 ? "NUL" : argv[i] );
}
return 0;
}
int main(int argc,char * argv[])
{
const char * ssql1 = "create table users(userid varchar(20) PRIMARY KEY,age int,birthday datetime);";
const char * ssql2 = "insert into users values('wang',20,'1989-5-4');";
const char * ssql3 = "select * from users;";
sqlite3 * db = 0;
char * pErrMsg = 0;
int ret = 0;
// 连接数据库
ret = sqlite3_open("./test.db",&db);
if ( ret != sqlITE_OK )
{
fprintf(stderr,"无法打开数据库: %s",sqlite3_errmsg(db));
return(1);
}
printf("数据库连接成功!\n");
// 执行建表sql
sqlite3_exec( db,ssql1,&pErrMsg );
if ( ret != sqlITE_OK )
{
fprintf(stderr,"sql error: %s\n",pErrMsg);
sqlite3_free(pErrMsg);
}
// 执行插入记录sql
sqlite3_exec( db,ssql2,&pErrMsg);
// 查询数据表
sqlite3_exec( db,ssql3,_sql_callback,&pErrMsg);
sqlite3_close(db);
db = 0;
return 0;
}
使用事务
在上面的例子中,我们向数据库里插入了10条数据,然后再从数据库里读出来。细心的你不知道有没有发现,在执行Insert的时候 ,并没有使用同一个事 务。在很多情况下,我们需要使用事务来保证对数据库操作的原子性。sqlite是支持事务的,而且对事务的使用非常简单: 使用sql语句”begin;” 表示事务开始,”rollback;”表示事务的回滚,”commit;”表示事务的提交。下面我们对上面例子中的代码作一下修改, 给Insert操作添 加事务支持:
//... ...bool is_succed = true; sqlite3_exec(conn,"begin;",0); //
开启事务 //添加10条记录 for (int i = 0; i < 10; i++) { // 执行sql sprintf(sql,"INSERT INTO [test_for_cpp] ([id],[name],[age]) \ VALUES (%d,'%s',%d)",i,"JGood",i); if (sqlITE_OK != sqlite3_exec(conn,sql,&err_msg)) { is_succed = false; break; } } if (is_succed) sqlite3_exec(conn,"commit;",0); // 提交事务 else sqlite3_exec(conn,"rollback;",0); // 回滚事务 //... ...
使用sql参数
基本上,使用sqlite3_open,sqlite3_close,sqlite3_exec这三个函数, 可以完成大大部分的工作。但还不完善。上面的例子中,都是直接以sql语句的形式来操作数据库,这样很容易被注入。所以有必要使用sql参数。
sqlite3_prepare
sqlite3_bind_*
sqlite3_step
sqlite3_column_*
struct sqlite3_stmt
sqlite3_finalize
sqlite3_prepare用来编译sql语句。sql语句被执行之前, 必须先编译成字节码。sqlite3_stmt是一个结构体,表示sql语句 编译后的字节码。sqlite3_step用来执行编译后的sql语句。
sqlite3_bind_*用于将sql参数绑定到sql语句。 sqlite3_column_*用于从查询的结果中获取数据。sqlite3_finalize用来释放sqlite3_stmt对象。代码最能说明函 数的功能,
下面就用一个例子来演示吧~~
// ---------------------------------------------- // http://blog.csdn.net/JGood
// sqlite3_prepare,sqlite3_bind_*,sqlite3_step,sqlite3_column_*,sqlite3_column_type // sqlite3_stmt,sqlite3_finalize,sqlite3_reset // 查询 // ---------------------------------------------- sqlite3 *conn = NULL; sqlite3_stmt *stmt = NULL; const char *err_msg = NULL; // 列数据类型 char col_types[][10] = { "","Integer","Float","Text","Blob","NULL" }; sqlite3_open("test.db",&conn); sqlite3_prepare(conn,"SELECT * FROM [test_for_cpp] WHERE [id]>?",-1,&stmt,&err_msg); sqlite3_bind_int(stmt,1,5); while (sqlITE_ROW == sqlite3_step(stmt)) { int col_count = sqlite3_column_count(stmt); // 结果集中列的数量 const char *col_0_name = sqlite3_column_name(stmt,0); // 获取列名 int id = sqlite3_column_int(stmt,0); int id_type = sqlite3_column_type(stmt,0); // 获取列数据类型 const char *col_2_name = sqlite3_column_name(stmt,2); int age = sqlite3_column_int(stmt,2); int age_type = sqlite3_column_type(stmt,2); const char *col_1_name = sqlite3_column_name(stmt,1); char name[80]; strncpy(name,(const char *)sqlite3_column_text(stmt,1),80); int name_type = sqlite3_column_type(stmt,1); // 打印结果 printf("col_count: %d,%s = %d(%s),%s = %s(%s),%s = %d(%s)\n", col_count,col_0_name,id,col_types[id_type],col_2_name,name, col_types[name_type],col_1_name,age,col_types[age_type]); } sqlite3_finalize(stmt); // 释放sqlite3_stmt sqlite3_close(conn);
这段代码查询id号大于5的所有记录.
其他函数
在上面的例子中,还使用了其他的一些函数,
如:sqlite3_column_count用于获取结果集中列的数 量;sqlite3_column_name用于获取列的名称;
sqlite3_column_type用于获取列的数据类 型;sqlite3_errcode用于获取最近一次操作出错的错误代码;
sqlite3_errmsg用于获取最近一次操作出错的错误说明。 sqlite的api中还有很多的函数,有了上面的基础,
相信你通过查询官方的文档,能迅速掌握本文未介绍的api。