sqlite使用小结3

＊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。

原文链接：https://www.f2er.com/sqlite/202399.html

使用事务

猜你在找的Sqlite相关文章