xylz,imxylz

關注后端架構、中間件、分布式和并發編程

:: 首頁 :: 新隨筆 :: 聯系 :: 聚合

:: 管理 ::

111 隨筆 :: 10 文章 :: 2680 評論 :: 0 Trackbacks

公告

常用鏈接

留言簿(149)

隨筆分類(137)

隨筆檔案(107)

文章分類(12)

文章檔案(12)

友情鏈接

imxylz (rss)
jafka
a fast distributed publish-subscribe messaging system

搜索

積分與排名

積分 - 2206855
排名 - 4

閱讀排行榜

評論排行榜

SQLite3 C語言API入門

下載SQLite3

我們下載sqlite源碼包，只需要其中的sqlite3.c、sqlite.h即可。

最簡單的一個創建表操作

#include <stdio.h>
#include "sqlite3.h"

int main(int argc,char *argv[]){
    const char *sql_create_table="create table t(id int primary key,msg varchar(128))";
    char *errmsg = 0;
    int ret = 0;

    sqlite3 *db = 0;
    ret = sqlite3_open("./sqlite3-demo.db",&db);
    if(ret != SQLITE_OK){
        fprintf(stderr,"Cannot open db: %s\n",sqlite3_errmsg(db));
        return 1;
    }
    printf("Open database\n");

    ret = sqlite3_exec(db,sql_create_table,NULL,NULL,&errmsg);
    if(ret != SQLITE_OK){
        fprintf(stderr,"create table fail: %s\n",errmsg);
    }
    sqlite3_free(errmsg);
    sqlite3_close(db);

    printf("Close database\n");

    return 0;
}

在這個操作中我們執行了如下操作：

打開數據庫
執行SQL語句
關閉數據庫

當然這中間會有一些狀態的判斷以及內存指針的釋放等。

打開數據庫的API如下：

int sqlite3_open(
const char *filename, /* Database filename (UTF-8) */
sqlite3 **ppDb /* OUT: SQLite db handle */
);

這里會引入一個非常復雜的sqlite3的數據結構。這個根據需要以后酌情了解些。

打開數據庫除了這種形式意外，還有sqlite3_open、sqlite3_open16、sqlite3_open_v2幾種形式，基本上類似。

大部分sql操作都可以通過sqlite3_exec來完成，它的API形式如下：

int sqlite3_exec(
  sqlite3*,                                  /* An open database */
  const char *sql,                           /* SQL to be evaluated */
  int (*callback)(void*,int,char**,char**),  /* Callback function */
  void *,                                    /* 1st argument to callback */
  char **errmsg                              /* Error msg written here */
);

各個參數的意義為：

sqlite3描述的是數據庫句柄
sql 要執行的SQL語句
callback回調函數
void *回調函數的第一個參數
errmsg錯誤信息，如果沒有SQL問題則值為NULL

回調函數式一個比較復雜的函數。它的原型是這樣的:

int callback(void *params,int column_size,char **column_value,char **column_name){

每一個參數意義如下：

params是sqlite3_exec傳入的第四個參數
column_size是結果字段的個數
column_value是返回記錄的一位字符數組指針
column_name是結果字段的名稱

通常情況下callback在select操作中會使用到，尤其是處理每一行記錄數。返回的結果每一行記錄都會調用下“回調函數”。如果回調函數返回了非0，那么sqlite3_exec將返回SQLITE_ABORT，并且之后的回調函數也不會執行，同時未執行的子查詢也不會繼續執行。

對于更新、刪除、插入等不需要回調函數的操作，sqlite3_exec的第三、第四個參數可以傳入0或者NULL。

通常情況下sqlite3_exec返回SQLITE_OK=0的結果，非0結果可以通過errmsg來獲取對應的錯誤描述。

Windows下編譯：

D:\home\dev\c>cl /nologo /TC sqlite3-demo.c sqlite3.c

GCC下編譯:

$ gcc -o sqlite3-demo.bin sqlite3-demo.c sqlite3.c

刪除表操作

為了防止垃圾數據，我們在加載數據庫的時候刪除表操作。

簡單的刪除操作可以直接使用sqlite3_exec即可。這里不需要回調函數以及回調函數的參數。當然需要可以關注sqlite3_exec返回的結果是否為SQLITE_OK的值。

const char *sql_drop_table="drop table if exists t";
const char *sql_create_table="create table t(id int primary key,msg varchar(128))";

sqlite3_exec(db,sql_drop_table,0,0,&errmsg);
sqlite3_exec(db,sql_create_table,0,0,&errmsg);

插入數據

插入第一條數據

ret = sqlite3_exec(db,"insert into t(id,msg) values(1,'Ady Liu')",NULL,NULL,&errmsg);
printf("Insert a record %s\n",ret == SQLITE_OK ? "OK":"FAIL");

返回值ret為SQLITE_OK即操作成功。

插入多條數據，并刪除數據

ret = sqlite3_exec(db,"insert into t(id,msg) values(1,'Ady Liu')",NULL,NULL,&errmsg);
    printf("Insert a record %s\n",ret == SQLITE_OK ? "OK":"FAIL");
    ret = sqlite3_exec(db,"insert into t(id,msg) values(2,'IMXYLZ')",NULL,NULL,&errmsg);
    printf("Insert a record %s\n",ret == SQLITE_OK ? "OK":"FAIL");
    ret = sqlite3_exec(db,"delete from t where id < 3",NULL,NULL,&errmsg);
    printf("Delete records: %s\n",ret == SQLITE_OK ? "OK":"FAIL");

插入多條數據，簡單的使用sqlite3_exec進行SQL執行即可。當然這里是完整的SQL字符串。

預編譯操作

  int i = 0;
    sqlite3_stmt *stmt;
    char ca[255];

    //prepare statement
    sqlite3_prepare_v2(db,"insert into t(id,msg) values(?,?)",-1,&stmt,0);
    for(i=10;i<20;i++){
        sprintf(ca,"HELLO#%i",i);
        sqlite3_bind_int(stmt,1,i);
        sqlite3_bind_text(stmt,2,ca,strlen(ca),NULL);
        sqlite3_step(stmt);
        sqlite3_reset(stmt);
    }
    sqlite3_finalize(stmt);

預編譯操作比較麻煩的，完整的預編譯操作的流程是：

通過sqlite3_prepare_v2()創建一個sqlite3_stmt對象
通過sqlite3_bind_*()綁定預編譯字段的值
通過sqlite3_step()執行SQL語句
通過sqlite3_reset()重置預編譯語句，重復操作2多次
通過sqlite3_finalize()銷毀資源

sqlite3_prepare_v2()有個多種類似的形式，完整的API語法是：

int sqlite3_prepare(
  sqlite3 *db,            /* Database handle */
  const char *zSql,       /* SQL statement, UTF-8 encoded */
  int nByte,              /* Maximum length of zSql in bytes. */
  sqlite3_stmt **ppStmt,  /* OUT: Statement handle */
  const char **pzTail     /* OUT: Pointer to unused portion of zSql */
);

各個參數的定義為：

db為sqlite3的句柄
zSql為要執行的SQL語句
nByte為要執行語句在zSql中的最大長度，如果是負數，那么就需要重新自動計算
ppStmt為預編譯后的句柄
pzTail預編譯后剩下的字符串（未預編譯成功或者多余的）的指針，通常沒什么用，傳入0或者NULL即可。

綁定參數sqlite3_bind_*有多種形式，分別對應不同的數據類型:

int sqlite3_bind_blob(sqlite3_stmt*, int, const void*, int n, void(*)(void*));
int sqlite3_bind_double(sqlite3_stmt*, int, double);
int sqlite3_bind_int(sqlite3_stmt*, int, int);
int sqlite3_bind_int64(sqlite3_stmt*, int, sqlite3_int64);
int sqlite3_bind_null(sqlite3_stmt*, int);
int sqlite3_bind_text(sqlite3_stmt*, int, const char*, int n, void(*)(void*));
int sqlite3_bind_text16(sqlite3_stmt*, int, const void*, int, void(*)(void*));
int sqlite3_bind_value(sqlite3_stmt*, int, const sqlite3_value*);
int sqlite3_bind_zeroblob(sqlite3_stmt*, int, int n);

預編譯SQL語句中可以包含如下幾種形式：

?
?NNN
:VVV
@VVV
$VVV

NNN代表數字，VVV代表字符串。

如果是?或者?NNN，那么可以直接sqlite3_bind_*()進行操作，如果是字符串，還需要通過sqlite3_bind_parameter_index()獲取對應的index，然后再調用sqlite3_bind_*()操作。這通常用于構造不定條件的SQL語句（動態SQL語句）。

查詢操作

回調函數的解釋參考最上面的描述。首先聲明一個回調函數。

int print_record(void *,int,char **,char **);

查詢代碼

  //select data
    ret = sqlite3_exec(db,"select * from t",print_record,NULL,&errmsg);
    if(ret != SQLITE_OK){
        fprintf(stderr,"query SQL error: %s\n",errmsg);
    }

現在定義回調函數，只是簡單的輸出字段值。

int print_record(void *params,int n_column,char **column_value,char **column_name){
    int i;
    for(i=0;i<n_column;i++){
        printf("\t%s",column_value[i]);
    }
    printf("\n");
    return 0;
}

不使用回調的查詢操作

定義使用的變量

 char **dbresult; int j,nrow,ncolumn,index;

查詢操作

  //select table
    ret = sqlite3_get_table(db,"select * from t",&dbresult,&nrow,&ncolumn,&errmsg);
    if(ret == SQLITE_OK){
        printf("query %i records.\n",nrow);
        index=ncolumn;
        for(i=0;i<nrow;i++){
            printf("[%2i]",i);
            for(j=0;j<ncolumn;j++){
                printf(" %s",dbresult[index]);
                index++;
            }
            printf("\n");
        }
    }
    sqlite3_free_table(dbresult);

sqlite3_get_table的API語法：

int sqlite3_get_table(
  sqlite3 *db,          /* An open database */
  const char *zSql,     /* SQL to be evaluated */
  char ***pazResult,    /* Results of the query */
  int *pnRow,           /* Number of result rows written here */
  int *pnColumn,        /* Number of result columns written here */
  char **pzErrmsg       /* Error msg written here */
);
void sqlite3_free_table(char **result);

其中：

db是sqlite3的句柄
zSql是要執行的sql語句
pazResult是執行查詢操作的返回結果集
pnRow是記錄的行數
pnColumn是記錄的字段個數
pzErrmsg是錯誤信息

由于sqlite3_get_table是sqlite3_exec的包裝，因此返回的結果和sqlite3_exec類似。

pazResult是一個(pnRow+1)*pnColumn結果集的字符串數組，其中前pnColumn個結果是字段的名稱，后pnRow行記錄是真實的字段值，如果某個字段為空，則對應值為NULL。

最后需要通過sqlite3_free_table()釋放完整的結果集。

更新操作

 sqlite3_exec(db,"update t set msg='MESSAGE#10' where id=10",NULL,NULL,&errmsg);

當然了，我們也可以使用預編譯方法進行更新操作。

受影響的記錄數

我們可以使用sqlite3_change(sqlite3 *)的API來統計上一次操作受影響的記錄數。

 ret = sqlite3_exec(db,"delete from t",NULL,NULL,&errmsg); 

if(ret == SQLITE_OK){

printf("delete records: %i\n",sqlite3_changes(db));

}

總結

這里我們接觸了SQLITE3的13個API：

sqlite3_open()
sqlite3_exec()
sqlite3_close()
sqlite3_prepare_v2
sqlite3_bind_*()
sqlite3_bind_parameter_index()
sqlite3_step()
sqlite3_reset()
sqlite3_finalize()
sqlite3_get_table
sqlite3_change()
sqlite3_free()
sqlite3_free_table()

事實上截止到SQLITE3.7.14(2012/09/03) 一共提供了204個API函數（http://www.sqlite.org/c3ref/funclist.html）。

但最精簡的API函數大概有6個：

sqlite3_open()
sqlite3_prepare()
sqlite3_step()
sqlite3_column()
sqlite3_finalize()
sqlite3_close()

核心API也就10個（在精簡API基礎上增加4個）：

sqlite3_exec()
sqlite3_get_table()
sqlite3_reset()
sqlite3_bind()

因此掌握起來還是比較容易的。

完整的源碼地址： https://gist.github.com/3780669

posted on 2012-09-25 16:34 imxylz 閱讀(28395) 評論(0) 編輯收藏所屬分類: 技術

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發表評論。




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: 世界邦旅行網(北京)招聘Java高級/資深工程師前端工程師/移動開發工程師等_20150616更新 Java 8 入門/新特性 Bash命令路徑的緩存 MAC下批量轉換PNG和JPEG Octopress加速Google字體渲染 JRebel 6.0.0 Crack (20141216更新) 申請SSL證書及Nginx支持HTTPS 隨機選擇集合的子元素集合 Python 基礎文件操作 Crack JRebel 5.3.1

xylz,imxylz

公告

常用鏈接

留言簿(149)

隨筆分類(137)

隨筆檔案(107)

文章分類(12)

文章檔案(12)

友情鏈接

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜

SQLite3 C語言API入門

下載SQLite3

最簡單的一個創建表操作

刪除表操作

插入數據

插入多條數據，并刪除數據

預編譯操作

查詢操作

不使用回調的查詢操作

更新操作

受影響的記錄數

總結