sqlite入門基礎

2019-11-11 05:47:06

字體：大中小

來源：轉載

供稿：網友

打開數據庫鏈接sqlite3_open用法

原型：

int sqlite3_open(  const char *filename,   /* Database filename (UTF-8) */  sqlite3 **ppDb          /* OUT: SQLite db handle */);用這個函數開始數據庫操作。需要傳入兩個參數，一是數據庫文件名，比如：E:/test.db。文件名不需要一定存在，如果此文件不存在，sqlite會自動建立它。如果它存在，就嘗試把它當數據庫文件來打開。二是sqlite3**，即前面提到的關鍵數據結構。這個結構底層細節如何，你不要管它。函數返回值表示操作是否正確，如果是SQLITE_OK則表示操作正常。相關的返回值sqlite定義了一些宏。具體這些宏的含義可以參考sqlite3.h 文件。里面有詳細定義（順便說一下，sqlite3 的代碼注釋率自稱是非常高的，實際上也的確很高。只要你會看英文，sqlite 可以讓你學到不少東西）。
關閉數據庫鏈接sqlite3_close用法
原型：
int sqlite3_close(sqlite3 *ppDb);ppDb為剛才使用sqlite3_open打開的數據庫鏈接
執行sql操作sqlite3_exec用法
原型：
int sqlite3_exec(  sqlite3* ppDb,                             /* An open database */  const char *sql,                           /* SQL to be evaluated */  int (*callback)(void*,int,char**,char**),  /* Callback function */  void *,                                    /* 1st argument to callback */  char **errmsg                              /* Error msg written here */);這就是執行一條sql 語句的函數。第1個參數不再說了，是前面open函數得到的指針。說了是關鍵數據結構。第2個參數constchar*sql是一條sql 語句，以/0結尾。第3個參數sqlite3_callback 是回調，當這條語句執行之后，sqlite3會去調用你提供的這個函數。第4個參數void*是你所提供的指針，你可以傳遞任何一個指針參數到這里，這個參數最終會傳到回調函數里面，如果不需要傳遞指針給回調函數，可以填NULL。等下我們再看回調函數的寫法，以及這個參數的使用。第5個參數char** errmsg 是錯誤信息。注意是指針的指針。sqlite3里面有很多固定的錯誤信息。執行sqlite3_exec 之后，執行失敗時可以查閱這個指針（直接cout<<errmsg得到一串字符串信息，這串信息告訴你錯在什么地方。sqlite3_exec函數通過修改你傳入的指針的指針，把你提供的指針指向錯誤提示信息，這樣sqlite3_exec函數外面就可以通過這個char*得到具體錯誤提示。說明：通常，sqlite3_callback 和它后面的void*這兩個位置都可以填NULL。填NULL表示你不需要回調。比如你做insert 操作，做delete操作，就沒有必要使用回調。而當你做select 時，就要使用回調，因為sqlite3 把數據查出來，得通過回調告訴你查出了什么數據。
exec 的回調
typedef int(*sqlite3_callback)(void*,int,char**,char**);你的回調函數必須定義成上面這個函數的類型。下面給個簡單的例子：//sqlite3的回調函數//sqlite 每查到一條記錄，就調用一次這個回調int LoadMyInfo(void* para,intn_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是對應的，表示這個字段的字段名稱
實例：
#include <iostream>using namespace std;#include "sqlite/sqlite3.h"int callback(void*,int,char**,char**);int main(){    sqlite3* db;    int nResult = sqlite3_open("test.db",&db);    if (nResult != SQLITE_OK)    {        cout<<"打開數據庫失?。?quot;<<sqlite3_errmsg(db)<<endl;        return 0;    }    else    {        cout<<"數據庫打開成功"<<endl;    }    char* errmsg;    nResult = sqlite3_exec(db,"create table fuck(id integer PRimary key autoincrement,name varchar(100))",NULL,NULL,&errmsg);     if (nResult != SQLITE_OK)     {         sqlite3_close(db);         cout<<errmsg;         sqlite3_free(errmsg);        return 0;    }    string strSql;    strSql+="begin;/n";    for (int i=0;i<100;i++)    {        strSql+="insert into fuck values(null,'heh');/n";    }    strSql+="commit;";    //cout<<strSql<<endl;    nResult = sqlite3_exec(db,strSql.c_str(),NULL,NULL,&errmsg);    if (nResult != SQLITE_OK)    {        sqlite3_close(db);        cout<<errmsg<<endl;        sqlite3_free(errmsg);        return 0;    }    strSql = "select * from fuck";    nResult = sqlite3_exec(db,strSql.c_str(),callback,NULL,&errmsg);      if (nResult != SQLITE_OK)    {        sqlite3_close(db);        cout<<errmsg<<endl;        sqlite3_free(errmsg);        return 0;    }    sqlite3_close(db);    return 0;}int callback(void* ,int nCount,char** pValue,char** pName){    string s;    for(int i=0;i<nCount;i++)    {        s+=pName[i];        s+=":";        s+=pValue[i];        s+="/n";    }    cout<<s<<endl;    return 0;}
上一篇介紹的sqlite3_exec 是使用回調來執行對select結果的操作。還有一個方法可以直接查詢而不需要回調。但是，我個人感覺還是回調好，因為代碼可以更加整齊，只不過用回調很麻煩，你得聲明一個函數，如果這個函數是類成員函數，你還不得不把它聲明成static的（要問為什么？這又是C++基礎了。C++成員函數實際上隱藏了一個參數：this，C++調用類的成員函數的時候，隱含把類指針當成函數的第一個參數傳遞進去。結果，這造成跟前面說的sqlite 回調函數的參數不相符。只有當把成員函數聲明成static 時，它才沒有多余的隱含的this參數）。雖然回調顯得代碼整齊，但有時候你還是想要非回調的select 查詢。這可以通過sqlite3_get_table 函數做到。
int sqlite3_get_table(  sqlite3 *db,          /* An open database */  const char *zSql,     /* SQL to be evaluated */  char ***pazResult,    /* Results of the query */  int *pnRow,           /* Number of result rows written here */  int *pnColumn,        /* Number of result columns written here */  char **pzErrmsg       /* Error msg written here */);void sqlite3_free_table(char **result);第1個參數不再多說，看前面的例子。第2個參數是sql 語句，跟sqlite3_exec 里的sql 是一樣的。是一個很普通的以/0結尾的char*字符串。第3個參數是查詢結果，它依然一維數組（不要以為是二維數組，更不要以為是三維數組）。它內存布局是：字段名稱，后面是緊接著是每個字段的值。下面用例子來說事。第4個參數是查詢出多少條記錄（即查出多少行，不包括字段名那行）。第5個參數是多少個字段（多少列）。第6個參數是錯誤信息，跟前面一樣，這里不多說了。
pazResult返回的字符串數量實際上是(*pnRow+1)*(*pnColumn),因為前(*pnColumn)個是字段名
修改上篇的例子，使用sqlite3_get_table,來去的結果集：
#include <iostream>using namespace std;#include "sqlite/sqlite3.h"int callback(void*,int,char**,char**);int main(){    sqlite3* db;    int nResult = sqlite3_open("test.db",&db);    if (nResult != SQLITE_OK)    {        cout<<"打開數據庫失敗："<<sqlite3_errmsg(db)<<endl;        return 0;    }    else    {        cout<<"數據庫打開成功"<<endl;    }    char* errmsg;    nResult = sqlite3_exec(db,"create table fuck(id integer primary key autoincrement,name varchar(100))",NULL,NULL,&errmsg);     if (nResult != SQLITE_OK)     {         sqlite3_close(db);         cout<<errmsg;         sqlite3_free(errmsg);        return 0;    }    string strSql;    strSql+="begin;/n";    for (int i=0;i<100;i++)    {        strSql+="insert into fuck values(null,'heh');/n";    }    strSql+="commit;";    //cout<<strSql<<endl;    nResult = sqlite3_exec(db,strSql.c_str(),NULL,NULL,&errmsg);    if (nResult != SQLITE_OK)    {        sqlite3_close(db);        cout<<errmsg<<endl;        sqlite3_free(errmsg);        return 0;    }    strSql = "select * from fuck";    //nResult = sqlite3_exec(db,strSql.c_str(),callback,NULL,&errmsg);    char** pResult;    int nRow;    int nCol;    nResult = sqlite3_get_table(db,strSql.c_str(),&pResult,&nRow,&nCol,&errmsg);      if (nResult != SQLITE_OK)    {        sqlite3_close(db);        cout<<errmsg<<endl;        sqlite3_free(errmsg);        return 0;    }    string strOut;    int nIndex = nCol;    for(int i=0;i<nRow;i++)    {        for(int j=0;j<nCol;j++)        {            strOut+=pResult[j];            strOut+=":";            strOut+=pResult[nIndex];            strOut+="/n";            ++nIndex;        }    }    sqlite3_free_table(pResult);    cout<<strOut<<endl;    sqlite3_close(db);    return 0;}/*int callback(void* ,int nCount,char** pValue,char** pName){    string s;    for(int i=0;i<nCount;i++)    {        s+=pName[i];        s+=":";        s+=pValue[i];        s+="/n";    }    cout<<s<<endl;    return 0;}*/