linux c編程操作數據庫(sqlite3應用)


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]# 
      從程序輸出結果就可以看出,在刪除數據前,我們有三條記錄,刪除數據后我們發現,數據庫內記錄少了。從而實現了我們的刪除數據目的。

 

 
        

 


免責聲明!

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



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