sqlite3 示例程序

本文档简要描述了sqlite3 C API的用法，实现了插入和查找两个操作。常用sqlite3函数的参考地址：http://www.sqlite.org/c3ref/funclist.html

1、sqlite3_exec()

我们使用sqlite3_open()创建或打开数据库连接，使用sqlite3_exec来创建表，插入数据并查询数据；大多数情况下，我们使用sqlite3_prepare_v2()来查询数据。

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

#include <assert.h>  
#pragma comment(lib,"sqlite3.lib")  

typedef struct per
{
    char *name;
    int age;
    char *sex;
} per;

per a[] = {
    "David",22,"man","Eve",28,"Frand",21,"woman"
};



// 这个函数可以用来打印出每行的信息  
static int callback(void *NotUsed,int argc,char **argv,char **azColName){  
    int i;  
    for(i=0; i<argc; i++){  
        printf("%s = %s\n",azColName[i],argv[i] ? argv[i] : "NULL");  
    }  
    printf("\n");  
    return 0;  
}  

int main()  
{  
    sqlite3 *pdb;  
    char *zErrMsg;  
    sqlite3_stmt *pstmt;  
    const char *pzTail;  
    const unsigned char *pTmp;
    int age;
    int nCol;

    // 打开数据库连接   
    int nRet = sqlite3_open("e:\\db\\people.db",&pdb);  
    assert(sqlITE_OK == nRet);  

    // 创建表  
    const char *sql = "CREATE TABLE IF NOT EXISTS person(name VARCHAR(128),"  
        "age INTEGER,"  
        "sex VARCHAR(7)"  
        ");";  
    nRet = sqlite3_exec(pdb,sql,NULL,&zErrMsg);  
    if (nRet != sqlITE_OK)  
    {  
        printf("%s\n",zErrMsg);  
        sqlite3_close(pdb);  
        return 1;  
    }

    sql = "DELETE  FROM person;";
    nRet = sqlite3_exec(pdb,zErrMsg);  
        sqlite3_close(pdb);  
        return 1;  
    }

    // 使用sqlite3_exec() 插入数据  
    sql = "INSERT INTO person(name,age,sex) VALUES(\"Alice\",15,\"woman\");";  
    nRet = sqlite3_exec(pdb,&zErrMsg);  
    assert(sqlITE_OK == nRet);  // 为了简单，这里不打印zErrMsg的值  

    sql = "INSERT INTO person(name,sex) VALUES(\"Bob\",18,\"man\");";  
    nRet = sqlite3_exec(pdb,sex) VALUES(\"Charli\",11,&zErrMsg);  
    assert(sqlITE_OK == nRet);  // 为了简单，这里不打印zErrMsg的值  

    // 使用sqlite3_exec() 查询数据  
    printf("=====query by sqlite3_exec()=====\n");
    sql = "SELECT name,sex FROM person;";  
    nRet = sqlite3_exec(pdb,callback,&zErrMsg);  
    assert(sqlITE_OK == nRet);  

    // 使用sqlite3_prepare_v2(),sqlite3_bind_...() 插入数据
    sql = "INSERT INTO person(name,sex) VALUES(?,?,?);";
    nRet = sqlite3_prepare_v2(pdb,strlen(sql),&pstmt,&pzTail);
    assert(sqlITE_OK == nRet);  
    int i;
    for (i=0;i<sizeof(a)/sizeof(per);i++)
    {
        nCol = 1;
        sqlite3_bind_text(pstmt,nCoL++,a[i].name,strlen(a[i].name),NULL);
        sqlite3_bind_int(pstmt,a[i].age);
        sqlite3_bind_text(pstmt,a[i].sex,strlen(a[i].sex),NULL);

        sqlite3_step(pstmt);
        sqlite3_reset(pstmt);
    }

    sqlite3_finalize(pstmt);

    // 使用sqlite3_prepare_v2(),sqlite3_column_...() 查询数据

    printf("====== query by sqlite3_prepare_v2()======\n");
    sql = "SELECT name,sex FROM person;";
    nRet = sqlite3_prepare_v2(pdb,&pzTail);
    assert(sqlITE_OK == nRet);  

    while(1)
    {
        nRet = sqlite3_step(pstmt);
        if (sqlITE_DONE == nRet)
        {
            sqlite3_finalize(pstmt);
            break;
        }
        if (sqlITE_ROW == nRet)
        {
            nCol = 0;
            pTmp = sqlite3_column_text(pstmt,nCoL++);
            printf("%s|",pTmp);

            age = sqlite3_column_int(pstmt,nCoL++);
            printf("%d|",age);

            pTmp = sqlite3_column_text(pstmt,nCoL++);
            printf("%s\n",pTmp);

            continue;
        }

        printf("something error.\n");
        sqlite3_finalize(pstmt);
        break;
    }

    sqlite3_close(pdb);  
    return 0; 
}