SQLite學習手冊(實例代碼<二>)

3、高效的批量數據插入：

    在給出操做步驟以前先簡單說明一下批量插入的概念，以幫助你們閱讀其後的示例代碼。事實上，批量插入並非什麼新的概念，在其它關係型數據庫的C接口API中都提供了必定的支持，只是接口的實現方式不一樣而已。縱觀衆多流行的數據庫接口，如OCI(Oracle API)、MySQL API和PostgreSQL API等，OCI提供的編程接口最爲方便，實現方式也最爲高效。SQLite做爲一種簡單靈活的嵌入式數據庫也一樣提供了該功能，可是實現方式並不像其餘數據庫那樣方便明顯，它只是經過一種隱含的技巧來達到批量插入的目的，其邏輯以下：
    1). 開始一個事物，以保證後面的數據操做語句均在該事物內完成。在SQLite中，若是沒有手工開啓一個事物，其全部的DML語句都是在自動提交模式下工做的，既每次操做後數據均被自動提交併寫入磁盤文件。然而在非自動提交模式下，只有當其所在的事物被手工COMMIT以後纔會將修改的數據寫入到磁盤中，以前修改的數據都是僅僅駐留在內存中。顯而易見，這樣的批量寫入方式在效率上勢必會遠遠優於多迭代式的單次寫入操做。
    2). 基於變量綁定的方式準備待插入的數據，這樣能夠節省大量的sqlite3_prepare_v2函數調用次數，從而節省了屢次將同一SQL語句編譯成SQLite內部識別的字節碼所用的時間。事實上，SQLite的官方文檔中已經明確指出，在不少時候sqlite3_prepare_v2函數的執行時間要多於sqlite3_step函數的執行時間，所以建議使用者要儘可能避免重複調用sqlite3_prepare_v2函數。在咱們的實現中，若是想避免此類開銷，只需將待插入的數據以變量的形式綁定到SQL語句中，這樣該SQL語句僅需調用sqlite3_prepare_v2函數編譯一次便可，其後的操做只是替換不一樣的變量數值。
    3). 在完成全部的數據插入後顯式的提交事物。提交後，SQLite會將當前鏈接自動恢復爲自動提交模式。
    
    下面是示例代碼的實現步驟：
    1). 建立測試數據表。
    2). 經過執行BEGIN TRANSACTION語句手工開啓一個事物。
    3). 準備插入語句及相關的綁定變量。
    4). 迭代式插入數據。
    5). 完成後經過執行COMMIT語句提交事物。
    6). 刪除測試表。
    見如下代碼及關鍵性註釋：

 1 #include <sqlite3.h>  2 #include <string>  3 #include <stdio.h>  4  5 using namespace std;  6  7 void doTest()  8 {  9 sqlite3* conn = NULL;  10 //1. 打開數據庫  11 int result = sqlite3_open("D:/mytest.db",&conn);  12 if (result != SQLITE_OK) {  13 sqlite3_close(conn);  14 return;  15 }  16 const char* createTableSQL =  17 "CREATE TABLE TESTTABLE (int_col INT, float_col REAL, string_col TEXT)";  18 sqlite3_stmt* stmt = NULL;  19 int len = strlen(createTableSQL);  20 //2. 準備建立數據表，若是建立失敗，須要用sqlite3_finalize釋放sqlite3_stmt對象，以防止內存泄露。  21 if (sqlite3_prepare_v2(conn,createTableSQL,len,&stmt,NULL) != SQLITE_OK) {  22 if (stmt)  23 sqlite3_finalize(stmt);  24 sqlite3_close(conn);  25 return;  26 }  27 //3. 經過sqlite3_step命令執行建立表的語句。對於DDL和DML語句而言，sqlite3_step執行正確的返回值  28 //只有SQLITE_DONE，對於SELECT查詢而言，若是有數據返回SQLITE_ROW，當到達結果集末尾時則返回  29  //SQLITE_DONE。  30 if (sqlite3_step(stmt) != SQLITE_DONE) {  31 sqlite3_finalize(stmt);  32 sqlite3_close(conn);  33 return;  34 }  35 //4. 釋放建立表語句對象的資源。  36 sqlite3_finalize(stmt);  37 printf("Succeed to create test table now.\n");  38  39 //5. 顯式的開啓一個事物。  40 sqlite3_stmt* stmt2 = NULL;  41 const char* beginSQL = "BEGIN TRANSACTION";  42 if (sqlite3_prepare_v2(conn,beginSQL,strlen(beginSQL),&stmt2,NULL) != SQLITE_OK) {  43 if (stmt2)  44 sqlite3_finalize(stmt2);  45 sqlite3_close(conn);  46 return;  47 }  48 if (sqlite3_step(stmt2) != SQLITE_DONE) {  49 sqlite3_finalize(stmt2);  50 sqlite3_close(conn);  51 return;  52 }  53 sqlite3_finalize(stmt2);  54  55 //6. 構建基於綁定變量的插入數據。  56 const char* insertSQL = "INSERT INTO TESTTABLE VALUES(?,?,?)";  57 sqlite3_stmt* stmt3 = NULL;  58 if (sqlite3_prepare_v2(conn,insertSQL,strlen(insertSQL),&stmt3,NULL) != SQLITE_OK) {  59 if (stmt3)  60 sqlite3_finalize(stmt3);  61 sqlite3_close(conn);  62 return;  63 }  64 int insertCount = 10;  65 const char* strData = "This is a test.";  66 //7. 基於已有的SQL語句，迭代的綁定不一樣的變量數據  67 for (int i = 0; i < insertCount; ++i) {  68 //在綁定時，最左面的變量索引值是1。  69 sqlite3_bind_int(stmt3,1,i);  70 sqlite3_bind_double(stmt3,2,i * 1.0);  71 sqlite3_bind_text(stmt3,3,strData,strlen(strData),SQLITE_TRANSIENT);  72 if (sqlite3_step(stmt3) != SQLITE_DONE) {  73 sqlite3_finalize(stmt3);  74 sqlite3_close(conn);  75 return;  76 }  77 //從新初始化該sqlite3_stmt對象綁定的變量。  78 sqlite3_reset(stmt3);  79 printf("Insert Succeed.\n");  80 }  81 sqlite3_finalize(stmt3);  82  83 //8. 提交以前的事物。  84 const char* commitSQL = "COMMIT";  85 sqlite3_stmt* stmt4 = NULL;  86 if (sqlite3_prepare_v2(conn,commitSQL,strlen(commitSQL),&stmt4,NULL) != SQLITE_OK) {  87 if (stmt4)  88 sqlite3_finalize(stmt4);  89 sqlite3_close(conn);  90 return;  91 }  92 if (sqlite3_step(stmt4) != SQLITE_DONE) {  93 sqlite3_finalize(stmt4);  94 sqlite3_close(conn);  95 return;  96 }  97 sqlite3_finalize(stmt4);  98  99 //9. 爲了方便下一次測試運行，咱們這裏須要刪除該函數建立的數據表，不然在下次運行時將沒法 100 //建立該表，由於它已經存在。 101 const char* dropSQL = "DROP TABLE TESTTABLE"; 102 sqlite3_stmt* stmt5 = NULL; 103 if (sqlite3_prepare_v2(conn,dropSQL,strlen(dropSQL),&stmt5,NULL) != SQLITE_OK) { 104 if (stmt5) 105 sqlite3_finalize(stmt5); 106 sqlite3_close(conn); 107 return; 108 } 109 if (sqlite3_step(stmt5) == SQLITE_DONE) { 110 printf("The test table has been dropped.\n"); 111 } 112 sqlite3_finalize(stmt5); 113 sqlite3_close(conn); 114 } 115 116 int main() 117 { 118 doTest(); 119 return 0; 120 } 121 //輸出結果以下： 122 //Succeed to create test table now. 123 //Insert Succeed. 124 //Insert Succeed. 125 //Insert Succeed. 126 //Insert Succeed. 127 //Insert Succeed. 128 //Insert Succeed. 129 //Insert Succeed. 130 //Insert Succeed. 131 //Insert Succeed. 132 //Insert Succeed. 133 //The test table has been dropped.

    該結果和上一個例子(普通數據插入)的結果徹底相同，只是在執行效率上明顯優於前者。

4、數據查詢：

    數據查詢是每一個關係型數據庫都會提供的最基本功能，下面的代碼示例將給出如何經過SQLite API獲取數據。
    1). 建立測試數據表。
    2). 插入一條測試數據到該數據表以便於後面的查詢。
    3). 執行SELECT語句檢索數據。
    4). 刪除測試表。
    見如下示例代碼和關鍵性註釋：

 1 #include <sqlite3.h>  2 #include <string>  3 #include <stdio.h>  4  5 using namespace std;  6  7 void doTest()  8 {  9 sqlite3* conn = NULL;  10 //1. 打開數據庫  11 int result = sqlite3_open("D:/mytest.db",&conn);  12 if (result != SQLITE_OK) {  13 sqlite3_close(conn);  14 return;  15 }  16 const char* createTableSQL =  17 "CREATE TABLE TESTTABLE (int_col INT, float_col REAL, string_col TEXT)";  18 sqlite3_stmt* stmt = NULL;  19 int len = strlen(createTableSQL);  20 //2. 準備建立數據表，若是建立失敗，須要用sqlite3_finalize釋放sqlite3_stmt對象，以防止內存泄露。  21 if (sqlite3_prepare_v2(conn,createTableSQL,len,&stmt,NULL) != SQLITE_OK) {  22 if (stmt)  23 sqlite3_finalize(stmt);  24 sqlite3_close(conn);  25 return;  26 }  27 //3. 經過sqlite3_step命令執行建立表的語句。對於DDL和DML語句而言，sqlite3_step執行正確的返回值  28  //只有SQLITE_DONE，對於SELECT查詢而言，若是有數據返回SQLITE_ROW，當到達結果集末尾時則返回  29 //SQLITE_DONE。  30 if (sqlite3_step(stmt) != SQLITE_DONE) {  31 sqlite3_finalize(stmt);  32 sqlite3_close(conn);  33 return;  34 }  35 //4. 釋放建立表語句對象的資源。  36 sqlite3_finalize(stmt);  37 printf("Succeed to create test table now.\n");  38  39 //5. 爲後面的查詢操做插入測試數據。  40 sqlite3_stmt* stmt2 = NULL;  41 const char* insertSQL = "INSERT INTO TESTTABLE VALUES(20,21.0,'this is a test.')";  42 if (sqlite3_prepare_v2(conn,insertSQL,strlen(insertSQL),&stmt2,NULL) != SQLITE_OK) {  43 if (stmt2)  44 sqlite3_finalize(stmt2);  45 sqlite3_close(conn);  46 return;  47 }  48 if (sqlite3_step(stmt2) != SQLITE_DONE) {  49 sqlite3_finalize(stmt2);  50 sqlite3_close(conn);  51 return;  52 }  53 printf("Succeed to insert test data.\n");  54 sqlite3_finalize(stmt2);  55  56 //6. 執行SELECT語句查詢數據。  57 const char* selectSQL = "SELECT * FROM TESTTABLE";  58 sqlite3_stmt* stmt3 = NULL;  59 if (sqlite3_prepare_v2(conn,selectSQL,strlen(selectSQL),&stmt3,NULL) != SQLITE_OK) {  60 if (stmt3)  61 sqlite3_finalize(stmt3);  62 sqlite3_close(conn);  63 return;  64 }  65 int fieldCount = sqlite3_column_count(stmt3);  66 do {  67 int r = sqlite3_step(stmt3);  68 if (r == SQLITE_ROW) {  69 for (int i = 0; i < fieldCount; ++i) {  70 //這裏須要先判斷當前記錄當前字段的類型，再根據返回的類型使用不一樣的API函數  71 //獲取實際的數據值。  72 int vtype = sqlite3_column_type(stmt3,i);  73 if (vtype == SQLITE_INTEGER) {  74 int v = sqlite3_column_int(stmt3,i);  75 printf("The INTEGER value is %d.\n",v);  76 } else if (vtype == SQLITE_FLOAT) {  77 double v = sqlite3_column_double(stmt3,i);  78 printf("The DOUBLE value is %f.\n",v);  79 } else if (vtype == SQLITE_TEXT) {  80 const char* v = (const char*)sqlite3_column_text(stmt3,i);  81 printf("The TEXT value is %s.\n",v);  82 } else if (vtype == SQLITE_NULL) {  83 printf("This value is NULL.\n");  84 }  85 }  86 } else if (r == SQLITE_DONE) {  87 printf("Select Finished.\n");  88 break;  89 } else {  90 printf("Failed to SELECT.\n");  91 sqlite3_finalize(stmt3);  92 sqlite3_close(conn);  93 return;  94 }  95 } while (true);  96 sqlite3_finalize(stmt3);  97  98 //7. 爲了方便下一次測試運行，咱們這裏須要刪除該函數建立的數據表，不然在下次運行時將沒法  99  //建立該表，由於它已經存在。 100 const char* dropSQL = "DROP TABLE TESTTABLE"; 101 sqlite3_stmt* stmt4 = NULL; 102 if (sqlite3_prepare_v2(conn,dropSQL,strlen(dropSQL),&stmt4,NULL) != SQLITE_OK) { 103 if (stmt4) 104 sqlite3_finalize(stmt4); 105 sqlite3_close(conn); 106 return; 107 } 108 if (sqlite3_step(stmt4) == SQLITE_DONE) { 109 printf("The test table has been dropped.\n"); 110 } 111 sqlite3_finalize(stmt4); 112 sqlite3_close(conn); 113 } 114 115 int main() 116 { 117 doTest(); 118 return 0; 119 } 120 //輸出結果以下： 121 //Succeed to create test table now. 122 //Succeed to insert test data. 123 //The INTEGER value is 20. 124 //The DOUBLE value is 21.000000. 125 //The TEXT value is this is a test.. 126 //Select Finished. 127 //The test table has been dropped.