董平教授讲王阳明视频:sqlite 事务代码

Sqlite是我最喜歡使用的文件數據庫，它小巧、方便、速度快、支持大部分標準sql語句、開源、免費 .. .. .. 優點太多了。自從認識了她之後，我就將Access打入了冷宮，發誓以後再也不用Access了。我們可以到Sqlite的官方網站下載Sqlite的源代碼，編譯後的結果只有200多K，太小巧，太卡哇依了。如果嫌自己手動編譯麻煩，也可以直接從官網下載二進制的可執行文件或者動態鏈接庫。可執行文件可以用命令行的方式來創建、操作數據庫；動態鏈接庫則可以用程序來操作Sqlite數據庫。今天我就來介紹一下如何使用c/c++來操作Sqlite吧~~~

準備工作
    我這裏使用的sqlite版本是3.x，所以首先從官網下載動態鏈接庫sqlite3.dll；然後再下載api頭文件sqlite3.h。在Code::Block中新建一個C++的控制檯項目，添加對sqlite3.dll的引用，同時將sqlite3.h添加到項目中。我這裏還使用了一個工具：SqliteSpy，用於對數據庫進行可視化的操作。

開始使用API
    下面就開始使用API吧~。Sqlite的所有api，可以在這裏查詢到。

sqlite3_open
sqlite3_exec
sqlite3_close
    看到這些函數，我相信你大概能猜出這些函數的功能。sqlite3_open用於打開一個數據庫，並初始化一個數據庫的連接；sqlite3_close用於關閉連接；sqlte3_exec用於執行sql語句。用一個簡單的例子來演示這些函數的使用：下面的代碼創建一個數據庫test.db，並創建數據表：test_for_cpp。

// ----------------------------------------------
// http://blog.csdn.net/JGood// 創建數據庫
// sqlite3_open, sqlite3_exec, sqlite3_close
// ----------------------------------------------
sqlite3 *conn = NULL;   //數據庫連接。
char *err_msg = NULL;   //操作失敗的原因。
char sql[200];

// 打開數據庫, 創建連接
if (SQLITE_OK != sqlite3_open("test.db", &conn))
{
    printf("can't open the database.”);
    exit(-1);
}

// 執行SQL
sprintf(sql, "CREATE TABLE [test_for_cpp] (\
    [id] int, [name] varchar(20), [age] int)");
if (SQLITE_OK != sqlite3_exec(conn, sql, 0, 0, &err_msg))
{
    printf("operate failed: %s", err_msg);
    exit(-1);
}

// 關閉連接。
if (SQLITE_OK != sqlite3_close(conn))
{
    printf("can't close the database: %s\n", sqlite3_errmsg(conn));
    exit(-1);
}

printf("operate successfully. \n");上面的例子代碼都非常簡單。主要的函數sqlite3_exec比較複雜，它的原形爲：

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 */
);第三個參數是一個函數指針，表示函數執行完畢後的回調。第四個參數是傳遞給回調函數的參數，第五個參數表示執行失敗時的原因。下面用一個簡單的例子來演示該函數的詳細使用：

// ----------------------------------------------
// INSERT, SELECT
// sqlite3_exec的詳細使用
// ----------------------------------------------
sqlite3 *conn = NULL;   //數據庫連接。
char *err_msg = NULL;   //操作失敗的原因。
char sql[200];

// 回調函數聲明。
extern int sqlite3_exec_callback(void *data, int n_columns,
    char **col_values, char **col_names);

// 打開數據庫, 創建連接
sqlite3_open("test.db", &conn);

//添加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);
    sqlite3_exec(conn, sql, 0, 0, &err_msg);
}

// 查詢
sprintf(sql, "SELECT * FROM [test_for_cpp]");
sqlite3_exec(conn, sql, &sqlite3_exec_callback, 0, &err_msg);

// 關閉連接。
sqlite3_close(conn);

//… …/** sqlite3_exec的回調。
 *
 *  向控制檯打印查詢的結果。
 *
 *  @param in data 傳遞給回調函數的數據。
 *  @param in n_columns sqlite3_exec執行結果集中列的數量。
 *  @param in col_values sqlite3_exec執行結果集中每一列的數據。
 *  @param in col_names sqlite3_exec執行結果集中每一列的名稱。
 *  @return 狀態碼。
 */
int sqlite3_exec_callback(void *data, int n_columns, char **col_values, char **col_names)
{
    for (int i = 0; i < n_columns; i++)
    {
     printf("%s\t", col_values[i]);
    }
    printf("\n");

    return 0;
}下面是執行的結果：

使用事務
    在上面的例子中，我們向數據庫裏插入了10條數據，然後再從數據庫裏讀出來。細心的你不知道有沒有發現，在執行Insert的時候，並沒有使用同一個事務。在很多情況下，我們需要使用事務來保證對數據庫操作的原子性。Sqlite是支持事務的，而且對事務的使用非常簡單：使用sql語句”begin;”表示事務開始，”rollback;”表示事務的回滾，”commit;”表示事務的提交。下面我們對上面例子中的代碼作一下修改，給Insert操作添加事務支持：

//... ...

bool is_succed = true;
sqlite3_exec(conn, "begin;", 0, 0, 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, 0, 0, &err_msg))
    {
        is_succed = false;
        break;
    }
}

if (is_succed)
    sqlite3_exec(conn, "commit;", 0, 0, 0);  // 提交事務
else
    sqlite3_exec(conn, "rollback;", 0, 0, 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。

字符串編碼
    在官網上查看Sqlite的api的時候，發現有很同函數的名稱都非常相似，只是最後添加了”_16”，如：sqlite3_open和sqlite3_open16,  sqlite3_errmsg和sqlite3_errmsg16，等等。其實添加了”16”後綴的函數，主要用於支持utf-16編碼的字符串。如sqlite3_open16可以接收utf-16編碼的數據庫路徑。

    在sourceforge上，有一個開源的項目sqlitex，它封裝了這些api，使對sqlite數據庫的操作更加方便。sqlitex的源代碼非常的簡單，感興趣的同學可以下載下來自己研究。