摘要：目前支持兩種關(guān)系型數(shù)據(jù)庫(kù)需要鏈接對(duì)應(yīng)的和，并對(duì)其接口進(jìn)行了封裝，使用更加的方便簡(jiǎn)潔并且只需要換個(gè)，就可以隨時(shí)切換成其他數(shù)據(jù)庫(kù)引擎，而不需要修改接口。

TBOX目前支持sqlite3、mysql兩種關(guān)系型數(shù)據(jù)庫(kù)（需要鏈接對(duì)應(yīng)的libsqlite3.a和libmysql.a），并對(duì)其接口進(jìn)行了封裝，使用更加的方便簡(jiǎn)潔并且只需要換個(gè)url，就可以隨時(shí)切換成其他數(shù)據(jù)庫(kù)引擎，而不需要修改接口。

下面先看個(gè)簡(jiǎn)單的例子：

/* 初始化一個(gè)mysql數(shù)據(jù)庫(kù)
 *
 * localhost:   主機(jī)名，也可以是ip地址
 * type:        數(shù)據(jù)庫(kù)的類型，目前支持：mysql 和 sqlite3兩種類型
 * username:    數(shù)據(jù)庫(kù)用戶名
 * password:    數(shù)據(jù)庫(kù)用戶密碼
 * database:    要訪問(wèn)的數(shù)據(jù)庫(kù)名稱， 如果不設(shè)置則自動(dòng)連接默認(rèn)的數(shù)據(jù)庫(kù)
 *
 * 若果逆向指定個(gè)端口，可以顯示傳入：
 * "sql://localhost:3306/?type=mysql&username=xxxx&password=xxxx&database=xxxx"
 *
 * sqlite3的數(shù)據(jù)庫(kù)訪問(wèn)url為：
 * "sql:///home/file.sqlitedb?type=sqlite3"
 *
 * 或者直接傳文件路徑：
 * "/home/file.sqlite3"
 * "file:///home/file.sqlitedb"
 * "C://home/file.sqlite3"
 */
tb_database_sql_ref_t database = tb_database_sql_init("sql://localhost/?type=mysql&username=xxxx&password=xxxx&database=test");
if (database)
{
    // 打開(kāi)數(shù)據(jù)庫(kù)
    if (tb_database_sql_open(database))
    {
        // 執(zhí)行sql語(yǔ)句，進(jìn)行查詢
        if (tb_database_sql_done(database, "select * from test"))
        {
            /* 加載結(jié)果集
             *
             * 如果是insert, update等非select語(yǔ)句執(zhí)行，這個(gè)時(shí)候返回tb_null， 說(shuō)明沒(méi)有結(jié)果集
             *
             * 這個(gè)結(jié)果集完全采用迭代器模式，方便快速迭代訪問(wèn)。
             *
             * 后面的參數(shù)tb_true指示盡量一次性加載所有結(jié)果到內(nèi)存，如果成功
             * 就可以通過(guò)tb_iterator_size(result)獲取實(shí)際的結(jié)果集行數(shù)。
             *
             * 如果一次性加載失敗或者傳入的是tb_false， 說(shuō)明只能通過(guò)fetch，一行行的回滾數(shù)據(jù)行
             * 這樣占用內(nèi)存的資源較少，但是沒(méi)法提前獲取到實(shí)際的行數(shù)，這個(gè)時(shí)候tb_iterator_size(result)
             * 返回的是一個(gè)超大值
             */
            tb_iterator_ref_t result = tb_database_sql_result_load(database, tb_true);
            if (result)
            {
                // 如果一次性加載成功，返回實(shí)際的結(jié)果行數(shù)
                tb_trace_i("row: size: %lu", tb_iterator_size(result));
                
                // 遍歷所有行
                tb_for_all_if (tb_iterator_ref_t, row, result, row)
                {
                    // 顯示行的列數(shù)
                    tb_trace_i("[row: %lu, col: size: %lu]: ", row_itor, tb_iterator_size(row));
                    
                    // 遍歷這一行中的所有值
                    tb_for_all_if (tb_database_sql_value_t*, value, row, value)
                    {
                        /* tb_database_sql_value_name(value): 獲取值所對(duì)應(yīng)列名
                         * tb_database_sql_value_text(value)：獲取值的文本數(shù)據(jù)，如果是text類型的話
                         * tb_database_sql_value_type(value)：獲取值的類型
                         *
                         * ...
                         */
                        tb_tracet_i("[%s:%s] ", tb_database_sql_value_name(value), tb_database_sql_value_text(value));
                    }
                }
                
                // 釋放結(jié)果集數(shù)據(jù)
                tb_database_sql_result_exit(database, result);
            }
        }
        else
        {
            // 執(zhí)行失敗，顯示失敗狀態(tài)和原因
            tb_trace_e("done %s failed, error: %s", sql, tb_state_cstr(tb_database_sql_state(database)));
        }
    }
    else
    {
        // 打開(kāi)失敗，顯示失敗狀態(tài)和原因
        tb_trace_e("open failed: %s", tb_state_cstr(tb_database_sql_state(database)));
    }
    
    // 退出數(shù)據(jù)庫(kù)
    tb_database_sql_exit(database);
}

上面的例子沒(méi)法處理二進(jìn)制數(shù)據(jù)，如果要處理二進(jìn)制數(shù)據(jù)，比如插入一個(gè)圖像數(shù)據(jù)什么的可以使用statement模式，預(yù)編譯一個(gè)sql語(yǔ)句，bind每個(gè)參數(shù)來(lái)實(shí)現(xiàn)，這種方式更加的靈活而且對(duì)于頻繁處理某個(gè)sql語(yǔ)句的情況，效率更高，因?yàn)槭∪ッ看味家馕鲆槐閟ql語(yǔ)法的過(guò)程。

具體使用過(guò)程也很簡(jiǎn)單，下面先看個(gè)insert二進(jìn)制數(shù)據(jù)的例子：

// done
tb_database_sql_statement_ref_t     stmt = tb_null;
tb_stream_ref_t                     stream = tb_null;
do
{
    // 初始化一個(gè)插入語(yǔ)句，需要自定義傳入的參數(shù)用?代替， 并進(jìn)行預(yù)編譯處理
    if (!(stmt = tb_database_sql_statement_init(database, "insert into table2 values(?, ?, ?, ?, ?, ?, ?)")))
    {
        // trace
        tb_trace_e("stmt: init %s failed, error: %s", sql, tb_state_cstr(tb_database_sql_state(database)));
        break ;
    }
    
    // 初始化一個(gè)超大圖像數(shù)據(jù)流
    stream = tb_stream_init_from_url("/tmp/large_image.png");
    tb_assert_and_check_break(stream);
    
    // 打開(kāi)流
    if (!tb_stream_open(stream)) break;
    
    // 參數(shù)列表
    tb_database_sql_value_t list[7];

    // 綁定一個(gè)text類型的參數(shù)，sql中對(duì)應(yīng)：text
    tb_database_sql_value_set_text(&list[0], "hello", 0);

    // 綁定一個(gè)uint16大小的blob數(shù)據(jù)參數(shù)，由于是小塊數(shù)據(jù)，不用使用stream，sql中對(duì)應(yīng)：blob
    tb_database_sql_value_set_blob16(&list[1], data, size);

    // 綁定一個(gè)uint8大小的超小數(shù)據(jù)塊，節(jié)省存儲(chǔ)空間，sql中對(duì)應(yīng)：tinyblob
    tb_database_sql_value_set_blob8(&list[2], data, size);

    // 綁定一個(gè)uint32大小的超大數(shù)據(jù)塊，sql中對(duì)應(yīng)：longblob
    tb_database_sql_value_set_blob32(&list[3], data, size, tb_null);

    // 綁定一個(gè)uint32大小的超大數(shù)據(jù)流，這樣比較節(jié)省內(nèi)存，不會(huì)一次性加載數(shù)據(jù)到內(nèi)存中來(lái)處理，sql中對(duì)應(yīng)：longblob
    tb_database_sql_value_set_blob32(&list[4], tb_null, 0, stream);

    // 綁定一個(gè)int32整數(shù)，sql中對(duì)應(yīng)int
    tb_database_sql_value_set_int32(&list[5], number);

    // 綁定一個(gè)int16整數(shù)，sql中對(duì)應(yīng)smallint
    tb_database_sql_value_set_int16(&list[6], snumber);
    
    // 綁定參數(shù)列表
    if (!tb_database_sql_statement_bind(database, stmt, list, tb_arrayn(list)))
    {
        // trace
        tb_trace_e("stmt: bind %s failed, error: %s", sql, tb_state_cstr(tb_database_sql_state(database)));
        break ;
    }
    
    // 執(zhí)行預(yù)編譯的sql語(yǔ)句
    if (!tb_database_sql_statement_done(database, stmt))
    {
        // trace
        tb_trace_e("stmt: done %s failed, error: %s", sql, tb_state_cstr(tb_database_sql_state(database)));
        break ;
    }
    
} while (0);

// 刪除sql語(yǔ)句對(duì)象
if (stmt) tb_database_sql_statement_exit(database, stmt);

// 退出數(shù)據(jù)流
if (stream) tb_stream_exit(stream);

對(duì)于獲取對(duì)應(yīng)結(jié)果集數(shù)據(jù)，使用的接口和第一個(gè)例子一樣，可以直接進(jìn)行迭代
也可以通過(guò)索引直接訪問(wèn)其中某列的數(shù)據(jù)：

// 按回滾方式加載結(jié)果集
tb_iterator_ref_t result = tb_database_sql_result_load(database, tb_false);
if (result)
{
    // 遍歷行
    tb_for_all_if (tb_iterator_ref_t, row, result, row)
    {
        // 獲取text數(shù)據(jù)
        tb_database_sql_value_t const* name = tb_iterator_item(row, 0);
        tb_assert_and_check_break(name);
        tb_tracet_i("[%s:%s] ", tb_database_sql_value_name(name), tb_database_sql_value_text(name));
        
        // 獲取blob16數(shù)據(jù)
        tb_database_sql_value_t const* data = tb_iterator_item(row, 1);
        tb_assert_and_check_break(data);
        tb_tracet_i("[%s:%s] ", tb_database_sql_value_name(data), tb_database_sql_value_blob(data));
        
        // 獲取blob32數(shù)據(jù)
        tb_database_sql_value_t const* ldata = tb_iterator_item(row, 4);
        tb_assert_and_check_break(ldata);
        {
            /* 優(yōu)先嘗試獲取數(shù)據(jù)buffer，如果存在的話
             *
             * 針對(duì)小塊數(shù)據(jù)進(jìn)行了優(yōu)化，就算是blob32的數(shù)據(jù)，如果數(shù)據(jù)大小
             * 本身不大，會(huì)直接存到內(nèi)存buffer中去，來(lái)快速讀取
             */
            tb_stream_ref_t     stream = tb_null;
            if (tb_database_sql_value_blob(ldata))
            {
                // 獲取數(shù)據(jù)和大小
                tb_byte_t const*    data = tb_database_sql_value_blob(ldata);
                tb_size             size = tb_database_sql_value_size(ldata);
                // ...

            }
            // 如果獲取不到數(shù)據(jù)buffer，說(shuō)明數(shù)據(jù)量很大，嘗試獲取數(shù)據(jù)流來(lái)處理
            else if ((stream = tb_database_sql_value_blob_stream(ldata)))
            {
                // 進(jìn)行stream的數(shù)據(jù)讀取，注：這個(gè)流不支持寫(xiě)操作，只能用來(lái)讀
                // ...

            }
        }
        
        // 獲取int32數(shù)據(jù)，如果是int8, int16 或者float類型的數(shù)據(jù)，會(huì)自動(dòng)進(jìn)行強(qiáng)轉(zhuǎn)
        tb_database_sql_value_t const* number = tb_iterator_item(row, 5);
        tb_assert_and_check_break(number);
        tb_tracet_i("[%s:%d] ", tb_database_sql_value_name(number), tb_database_sql_value_int32(number));
        
    }
    
    // 退出結(jié)果集
    tb_database_sql_result_exit(database, result);
}

TBOX項(xiàng)目詳情

TBOX項(xiàng)目源碼

TBOX項(xiàng)目文檔

原文出處：http://tboox.org/cn/2016/09/18/database-usage/