三、高效的批量数据插入:
在给出 *** 作步骤之前先简单说明一下批量插入的概念,以帮助大家阅读其后的示例代码。事实上,批量插入并不是什么新的概念,在其它关系型数据库的C接口API中都提供了一定的支持,只是接口的实现方式不同而已。纵观众多流行的数据库接口,如OCI(Oracle API)、MysqL API和Postgresql API等,OCI提供的编程接口最为方便,实现方式也最为高效。sqlite作为一种简单灵活的嵌入式数据库也同样提供了该功能,但是实现方式并不像其他数据库那样方便明显,它只是通过一种隐含的技巧来达到批量插入的目的,其逻辑如下:
1). 开始一个事物,以保证后面的数据 *** 作语句均在该事物内完成。在sqlite中,如果没有手工开启一个事物,其所有的DML语句都是在自动提交模式下工作的,既每次 *** 作后数据均被自动提交并写入磁盘文件。然而在非自动提交模式下,只有当其所在的事物被手工COMMIT之后才会将修改的数据写入到磁盘中,之前修改的数据都是仅仅驻留在内存中。显而易见,这样的批量写入方式在效率上势必会远远优于多迭代式的单次写入 *** 作。
2). 基于变量绑定的方式准备待插入的数据,这样可以节省大量的sqlite3_prepare_v2函数调用次数,从而节省了多次将同一SQL语句编译成sqlite内部识别的字节码所用的时间。事实上,sqlite的官方文档中已经明确指出,在很多时候sqlite3_prepare_v2函数的执行时间要多于sqlite3_step函数的执行时间,因此建议使用者要尽量避免重复调用sqlite3_prepare_v2函数。在我们的实现中,如果想避免此类开销,只需将待插入的数据以变量的形式绑定到SQL语句中,这样该SQL语句仅需调用sqlite3_prepare_v2函数编译一次即可,其后的 *** 作只是替换不同的变量数值。
3). 在完成所有的数据插入后显式的提交事物。提交后,sqlite会将当前连接自动恢复为自动提交模式。
下面是示例代码的实现步骤:
1). 创建测试数据表。
2). 通过执行BEGIN TRANSACTION语句手工开启一个事物。
3). 准备插入语句及相关的绑定变量。
4). 迭代式插入数据。
5). 完成后通过执行COMMIT语句提交事物。
6). 删除测试表。
见以下代码及关键性注释:
1 #include <sqlite3.h> 2 #include <string> 3 #include <stdio.h> 4 5 using namespace std; 6 7 voID dotest() 8 { 9 sqlite3* conn = NulL; 10 //1. 打开数据库 11 int result = sqlite3_open("D:/mytest.db",&conn); 12 if (result != sqlITE_OK) { 13 sqlite3_close(conn); 14 return; 15 } 16 const char* createtablesql = 17 CREATE table TESTtable (int_col INT,float_col REAL,string_col TEXT)"; 18 sqlite3_stmt* stmt = NulL; 19 int len = strlen(createtablesql); 20 2. 准备创建数据表,如果创建失败,需要用sqlite3_finalize释放sqlite3_stmt对象,以防止内存泄露。 21 if (sqlite3_prepare_v2(conn,createtablesql,len,&stmt,NulL) != sqlITE_OK) { 22 if (stmt) 23 sqlite3_finalize(stmt); 24 sqlite3_close(conn); 25 26 } 27 3. 通过sqlite3_step命令执行创建表的语句。对于DDL和DML语句而言,sqlite3_step执行正确的返回值 28 只有sqlITE_DONE,对于SELECT查询而言,如果有数据返回sqlITE_ROW,当到达结果集末尾时则返回 29 //sqlITE_DONE。 30 if (sqlite3_step(stmt) != sqlITE_DONE) { 31 sqlite3_finalize(stmt); 32 sqlite3_close(conn); 33 34 } 35 4. 释放创建表语句对象的资源。 36 sqlite3_finalize(stmt); 37 printf(Succeed to create test table Now.\n"); 38 39 5. 显式的开启一个事物。 40 sqlite3_stmt* stmt2 = NulL; 41 char* beginsql = BEGIN TRANSACTION 42 43 if (stmt2) 44 sqlite3_finalize(stmt2); 45 sqlite3_close(conn); 46 47 } 48 if (sqlite3_step(stmt2) != sqlITE_DONE) { 49 sqlite3_finalize(stmt2); 50 sqlite3_close(conn); 51 52 } 53 sqlite3_finalize(stmt2); 54 55 6. 构建基于绑定变量的插入数据。 56 char* insertsql = INSERT INTO TESTtable VALUES(?,?,?) 57 sqlite3_stmt* stmt3 = NulL; 58 59 if (stmt3) 60 sqlite3_finalize(stmt3); 61 sqlite3_close(conn); 62 63 } 64 int insertCount = 10; 65 char* strData = This is a test. 66 7. 基于已有的SQL语句,迭代的绑定不同的变量数据 67 for (int i = 0; i < insertCount; ++i) { 68 在绑定时,最左面的变量索引值是1。 69 sqlite3_bind_int(stmt3,1,i); 70 sqlite3_bind_double(stmt3,128); line-height:1.5!important">2,i * 1.0); 71 sqlite3_bind_text(stmt3,128); line-height:1.5!important">3,strData,strlen(strData),sqlITE_TRANSIENT); 72 if (sqlite3_step(stmt3) != sqlITE_DONE) { 73 sqlite3_finalize(stmt3); 74 sqlite3_close(conn); 75 76 } 77 重新初始化该sqlite3_stmt对象绑定的变量。 78 sqlite3_reset(stmt3); 79 printf(Insert Succeed.\n 80 } 81 sqlite3_finalize(stmt3); 82 83 8. 提交之前的事物。 84 char* commitsql = COMMIT 85 sqlite3_stmt* stmt4 = NulL; 86 87 if (stmt4) 88 sqlite3_finalize(stmt4); 89 sqlite3_close(conn); 90 91 } 92 if (sqlite3_step(stmt4) != sqlITE_DONE) { 93 sqlite3_finalize(stmt4); 94 sqlite3_close(conn); 95 96 } 97 sqlite3_finalize(stmt4); 98 99 9. 为了方便下一次测试运行,我们这里需要删除该函数创建的数据表,否则在下次运行时将无法100 创建该表,因为它已经存在。101 char* dropsql = DROP table TESTtable102 sqlite3_stmt* stmt5 = NulL;103 104 if (stmt5)105 sqlite3_finalize(stmt5);106 sqlite3_close(conn);107 108 }109 if (sqlite3_step(stmt5) == sqlITE_DONE) {110 printf(The test table has been dropped.\n111 }112 sqlite3_finalize(stmt5);113 sqlite3_close(conn);114 }115 116 int main()117 {118 dotest();119 return 0;120 }121 输出结果如下:122 Succeed to create test table Now.123 Insert Succeed.124 125 126 127 128 129 130 131 132 133 The test table has been dropped.
该结果和上一个例子(普通数据插入)的结果完全相同,只是在执行效率上明显优于前者。
四、数据查询:
数据查询是每个关系型数据库都会提供的最基本功能,下面的代码示例将给出如何通过sqlite API获取数据。
1). 创建测试数据表。
2). 插入一条测试数据到该数据表以便于后面的查询。
3). 执行SELECT语句检索数据。
4). 删除测试表。
见以下示例代码和关键性注释:
以上是内存溢出为你收集整理的SQLite学习手册(实例代码<二>)全部内容,希望文章能够帮你解决SQLite学习手册(实例代码<二>)所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)