在之前的两篇博文中，分别介绍了SQLITE的基础知识和操作，C/C++ 的一些常用API

sqlite之我见--简单介绍与基本操作

sqlite之我见--C/C++ API接口介绍

本文中，我会给大家用几个小程序示例SQLITE C/C++ API的使用。

1.我们看下最简单的sqlite程序，通过sqlite3_open， sqlite3_exec， sqlite3_close来实现一个简单的数据库操作。

1. /*
2. *File:sqlite_test.cpp
3. *Author:Carl
4. *
5. *CreatedonSeptember20,2012,3:28PM
6. */
8. #include<cstdlib>
9. #include<cstdio>
10. #include<sqlite3.h>
12. staticint_sql_callback(void*notused,intargc,char**argv,char**szColName)
13. {
14. inti=0;
16. printf("notused:0x%x,argc:%dn",notused,argc);
17. for(i=0;i<argc;i++)
18. {
19. printf("%s=%sn",szColName[i],argv[i]==0?"NULL":argv[i]);
20. }
21. printf("n");
23. return0;
24. }
26. /*
27. *
28. */
29. intmain(intargc,char**argv)
30. {
31. constchar*sSQL1="createtableusers(useridvarchar(20)PRIMARYKEY,ageint,birthdaydatetime);";
32. constchar*sSQL2="insertintousersvalues('wang',20,'1989-5-4');";
33. constchar*sSQL3="select*fromusers;";
35. sqlite3*db=0;
36. char*pErrMsg=0;
37. intret=0;
39. //连接数据库
40. ret=sqlite3_open("./test.db",&db);
41. if(ret!=SQLITE_OK)
42. {
43. fprintf(stderr,"无法打开数据库：%sn",sqlite3_errmsg(db));
44. sqlite3_close(db);
45. return1;
46. }
47. printf("数据库连接成功n");
49. //执行建表SQL
50. ret=sqlite3_exec(db,sSQL1,_sql_callback,&pErrMsg);
51. if(ret!=SQLITE_OK)
52. {
53. fprintf(stderr,"SQLcreateerror:%sn",pErrMsg);
54. sqlite3_free(pErrMsg);//这个要的哦，要不然会内存泄露的哦！！！
55. sqlite3_close(db);
56. return1;
57. }
58. printf("数据库建表成功！！n");
60. //执行插入数据
61. ret=sqlite3_exec(db,sSQL2,&pErrMsg);
62. if(ret!=SQLITE_OK)
63. {
64. fprintf(stderr,"SQLinserterror:%sn",pErrMsg);
65. sqlite3_free(pErrMsg);//这个要的哦，要不然会内存泄露的哦！！！
66. sqlite3_close(db);
67. return1;
68. }
69. printf("数据库插入数据成功！n");
71. //执行查询操作
72. ret=sqlite3_exec(db,sSQL3,"SQLerror:%sn",pErrMsg);
73. sqlite3_free(pErrMsg);
74. sqlite3_close(db);
75. return1;
76. }
77. printf("数据库查询成功！！n");
79. //关闭数据库
80. sqlite3_close(db);
81. db=0;
83. return0;
84. }

/* 
 * File:   sqlite_test.cpp
 * Author: Carl
 *
 * Created on September 20,3:28 PM
 */

#include <cstdlib>
#include <cstdio>
#include <sqlite3.h>

static int _sql_callback(void *notused,int argc,char **argv,char **szColName)
{
    int i = 0;
    
    printf("notused:0x%x,argc:%dn",argc);
    for (i = 0; i < argc; i++)
    {
        printf("%s = %sn",argv[i] == 0 ? "NULL" : argv[i]);
    }
    printf("n");
    
    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','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,"无法打开数据库：%sn",sqlite3_errmsg(db));
        sqlite3_close(db);
        return 1;
    }
    printf("数据库连接成功n");
    
    //执行建表SQL
    ret = sqlite3_exec(db,&pErrMsg);
    if (ret != SQLITE_OK)
    {
        fprintf(stderr,"SQL create error: %sn",pErrMsg);
        sqlite3_free(pErrMsg); //这个要的哦，要不然会内存泄露的哦！！！
        sqlite3_close(db);
        return 1;
    }
    printf("数据库建表成功！！n");
    
    //执行插入数据
    ret = sqlite3_exec(db,"SQL insert error: %sn",pErrMsg);
        sqlite3_free(pErrMsg); //这个要的哦，要不然会内存泄露的哦！！！
        sqlite3_close(db);
        return 1;
    }
    printf("数据库插入数据成功！n");
    
    //执行查询操作
    ret = sqlite3_exec(db,"SQL error: %sn",pErrMsg);
        sqlite3_free(pErrMsg);
        sqlite3_close(db);
        return 1;
    }
    printf("数据库查询成功！！n");
    
    //关闭数据库
    sqlite3_close(db);
    db = 0;
    
    return 0;
}

运行结果如下结果：

1. [carl@Fedorasqlite]$g++sqlite_test.cpp-lsqlite3
2. [carl@Fedorasqlite]$./a.out
3. 数据库连接成功
4. 数据库建表成功！！
5. 数据库插入数据成功！
6. notused:0x0,argc:3
7. userid=wang
8. age=20
9. birthday=1989-5-4
11. 数据库查询成功！！
12. [carl@Fedorasqlite]$

[carl@Fedora sqlite]$ g++ sqlite_test.cpp -lsqlite3
[carl@Fedora sqlite]$ ./a.out 
数据库连接成功
数据库建表成功！！
数据库插入数据成功！
notused:0x0,argc:3
userid = wang
age = 20
birthday = 1989-5-4

数据库查询成功！！
[carl@Fedora sqlite]$

2. 我们再看一个在sqlite上是有事务来实现原子操作的的例子，

代码如下：

1. /*
2. *File:sqlite_test.cpp
3. *Author:Carl
4. *
5. *Createdon2012年9月22日,上午7:50
6. */
8. #include<cstdlib>
9. #include<cstdio>
10. #include<sqlite3.h>
12. staticint_sql_callback(void*notused,argv[i]==0?"NULL":argv[i]);
13. }
14. printf("n");
16. return0;
17. }
20. /*
21. *
22. */
23. intmain(intargc,char**argv)
24. {
25. constchar*sSQL1="createtabletest_for_cpp(idint,namevarchar(10),ageint);";
26. charsql[100]={0};
27. sqlite3*db=NULL;
28. char*pErrMsg=NULL;
29. intret=0;
30. boolis_success=true;
31. constchar*sSQL3="select*fromtest_for_cpp;";
33. ret=sqlite3_open("./test.db",&db);
34. if(SQLITE_OK!=ret)
35. {
36. fprintf(stderr,sqlite3_errmsg(db));
37. sqlite3_close(db);
38. return1;
39. }
40. printf("数据库连接成功n");
42. ret=sqlite3_exec(db,NULL,&pErrMsg);
43. if(SQLITE_OK!=ret)
44. {
45. fprintf(stderr,pErrMsg);
46. sqlite3_free(pErrMsg);
47. sqlite3_close(db);
48. return1;
49. }
50. printf("数据库建表成功！！n");
52. sqlite3_exec(db,"begin;",&pErrMsg);//开启事务
53. if(SQLITE_OK!=ret)
54. {
55. fprintf(stderr,"SQLbeginerror:%sn",pErrMsg);
56. sqlite3_free(pErrMsg);
57. sqlite3_close(db);
58. return1;
59. }
60. printf("数据库开启事务成功！！n");
62. for(inti=0;i<10;i++)
63. {
64. sprintf(sql,"insertintotest_for_cpp(id,name,age)values(%d,"%s",%d);",i,"Carl",i);
65. ret=sqlite3_exec(db,sql,&pErrMsg);
66. if(SQLITE_OK!=ret)
67. {
68. is_success=false;
69. fprintf(stderr,"for%dtimeerror:%sn",pErrMsg);
70. sqlite3_free(pErrMsg);
71. break;
72. }
73. }
75. if(is_success)
76. {
77. sqlite3_exec(db,"commit;",0);
78. printf("数据库插入数据成功！n");
79. }
80. else
81. {
82. sqlite3_exec(db,"rollback;",0);
83. printf("数据库插入数据失败！n");
84. }
86. ret=sqlite3_exec(db,"SQLERROR:%sn",pErrMsg);
87. sqlite3_free(pErrMsg);
88. sqlite3_close(db);
89. return1;
90. }
91. printf("数据库查询成功！！n");
93. sqlite3_close(db);
94. db=0;
96. return0;
97. }

/* 
 * File:   sqlite_test.cpp
 * Author: Carl
 *
 * Created on 2012年9月22日,上午7:50
 */

#include <cstdlib>
#include <cstdio>
#include <sqlite3.h>

static int _sql_callback(void *notused,argv[i] == 0 ? "NULL" : argv[i]);
    }
    printf("n");
    
    return 0;
}


/*
 * 
 */
int main(int argc,char** argv)
{
    const char *sSQL1 = "create table test_for_cpp (id int,name varchar(10),age int);";
    char sql[100] = {0};
    sqlite3 *db = NULL;
    char *pErrMsg = NULL;
    int ret = 0;
    bool is_success = true;
    const char *sSQL3 = "select * from test_for_cpp;";  
    
    ret = sqlite3_open("./test.db",&db);
    if (SQLITE_OK != ret)
    {
        fprintf(stderr,"无法打开数据库： %sn",sqlite3_errmsg(db));
        sqlite3_close(db);
        return 1;
    }
    printf("数据库连接成功n");  
    
    ret = sqlite3_exec(db,&pErrMsg);
    if (SQLITE_OK != ret)
    {
        fprintf(stderr,pErrMsg);
        sqlite3_free(pErrMsg);
        sqlite3_close(db);
        return 1;
    }
    printf("数据库建表成功！！n");  
    
    sqlite3_exec(db,"begin;",&pErrMsg); //开启事务
    if (SQLITE_OK != ret)
    {
        fprintf(stderr,"SQL begin error: %sn",pErrMsg);
        sqlite3_free(pErrMsg);
        sqlite3_close(db);
        return 1;
    }
    printf("数据库开启事务成功！！n");  
    
    for (int i = 0; i < 10; i++)
    {
        sprintf(sql,"insert into test_for_cpp(id,age) values(%d,%d);","Carl",i);
        ret = sqlite3_exec(db,&pErrMsg);
        if (SQLITE_OK != ret)
        {
            is_success = false;
            fprintf(stderr,"for %d time error: %sn",pErrMsg);
            sqlite3_free(pErrMsg);
            break;
        }
    }
    
    if (is_success)
    {
        sqlite3_exec(db,"commit;",0);
        printf("数据库插入数据成功！n");  
    }
    else
    {
        sqlite3_exec(db,"rollback;",0);
        printf("数据库插入数据失败！n");  
    }
    
    ret = sqlite3_exec(db,"SQL ERROR: %sn",pErrMsg);
        sqlite3_free(pErrMsg);
        sqlite3_close(db);
        return 1;
    }
    printf("数据库查询成功！！n");  
    
    sqlite3_close(db);
    db = 0;
    
    return 0;
}

1. [carl@Fedorasqlite]$g++sqlite_test.cpp-lsqlite3
2. [carl@Fedorasqlite]$./a.out
3. 数据库连接成功
4. 数据库建表成功！！
5. 数据库开启事务成功！！
6. 数据库插入数据成功！
7. notused:0x0,argc:3
8. id=0
9. name=Carl
10. age=0
12. notused:0x0,argc:3
13. id=1
14. name=Carl
15. age=1
17. notused:0x0,argc:3
18. id=2
19. name=Carl
20. age=2
22. notused:0x0,argc:3
23. id=3
24. name=Carl
25. age=3
27. notused:0x0,argc:3
28. id=4
29. name=Carl
30. age=4
32. notused:0x0,argc:3
33. id=5
34. name=Carl
35. age=5
37. notused:0x0,argc:3
38. id=6
39. name=Carl
40. age=6
42. notused:0x0,argc:3
43. id=7
44. name=Carl
45. age=7
47. notused:0x0,argc:3
48. id=8
49. name=Carl
50. age=8
52. notused:0x0,argc:3
53. id=9
54. name=Carl
55. age=9
57. 数据库查询成功！！
58. [carl@Fedorasqlite]$

[carl@Fedora sqlite]$ g++ sqlite_test.cpp -lsqlite3
[carl@Fedora sqlite]$ ./a.out 
数据库连接成功
数据库建表成功！！
数据库开启事务成功！！
数据库插入数据成功！
notused:0x0,argc:3
id = 0
name = Carl
age = 0

notused:0x0,argc:3
id = 1
name = Carl
age = 1

notused:0x0,argc:3
id = 2
name = Carl
age = 2

notused:0x0,argc:3
id = 3
name = Carl
age = 3

notused:0x0,argc:3
id = 4
name = Carl
age = 4

notused:0x0,argc:3
id = 5
name = Carl
age = 5

notused:0x0,argc:3
id = 6
name = Carl
age = 6

notused:0x0,argc:3
id = 7
name = Carl
age = 7

notused:0x0,argc:3
id = 8
name = Carl
age = 8

notused:0x0,argc:3
id = 9
name = Carl
age = 9

数据库查询成功！！
[carl@Fedora sqlite]$ 

3. 我们接着看一下如何能够更好的使用语句参数来操作sqlite数据库，用sqlite3_prepare_v2，sqlite3_bind_*，sqlite3_step，sqlite3_column_*等接口来实现对数据库的操作。

代码如下：里面的注释，有兴趣的可以试着打开试一下，但要记得注释掉相关的重复功能的语句哦。

1. /*
2. *File:sqlite_test2.cpp
3. *Author:Carl
4. *
5. *CreatedonSeptember21,3:12PM
6. */
8. #include<cstdlib>
9. #include<cstdio>
10. #include<cstring>
11. #include<sqlite3.h>
13. staticint_sql_callback(void*notused,char**szColName)
14. {
15. inti=0;
17. printf("notused:0x%x,argc);
18. for(i=0;i<argc;i++)
19. {
20. printf("%s=%sn",argv[i]==0?"NULL":argv[i]);
21. }
22. printf("n");
24. return0;
25. }
27. /*
28. *
29. */
30. intmain(intargc,char**argv)
31. {
32. sqlite3*conn=NULL;
33. sqlite3_stmt*stmt=NULL;
34. char*err_msg=NULL;
35. intret=0;
37. charcol_types[][10]={"","Interger","Float","Text","Blob","NULL"};
39. ret=sqlite3_open("./test.db",&conn);
40. if(SQLITE_OK!=ret)
41. {
42. fprintf(stderr,"sqliteopenerr,%dn",ret);
43. return1;
44. }
45. printf("打开数据库成功！！！n");
47. //ret=sqlite3_prepare_v2(conn,"SELECT*FROM[test_for_cpp]WHERE[name]==:name",-1,&stmt,(constchar**)&err_msg);
48. ret=sqlite3_prepare_v2(conn,"SELECT*FROM[test_for_cpp]WHERE[name]==?2",(constchar**)&err_msg);
49. if(SQLITE_OK!=ret)
50. {
51. fprintf(stderr,"sqliteprepareerror:%sn",err_msg);
52. sqlite3_free(err_msg);
53. sqlite3_close(conn);
54. return1;
55. }
56. //printf("数据库语句对象编译成功！！！%dn",sqlite3_bind_parameter_index(stmt,":name"));
57. printf("数据库语句对象编译成功！！！n");
59. ret=sqlite3_bind_text(stmt,2,4,SQLITE_STATIC);
60. if(SQLITE_OK!=ret)
61. {
62. fprintf(stderr,"sqlitebinderror:%dn",ret);
63. sqlite3_close(conn);
64. return1;
65. }
66. printf("数据库语句对象bind成功！！！n");
68. while(ret=sqlite3_step(stmt),ret==SQLITE_ROW)
69. {
70. intcol_count=sqlite3_column_count(stmt);//结果集中列的数量
71. printf("列数:%dt",col_count);
72. constchar*col_0_name=sqlite3_column_name(stmt,0);//获取列名
73. printf("列名:%st",col_0_name);
74. intid=sqlite3_column_int(stmt,0);
75. printf("id值:%dt",id);
76. intid_type=sqlite3_column_type(stmt,0);//获取列数据类型
77. printf("id类型:%dt",id_type);
79. constchar*col_2_name=sqlite3_column_name(stmt,2);
80. intage=sqlite3_column_int(stmt,2);
81. intage_type=sqlite3_column_type(stmt,2);
83. constchar*col_1_name=sqlite3_column_name(stmt,1);
84. charname[80];
85. strncpy(name,(constchar*)sqlite3_column_text(stmt,1),80);
86. intname_type=sqlite3_column_type(stmt,1);
88. //打印结果
89. printf("col_count:%d,%s=%d(%s),%s=%s(%s),%s=%d(%s)n",
90. col_count,col_0_name,id,col_types[id_type],col_1_name,
91. col_types[name_type],col_2_name,age,col_types[age_type]);
92. }
94. fprintf(stderr,"sqlitestepexitwith%dn",ret);
95. sqlite3_finalize(stmt);
96. sqlite3_close(conn);
98. return0;
99. }

/* 
 * File:   sqlite_test2.cpp
 * Author: Carl
 *
 * Created on September 21,3:12 PM
 */

#include <cstdlib>
#include <cstdio>
#include <cstring>
#include <sqlite3.h>

static int _sql_callback(void *notused,char** argv)
{
    sqlite3 *conn = NULL;
    sqlite3_stmt *stmt = NULL;
    char *err_msg = NULL;
    int ret = 0;
    
    char col_types[][10] = {"","Interger","Float","Text","Blob","NULL"};
    
    ret = sqlite3_open("./test.db",&conn);
    if (SQLITE_OK != ret)
    {
        fprintf(stderr,"sqlite open err,%dn",ret);
        return 1;
    }
    printf("打开数据库成功！！！n");
    
//    ret = sqlite3_prepare_v2(conn,"SELECT * FROM [test_for_cpp] WHERE [name]==:name",(const char **)&err_msg);
    ret = sqlite3_prepare_v2(conn,"SELECT * FROM [test_for_cpp] WHERE [name]==?2",(const char **)&err_msg);
    if (SQLITE_OK != ret)
    {
        fprintf(stderr,"sqlite prepare error: %sn",err_msg);
        sqlite3_free(err_msg);
        sqlite3_close(conn);
        return 1;
    }
//    printf("数据库语句对象编译成功！！！%dn",":name"));
    printf("数据库语句对象编译成功！！！n");
    
    ret = sqlite3_bind_text(stmt,SQLITE_STATIC);
    if (SQLITE_OK != ret)
    {
        fprintf(stderr,"sqlite bind error: %dn",ret);
        sqlite3_close(conn);
        return 1;
    }
    printf("数据库语句对象bind成功！！！n");
    
    while (ret = sqlite3_step(stmt),ret == SQLITE_ROW)
    {
        int col_count = sqlite3_column_count(stmt); //结果集中列的数量
        printf("列数:%dt",col_count);
        const char *col_0_name = sqlite3_column_name(stmt,0); //获取列名
        printf("列名:%st",col_0_name);
        int id = sqlite3_column_int(stmt,0);
        printf("id值:%dt",id);
        int id_type = sqlite3_column_type(stmt,0); //获取列数据类型
        printf("id类型:%dt",id_type);
        
        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,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_types[name_type],col_types[age_type]);
    }
    
    fprintf(stderr,"sqlite step exit with %dn",ret);
    sqlite3_finalize(stmt);
    sqlite3_close(conn);
    
    return 0;
}

1. [carl@Fedorasqlite]$g++sqlite_test2.cpp-lsqlite3
2. [carl@Fedorasqlite]$./a.out
3. 打开数据库成功！！！
4. 数据库语句对象编译成功！！！
5. 数据库语句对象bind成功！！！
6. 列数:3列名:idid值:0id类型:1col_count:3,id=0(Interger),name=Carl(Text),age=0(Interger)
7. 列数:3列名:idid值:1id类型:1col_count:3,id=1(Interger),age=1(Interger)
8. 列数:3列名:idid值:2id类型:1col_count:3,id=2(Interger),age=2(Interger)
9. 列数:3列名:idid值:3id类型:1col_count:3,id=3(Interger),age=3(Interger)
10. 列数:3列名:idid值:4id类型:1col_count:3,id=4(Interger),age=4(Interger)
11. 列数:3列名:idid值:5id类型:1col_count:3,id=5(Interger),age=5(Interger)
12. 列数:3列名:idid值:6id类型:1col_count:3,id=6(Interger),age=6(Interger)
13. 列数:3列名:idid值:7id类型:1col_count:3,id=7(Interger),age=7(Interger)
14. 列数:3列名:idid值:8id类型:1col_count:3,id=8(Interger),age=8(Interger)
15. 列数:3列名:idid值:9id类型:1col_count:3,id=9(Interger),age=9(Interger)
16. sqlitestepexitwith101//101意思为SQLITE_DONE
17. [carl@Fedorasqlite]$

[carl@Fedora sqlite]$ g++ sqlite_test2.cpp -lsqlite3
[carl@Fedora sqlite]$ ./a.out 
打开数据库成功！！！
数据库语句对象编译成功！！！
数据库语句对象bind成功！！！
列数:3	列名:id	id值:0	id类型:1	col_count: 3,id = 0(Interger),name = Carl(Text),age = 0(Interger)
列数:3	列名:id	id值:1	id类型:1	col_count: 3,id = 1(Interger),age = 1(Interger)
列数:3	列名:id	id值:2	id类型:1	col_count: 3,id = 2(Interger),age = 2(Interger)
列数:3	列名:id	id值:3	id类型:1	col_count: 3,id = 3(Interger),age = 3(Interger)
列数:3	列名:id	id值:4	id类型:1	col_count: 3,id = 4(Interger),age = 4(Interger)
列数:3	列名:id	id值:5	id类型:1	col_count: 3,id = 5(Interger),age = 5(Interger)
列数:3	列名:id	id值:6	id类型:1	col_count: 3,id = 6(Interger),age = 6(Interger)
列数:3	列名:id	id值:7	id类型:1	col_count: 3,id = 7(Interger),age = 7(Interger)
列数:3	列名:id	id值:8	id类型:1	col_count: 3,id = 8(Interger),age = 8(Interger)
列数:3	列名:id	id值:9	id类型:1	col_count: 3,id = 9(Interger),age = 9(Interger)
sqlite step exit with 101 //101意思为SQLITE_DONE
[carl@Fedora sqlite]$ 

（1） 使用“语句参数”方式，具有更高的安全性，可以有效防止“SQL注入攻击”。 “SQL注入攻击”要想达到目的，就必须让attack value随着SQL命令字符串一起传送进SQL解析器。黑客如果在一条SQL命令字符串被送入到sqlite3_prepare函数之前，利用c字符串处理函数等途径将attack value注入其中，而在sqlite3_prepare函数之中进行解析（parse），就可以达到攻击目的。而使用“语句参数”方式，被传送到sqlite3_prepare函数的只是SQL命令字符串中的参数符号（如：“?”），而不是具体的值。在sqlite3_prepare函数执行之后，才会使用bind函数给参数符号绑定具体的值，这就可以避免attack value随着SQL命令字符串一起在sqlite3_prepare函数中被解析，从而有效躲避“SQL注入攻击”。
（2）使用“语句参数”方式，可以更快的完成值替换。

（3）使用“语句参数”方式，更节省内存。原因是使用如snprintf函数，需要一个SQL命令模板，一块足够大的输出缓存，而且字符串处理函数需要工作内存（working memory），除此之外对于整形，浮点型，特别是BLOBs，经常会占用更多的空间。

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!