SQLITE3使用總結


   SQL語句操作

介紹如何用sqlite 執行標准 sql 語法。

 

i.1            執行sql語句

int sqlite3_exec(sqlite3*, const char *sql, sqlite3_callback, void *,  char **errmsg );

這就是執行一條 sql 語句的函數。

1個參數不再說了,是前面open函數得到的指針。說了是關鍵數據結構。

2個參數const char *sql 是一條 sql 語句,以\0結尾。

3個參數sqlite3_callback 是回調,當這條語句執行之后,sqlite3會去調用你提供的這個函數。(什么是回調函數,自己找別的資料學習)

4個參數void * 是你所提供的指針,你可以傳遞任何一個指針參數到這里,這個參數最終會傳到回調函數里面,如果不需要傳遞指針給回調函數,可以填NULL。等下我們再看回調函數的寫法,以及這個參數的使用。

5個參數char ** errmsg 是錯誤信息。注意是指針的指針。sqlite3里面有很多固定的錯誤信息。執行 sqlite3_exec 之后,執行失敗時可以查閱這個指針(直接 printf(“%s\n”,errmsg))得到一串字符串信息,這串信息告訴你錯在什么地方。sqlite3_exec函數通過修改你傳入的指針的指針,把你提供的指針指向錯誤提示信息,這樣sqlite3_exec函數外面就可以通過這個 char*得到具體錯誤提示。

說明:通常,sqlite3_callback 和它后面的 void * 這兩個位置都可以填 NULL。填NULL表示你不需要回調。比如你做 insert 操作,做 delete 操作,就沒有必要使用回調。而當你做 select 時,就要使用回調,因為 sqlite3 把數據查出來,得通過回調告訴你查出了什么數據。

 

i.2            exec 的回調

typedef int (*sqlite3_callback)(void*,int,char**, char**);

你的回調函數必須定義成上面這個函數的類型。下面給個簡單的例子:

//sqlite3的回調函數        

// sqlite 每查到一條記錄,就調用一次這個回調

     int LoadMyInfo( void * para, int n_column, char ** column_value, char ** column_name )

{

          //para是你在 sqlite3_exec 里傳入的 void * 參數

          //通過para參數,你可以傳入一些特殊的指針(比如類指針、結構指針),然后在這里面強制轉換成對應的類型(這里面是void*類型,必須強制轉換成你的類型才可用)。然后操作這些數據

          //n_column是這一條記錄有多少個字段 (即這條記錄有多少列)

          // char ** column_value 是個關鍵值,查出來的數據都保存在這里,它實際上是個1維數組(不要以為是2維數組),每一個元素都是一個 char * 值,是一個字段內容(用字符串來表示,以\0結尾)

          //char ** column_name  column_value是對應的,表示這個字段的字段名稱

         

          //這里,我不使用 para 參數。忽略它的存在.

 

          int i;

printf( 記錄包含 %d 個字段\n, n_column );

for( i = 0 ; i < n_column; i ++ )

{

     printf( 字段名:%s  ß字段值:%s\n,  column_name[i], column_value[i] );

}

printf( ------------------\n );        

return 0;

}

 

int main( int , char ** )

{

          sqlite3 * db;

          int result;

          char * errmsg = NULL;

 

          result = sqlite3_open( c:\\Dcg_database.db, &db );

    if( result != SQLITE_OK )

    {

     //數據庫打開失敗

return -1;

}

//數據庫操作代碼

//創建一個測試表,表名叫 MyTable_1,有2個字段: ID  name。其中ID是一個自動增加的類型,以后insert時可以不去指定這個字段,它會自己從0開始增加

result = sqlite3_exec( db, create table MyTable_1( ID integer primary key autoincrement, name nvarchar(32) ), NULL, NULL, errmsg );

if(result != SQLITE_OK )

{

     printf( 創建表失敗,錯誤碼:%d,錯誤原因:%s\n, result, errmsg );

}

//插入一些記錄

result = sqlite3_exec( db, insert into MyTable_1( name ) values ( 走路 ), 0, 0, errmsg );

if(result != SQLITE_OK )

{

     printf( 插入記錄失敗,錯誤碼:%d,錯誤原因:%s\n, result, errmsg );

}

result = sqlite3_exec( db, insert into MyTable_1( name ) values ( 騎單車 ), 0, 0, errmsg );

if(result != SQLITE_OK )

{

     printf( 插入記錄失敗,錯誤碼:%d,錯誤原因:%s\n, result, errmsg );

}

result = sqlite3_exec( db, insert into MyTable_1( name ) values ( 坐汽車 ), 0, 0, errmsg );

if(result != SQLITE_OK )

{

     printf( 插入記錄失敗,錯誤碼:%d,錯誤原因:%s\n, result, errmsg );

}

 

 

//開始查詢數據庫

result = sqlite3_exec( db, select * from MyTable_1, LoadMyInfo, NULL, errmsg );

 

//關閉數據庫

sqlite3_close( db );

return 0;

}

 

通過上面的例子,應該可以知道如何打開一個數據庫,如何做數據庫基本操作。

有這些知識,基本上可以應付很多數據庫操作了。

 

i.3            不使用回調查詢數據庫

上面介紹的 sqlite3_exec 是使用回調來執行 select 操作。還有一個方法可以直接查詢而不需要回調。但是,我個人感覺還是回調好,因為代碼可以更加整齊,只不過用回調很麻煩,你得聲明一個函數,如果這個函數是類成員函數,你還不得不把它聲明成 static 的(要問為什么?這又是C++基礎了。C++成員函數實際上隱藏了一個參數:this,C++調用類的成員函數的時候,隱含把類指針當成函數的第一個參數傳遞進去。結果,這造成跟前面說的 sqlite 回調函數的參數不相符。只有當把成員函數聲明成 static 時,它才沒有多余的隱含的this參數)。

雖然回調顯得代碼整齊,但有時候你還是想要非回調的 select 查詢。這可以通過 sqlite3_get_table 函數做到。

int sqlite3_get_table(sqlite3*, const char *sql, char ***resultp, int *nrow, int *ncolumn, char **errmsg );

第1個參數不再多說,看前面的例子。

第2個參數是 sql 語句,跟 sqlite3_exec 里的 sql 是一樣的。是一個很普通的以\0結尾的char *字符串。

第3個參數是查詢結果,它依然一維數組(不要以為是二維數組,更不要以為是三維數組)。它內存布局是:第一行是字段名稱,后面是緊接着是每個字段的值。下面用例子來說事。

第4個參數是查詢出多少條記錄(即查出多少行)。..
 

第5個參數是多少個字段(多少列)。

第6個參數是錯誤信息,跟前面一樣,這里不多說了。

下面給個簡單例子:

int main( int , char ** )

{

          sqlite3 * db;

          int result;

          char * errmsg = NULL;

char **dbResult; // char ** 類型,兩個*

          int nRow, nColumn;

          int i , j;

          int index;

 

          result = sqlite3_open( c:\\Dcg_database.db, &db );

    if( result != SQLITE_OK )

    {

     //數據庫打開失敗

return -1;

}

//數據庫操作代碼

//假設前面已經創建了 MyTable_1 

//開始查詢,傳入的 dbResult 已經是 char **,這里又加了一個 & 取地址符,傳遞進去的就成了 char ***

result = sqlite3_get_table( db, select * from MyTable_1, &dbResult, &nRow, &nColumn, &errmsg );

if( SQLITE_OK == result )

{

     //查詢成功

 

    index = nColumn; //前面說過 dbResult 前面第一行數據是字段名稱,從 nColumn 索引開始才是真正的數據

     printf( 查到%d條記錄\n, nRow );

     for(  i = 0; i < nRow ; i++ )

     {

         printf(  %d 條記錄\n, i+1 );

         for( j = 0 ; j < nColumn; j++ )

         {

              printf( 字段名:%s  ß字段值:%s\n,  dbResult[j], dbResult [index] );

              ++index; // dbResult 的字段值是連續的,從第0索引到第 nColumn - 1索引都是字段名稱,從第 nColumn 索引開始,后面都是字段值,它把一個二維的表(傳統的行列表示法)用一個扁平的形式來表示

         }

         printf( -------\n );

     }

}

 

//到這里,不論數據庫查詢是否成功,都釋放 char** 查詢結果,使用 sqlite 提供的功能來釋放

sqlite3_free_table( dbResult );

 

//關閉數據庫

sqlite3_close( db );

return 0;

}

 

到這個例子為止,sqlite3 的常用用法都介紹完了。

用以上的方法,再配上 sql 語句,完全可以應付絕大多數數據庫需求。

但有一種情況,用上面方法是無法實現的:需要insert、select 二進制。當需要處理二進制數據時,上面的方法就沒辦法做到。下面這一節說明如何插入二進制數據

(2)              操作二進制

sqlite 操作二進制數據需要用一個輔助的數據類型:sqlite3_stmt * 

這個數據類型記錄了一個“sql語句”。為什么我把 “sql語句” 用雙引號引起來?因為你可以把 sqlite3_stmt * 所表示的內容看成是 sql語句,但是實際上它不是我們所熟知的sql語句。它是一個已經把sql語句解析了的、用sqlite自己標記記錄的內部數據結構。

正因為這個結構已經被解析了,所以你可以往這個語句里插入二進制數據。當然,把二進制數據插到 sqlite3_stmt 結構里可不能直接 memcpy ,也不能像 std::string 那樣用 + 號。必須用 sqlite 提供的函數來插入。

 

i.1          寫入二進制

下面說寫二進制的步驟。

要插入二進制,前提是這個表的字段的類型是 blob 類型。我假設有這么一張表:

create table Tbl_2( ID integer, file_content  blob )

首先聲明

sqlite3_stmt * stat;

然后,把一個 sql 語句解析到 stat 結構里去:

sqlite3_prepare( db, insert into Tbl_2( ID, file_content) values( 10, ? ), -1, &stat, 0 );

上面的函數完成 sql 語句的解析。第一個參數跟前面一樣,是個 sqlite3 * 類型變量,第二個參數是一個 sql 語句。

這個 sql 語句特別之處在於 values 里面有個 ? 號。在sqlite3_prepare函數里,?號表示一個未定的值,它的值等下才插入。

第三個參數我寫的是-1,這個參數含義是前面 sql 語句的長度。如果小於0,sqlite會自動計算它的長度(把sql語句當成以\0結尾的字符串)。

第四個參數是 sqlite3_stmt 的指針的指針。解析以后的sql語句就放在這個結構里。

第五個參數我也不知道是干什么的。為0就可以了。

如果這個函數執行成功(返回值是 SQLITE_OK 且 stat 不為NULL ),那么下面就可以開始插入二進制數據。

sqlite3_bind_blob( stat, 1, pdata, (int)(length_of_data_in_bytes), NULL ); // pdata為數據緩沖區,length_of_data_in_bytes為數據大小,以字節為單位

這個函數一共有5個參數。

第1個參數:是前面prepare得到的 sqlite3_stmt * 類型變量。

第2個參數:?號的索引。前面prepare的sql語句里有一個?號,假如有多個?號怎么插入?方法就是改變 bind_blob 函數第2個參數。這個參數我寫1,表示這里插入的值要替換 stat 的第一個?號(這里的索引從1開始計數,而非從0開始)。如果你有多個?號,就寫多個 bind_blob 語句,並改變它們的第2個參數就替換到不同的?號。如果有?號沒有替換,sqlite為它取值null。

第3個參數:二進制數據起始指針。

第4個參數:二進制數據的長度,以字節為單位。

第5個參數:是個析夠回調函數,告訴sqlite當把數據處理完后調用此函數來析夠你的數據。這個參數我還沒有使用過,因此理解也不深刻。但是一般都填NULL,需要釋放的內存自己用代碼來釋放。

bind完了之后,二進制數據就進入了你的“sql語句”里了。你現在可以把它保存到數據庫里:

int result = sqlite3_step( stat );

通過這個語句,stat 表示的sql語句就被寫到了數據庫里。

最后,要把 sqlite3_stmt 結構給釋放:

sqlite3_finalize( stat ); //把剛才分配的內容析構掉

 

i.2          讀出二進制

下面說讀二進制的步驟。

跟前面一樣,先聲明 sqlite3_stmt * 類型變量:

sqlite3_stmt * stat;

然后,把一個 sql 語句解析到 stat 結構里去:

sqlite3_prepare( db, select * from Tbl_2, -1, &stat, 0 );

當 prepare 成功之后(返回值是 SQLITE_OK ),開始查詢數據。

int result = sqlite3_step( stat );

這一句的返回值是 SQLITE_ROW 時表示成功(不是 SQLITE_OK )。

你可以循環執行 sqlite3_step 函數,一次 step 查詢出一條記錄。直到返回值不為 SQLITE_ROW 時表示查詢結束。

然后開始獲取第一個字段:ID 的值。ID是個整數,用下面這個語句獲取它的值:

int id = sqlite3_column_int( stat, 0 ); //2個參數表示獲取第幾個字段內容,從0開始計算,因為我的表的ID字段是第一個字段,因此這里我填0

 

下面開始獲取 file_content 的值,因為 file_content 是二進制,因此我需要得到它的指針,還有它的長度:

         const void * pFileContent = sqlite3_column_blob( stat, 1 );

         int len = sqlite3_column_bytes( stat, 1 );

這樣就得到了二進制的值。

把 pFileContent 的內容保存出來之后,不要忘了釋放 sqlite3_stmt 結構:

sqlite3_finalize( stat ); //把剛才分配的內容析構掉

 

i.3          重復使用 sqlite3_stmt 結構

如果你需要重復使用 sqlite3_prepare 解析好的 sqlite3_stmt 結構,需要用函數: sqlite3_reset

result = sqlite3_reset(stat);

這樣, stat 結構又成為 sqlite3_prepare 完成時的狀態,你可以重新為它 bind 內容。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM