C/C++語言中調用 sqlite 的函數接口來實現對數據庫的管理(創建數據庫、創建表格、插入數據、查詢、數據、刪除數據等)。
首先要編譯好
sqlite的庫文件 :
libsqlite3.a libsqlite3.la libsqlite3.so libsqlite3.so.0 libsqlite3.so.0.8.6 pkgconfig
可執行文件 :
sqlite3
本次測試:
sqlite3的庫文件目錄是:/usr/local/lib
可執行文件 sqlite3 的目錄是: /usr/local/bin
頭文件 sqlite3.h 的目錄是: /usr/local/include
用ls命令查看如下:
[root@localhost config]# ls /usr/local/lib
libclamav.a libclamunrar_iface.a libclamunrar.so libsqlite3.so
libclamav.la libclamunrar_iface.la libclamunrar.so.5 libsqlite3.so.0
libclamav.so libclamunrar_iface.so libclamunrar.so.5.0.3 libsqlite3.so.0.8.6
libclamav.so.5 libclamunrar_iface.so.5 libmstring.so pkgconfig
libclamav.so.5.0.3 libclamunrar_iface.so.5.0.3 libsqlite3.a
libclamunrar.a libclamunrar.la libsqlite3.la
此目錄下包含庫文件:
libsqlite3.a libsqlite3.la libsqlite3.so libsqlite3.so.0 libsqlite3.so.0.8.6 pkgconfig
開始sqlite編程:
1. 下面是一個C程序的例子,顯示怎么使用 sqlite 的 C/C++ 接口. 數據庫的名字由第一個參數取得且第個參數或更多的參數是 SQL 執行語句.
這個函數調用sqlite3_open() 打開數據庫,並且調用sqlite3_close() 關閉數據庫連接。
程序一:opendbslite.c:
1. #include <stdio.h> 2. #include <stdlib.h> 3. #include <sqlite3.h> 4. int main( void ) 5. { 6. sqlite3 *db=NULL; 7. char *zErrMsg = 0; 8. int rc; 9. 10. //打開指定的數據庫文件,如果不存在將創建一個同名的數據庫文件 11. rc = sqlite3_open("zieckey.db", &db); 12. if( rc ) 13. { 14. fprintf(stderr, "Can't open database: %s/n", sqlite3_errmsg(db)); 15. sqlite3_close(db); 16. exit(1); 17. } 18. else printf("You have opened a sqlite3 database named zieckey.db successfully!/nCongratulations! Have fun ! ^-^ /n"); 19. 20. sqlite3_close(db); //關閉數據庫 21. return 0; 22. }
編譯(問題):
[root@localhost liuxltest]# gcc -o opendbsqlite opendbsqlite.c
/tmp/ccuquUQN.o: In function `main':
opendbsqlite.c:(.text+0x2e): undefined reference to `sqlite3_open'
opendbsqlite.c:(.text+0x42): undefined reference to `sqlite3_errmsg'
opendbsqlite.c:(.text+0x67): undefined reference to `sqlite3_close'
opendbsqlite.c:(.text+0x8a): undefined reference to `sqlite3_close'
collect2: ld returned 1 exit status
編譯(解決):
出現上述問題是因為沒有找到庫文件的問題。
由於用到了用戶自己的庫文件,所用應該指明所用到的庫,我們可以這樣編譯:
[root@localhost liuxltest]# gcc -o opendbsqlite opendbsqlite.c -lsqlite3
用 -lsqlite3 選項就可以了(前面我們生成的庫文件是 libsqlite3.so.0.8.6 等,去掉前面的lib和后面的版本標志,就剩下 sqlite3 了所以是 -lsqlite3 )
執行:
[root@localhost liuxltest]# ./opendbsqlite
You have opened a sqlite3 database named zieckey.db successfully!
Congratulations! Have fun ! ^-^
[root@localhost liuxltest]#
2. 插入 :insert
在C語言中向數據庫插入數據:
sqlite3_exec的函數原型說明如下:
int sqlite3_exec(
sqlite3*, /* An open database */
const char *sql, /* SQL to be executed */
sqlite_callback, /* Callback function */
void *, /* 1st argument to callback function */
char **errmsg /* Error msg written here */
);
程序二:insert.c:
1. #include <stdio.h> 2. #include <stdlib.h> 3. #include "sqlite3.h" 4. #define _DEBUG_ 5. int main( void ) 6. { 7. sqlite3 *db=NULL; 8. char *zErrMsg = 0; 9. int rc; 10. rc = sqlite3_open("zieckey.db", &db); //打開指定的數據庫文件,如果不存在將創建一個同名的數據庫文件 11. if( rc ) 12. { 13. fprintf(stderr, "Can't open database: %s/n", sqlite3_errmsg(db)); 14. sqlite3_close(db); 15. exit(1); 16. } 17. else printf("You have opened a sqlite3 database named zieckey.db successfully!/nCongratulations! Have fun ! ^-^ /n"); 18. //創建一個表,如果該表存在,則不創建,並給出提示信息,存儲在 zErrMsg 中 19. char *sql = " CREATE TABLE SensorData( / 20. ID INTEGER PRIMARY KEY, / 21. SensorID INTEGER, / 22. SiteNum INTEGER, / 23. Time VARCHAR(12), / 24. SensorParameter REAL / 25. );" ; 26. sqlite3_exec( db , sql , 0 , 0 , &zErrMsg ); 27. #ifdef _DEBUG_ 28. printf("%s/n",zErrMsg); 29. #endif 30. //插入數據 31. char* sql1 = "INSERT INTO /"SensorData/" VALUES( NULL , 1 , 1 , '200605011206', 18.9 );" ; 32. sqlite3_exec( db , sql1 , 0 , 0 , &zErrMsg ); 33. char* sql2 = "INSERT INTO /"SensorData/" VALUES( NULL , 1 , 1 , '200605011306', 16.4 );" ; 34. sqlite3_exec( db , sql2 , 0 , 0 , &zErrMsg ); 35. sqlite3_close(db); //關閉數據庫 36. return 0; 37. }
編譯運行:
[root@localhost liuxltest]# gcc -o insert insert.c -lsqlite3
[root@localhost liuxltest]# ./insert
You have opened a sqlite3 database named zieckey.db successfully!
Congratulations! Have fun ! ^-^
(null)
(null)
(null)
[root@localhost liuxltest]#
查看是否插入數據:
[root@localhost liuxltest]# /usr/local/bin/sqlite3 zieckey.db "select * from SensorData"
3. 查詢: SELETE
C語言中查詢數據庫中的數據。
函數接口sqlite3_get_table( db , sql , &azResult , &nrow , &ncolumn , &zErrMsg );
解釋:
int sqlite3_get_table(sqlite3*, const char *sql,char***result , int *nrow , int *ncolumn ,char **errmsg );
result中是以數組的形式存放你所查詢的數據,首先是表名,再是數據。
nrow ,ncolumn分別為查詢語句返回的結果集的行數,列數,沒有查到結果時返回0
程序三:query.c:
1. #include <stdio.h> 2. #include <stdlib.h> 3. #include "sqlite3.h" 4. #define _DEBUG_ 5. int main( void ) 6. { 7. sqlite3 *db=NULL; 8. char *zErrMsg = 0; 9. int rc; 10. 11. rc = sqlite3_open("zieckey.db", &db); //打開指定的數據庫文件,如果不存在將創建一個同名的數據庫文件 12. if( rc ) 13. { 14. fprintf(stderr, "Can't open database: %s/n", sqlite3_errmsg(db)); 15. sqlite3_close(db); 16. exit(1); 17. } 18. else printf("You have opened a sqlite3 database named zieckey.db successfully!/nCongratulations! Have fun ! ^-^ /n"); 19. 20. //創建一個表,如果該表存在,則不創建,並給出提示信息,存儲在 zErrMsg 中 21. char *sql = " CREATE TABLE SensorData( / 22. ID INTEGER PRIMARY KEY, / 23. SensorID INTEGER, / 24. SiteNum INTEGER, / 25. Time VARCHAR(12), / 26. SensorParameter REAL / 27. );" ; 28. sqlite3_exec( db , sql , 0 , 0 , &zErrMsg ); 29. #ifdef _DEBUG_ 30. printf("zErrMsg = %s /n", zErrMsg); 31. #endif 32. 33. //插入數據 34. sql = "INSERT INTO /"SensorData/" VALUES(NULL , 1 , 1 , '200605011206', 18.9 );" ; 35. sqlite3_exec( db , sql , 0 , 0 , &zErrMsg ); 36. 37. sql = "INSERT INTO /"SensorData/" VALUES(NULL , 1 , 1 , '200605011306', 16.4 );" ; 38. sqlite3_exec( db , sql , 0 , 0 , &zErrMsg ); 39. 40. 41. 42. int nrow = 0, ncolumn = 0; 43. char **azResult; //二維數組存放結果 44. //查詢數據 45. /* 46. int sqlite3_get_table(sqlite3*, const char *sql,char***result , int *nrow , int *ncolumn ,char **errmsg ); 47. result中是以數組的形式存放你所查詢的數據,首先是表名,再是數據。 48. nrow ,ncolumn分別為查詢語句返回的結果集的行數,列數,沒有查到結果時返回0 49. */ 50. sql = "SELECT * FROM SensorData "; 51. sqlite3_get_table( db , sql , &azResult , &nrow , &ncolumn , &zErrMsg ); 52. int i = 0 ; 53. printf( "row:%d column=%d /n" , nrow , ncolumn ); 54. printf( "/nThe result of querying is : /n" ); 55. 56. for( i=0 ; i<( nrow + 1 ) * ncolumn ; i++ ) 57. printf( "azResult[%d] = %s/n", i , azResult[i] ); 58. //釋放掉 azResult 的內存空間 59. sqlite3_free_table( azResult ); 60. 61. #ifdef _DEBUG_ 62. printf("zErrMsg = %s /n", zErrMsg); 63. #endif 64. sqlite3_close(db); //關閉數據庫 65. return 0; 66. 67. }
這里用到了一個查詢的語句是 "SELECT * FROM SensorData " ,
編譯運行:
[root@localhost liuxltest]# gcc -o query query.c -lsqlite3
[root@localhost liuxltest]# ./query
You have opened a sqlite3 database named zieckey.db successfully!
Congratulations! Have fun ! ^-^
zErrMsg = (null)
row:2 column=5
The result of querying is :
azResult[0] = ID
azResult[1] = SensorID
azResult[2] = SiteNum
azResult[3] = Time
azResult[4] = SensorParameter
azResult[5] = 1
azResult[6] = 1
azResult[7] = 1
azResult[8] = 200605011206
azResult[9] = 18.9
azResult[10] = 2
azResult[11] = 1
azResult[12] = 1
azResult[13] = 200605011306
azResult[14] = 16.4
zErrMsg = (null)
[root@localhost liuxltest]#
這里我們可以看到,azResult 的前面 5 個數據正好是我們的表 SensorData 的列屬性,之后才是我們要查詢的數據。所以我們的程序中才有 i<( nrow + 1 ) * ncolumn 的判斷條件:
for( i=0 ; i<( nrow + 1 ) * ncolumn ; i++ )
printf( "azResult[%d] = %s/n", i , azResult[i] );
輸出中有 zErrMsg = (null) 這樣的字句,這是 zErrMsg 保留的錯誤信息,正如你所看到的,zErrMsg 為空,表明在執行過程中沒有錯誤信息。
4. 刪除:delete
C語言中刪除數據庫中的特定的數據。
程序四: delete.c:
1. #include <stdio.h> 2. #include <stdlib.h> 3. #include "sqlite3.h" 4. #define _DEBUG_ 5. int main( void ) 6. { 7. sqlite3 *db=NULL; 8. char *zErrMsg = 0; 9. int rc; 10. 11. rc = sqlite3_open("zieckey.db", &db); //打開指定的數據庫文件,如果不存在將創建一個同名的數據庫文件 12. if( rc ) 13. { 14. fprintf(stderr, "Can't open database: %s/n", sqlite3_errmsg(db)); 15. sqlite3_close(db); 16. exit(1); 17. } 18. else printf("You have opened a sqlite3 database named zieckey.db successfully!/nCongratulations! Have fun ! ^-^ /n"); 19. 20. //創建一個表,如果該表存在,則不創建,並給出提示信息,存儲在 zErrMsg 中 21. char *sql = " CREATE TABLE SensorData( / 22. ID INTEGER PRIMARY KEY, / 23. SensorID INTEGER, / 24. SiteNum INTEGER, / 25. Time VARCHAR(12), / 26. SensorParameter REAL / 27. );" ; 28. sqlite3_exec( db , sql , 0 , 0 , &zErrMsg ); 29. #ifdef _DEBUG_ 30. printf("zErrMsg = %s /n", zErrMsg); 31. #endif 32. 33. //插入數據 34. sql = "INSERT INTO /"SensorData/" VALUES(NULL , 1 , 1 , '200605011206', 18.9 );" ; 35. sqlite3_exec( db , sql , 0 , 0 , &zErrMsg ); 36. 37. sql = "INSERT INTO /"SensorData/" VALUES(NULL , 23 , 45 , '200605011306', 16.4 );" ; 38. sqlite3_exec( db , sql , 0 , 0 , &zErrMsg ); 39. 40. sql = "INSERT INTO /"SensorData/" VALUES(NULL , 34 , 45 , '200605011306', 15.4 );" ; 41. sqlite3_exec( db , sql , 0 , 0 , &zErrMsg ); 42. 43. 44. int nrow = 0, ncolumn = 0; 45. char **azResult; //二維數組存放結果 46. //查詢數據 47. sql = "SELECT * FROM SensorData "; 48. sqlite3_get_table( db , sql , &azResult , &nrow , &ncolumn , &zErrMsg ); 49. int i = 0 ; 50. printf( "row:%d column=%d /n" , nrow , ncolumn ); 51. printf( "/nThe result of querying is : /n" ); 52. for( i=0 ; i<( nrow + 1 ) * ncolumn ; i++ ) 53. printf( "azResult[%d] = %s/n", i , azResult[i] ); 54. //刪除數據 55. sql = "DELETE FROM SensorData WHERE SensorID = 1 ;" ; 56. sqlite3_exec( db , sql , 0 , 0 , &zErrMsg ); 57. #ifdef _DEBUG_ 58. printf("zErrMsg = %s /n", zErrMsg); 59. #endif 60. sql = "SELECT * FROM SensorData "; 61. sqlite3_get_table( db , sql , &azResult , &nrow , &ncolumn , &zErrMsg ); 62. printf( "/n/n/n/nrow:%d column=%d " , nrow , ncolumn ); 63. printf( "/nAfter deleting , the result of querying is : /n" ); 64. for( i=0 ; i<( nrow + 1 ) * ncolumn ; i++ ) 65. printf( "azResult[%d] = %s/n", i , azResult[i] ); 66. 67. //釋放掉 azResult 的內存空間 68. sqlite3_free_table( azResult ); 69. 70. #ifdef _DEBUG_ 71. printf("zErrMsg = %s /n", zErrMsg); 72. #endif 73. sqlite3_close(db); //關閉數據庫 74. return 0; 75. 76. }
編譯運行:
[root@localhost liuxltest]# gcc -o delete delete.c -lsqlite3
[root@localhost liuxltest]# ./delete
You have opened a sqlite3 database named zieckey.db successfully!
Congratulations! Have fun ! ^-^
zErrMsg = (null)
row:3 column=5
The result of querying is :
azResult[0] = ID
azResult[1] = SensorID
azResult[2] = SiteNum
azResult[3] = Time
azResult[4] = SensorParameter
azResult[5] = 1
azResult[6] = 1
azResult[7] = 1
azResult[8] = 200605011206
azResult[9] = 18.9
azResult[10] = 2
azResult[11] = 23
azResult[12] = 45
azResult[13] = 200605011306
azResult[14] = 16.4
azResult[15] = 3
azResult[16] = 34
azResult[17] = 45
azResult[18] = 200605011306
azResult[19] = 15.4
zErrMsg = (null)
row:2 column=5
After deleting , the result of querying is :
azResult[0] = ID
azResult[1] = SensorID
azResult[2] = SiteNum
azResult[3] = Time
azResult[4] = SensorParameter
azResult[5] = 2
azResult[6] = 23
azResult[7] = 45
azResult[8] = 200605011306
azResult[9] = 16.4
azResult[10] = 3
azResult[11] = 34
azResult[12] = 45
azResult[13] = 200605011306
azResult[14] = 15.4
zErrMsg = (null)
[root@localhost liuxltest]#
從程序輸出結果就可以看出,在刪除數據前,我們有三條記錄,刪除數據后我們發現,數據庫內記錄少了。從而實現了我們的刪除數據目的。