SQLite - C/C++接口 API（一）

1、sqlite3_open(const char *filename, sqlite3 **ppDb)

該例程打開一個指向 SQLite 數據庫文件的連接，返回一個用於其他 SQLite 程序的數據庫連接對象。

如果 filename 參數是 NULL 或 ':memory:'，那么 sqlite3_open() 將會在 RAM 中創建一個內存數據庫，這只會在 session 的有效時間內持續。

如果文件名 filename 不為 NULL，那么 sqlite3_open() 將使用這個參數值嘗試打開數據庫文件。如果該名稱的文件不存在，sqlite3_open() 將創建一個新的命名為該名稱的數據庫文件並打開。

 

2、sqlite3_exec(sqlite3*, const char *sql, sqlite_callback, void *data, char **errmsg)

該例程提供了一個執行 SQL 命令的快捷方式，SQL 命令由 sql 參數提供，可以由多個 SQL 命令組成。

在這里，第一個參數 sqlite3 是打開的數據庫對象，sqlite_callback 是一個回調，data 作為其第一個參數，errmsg 將被返回用來獲取程序生成的任何錯誤。

sqlite3_exec() 程序解析並執行由 sql 參數所給的每個命令，直到字符串結束或者遇到錯誤為止。

 

3、sqlite3_close(sqlite3*)

該例程關閉之前調用 sqlite3_open() 打開的數據庫連接。所有與連接相關的語句都應在連接關閉之前完成。

如果還有查詢沒有完成，sqlite3_close() 將返回 SQLITE_BUSY 禁止關閉的錯誤消息。

 

實例一、

#include <iostream>
#include <string.h>
#include "../Sqlite3/sqlite3.h"
using namespace std;

int callback(void*,int,char**,char**);

int CreateSQLite(void);

int main(int argc, char *argv[])
{
    CreateSQLite();

    return 0;
}

int callback(void *NotUsed, int argc, char **argv, char **azColName)
{
    int i;
    for(i=0; i<argc; i++){
        printf("%s = %s\n", azColName[i], argv[i] ? argv[i] : "NULL");
    }
    printf("\n");

    return 0;
}

int CreateSQLite(void)
{
    int rc = 0;
    sqlite3 *p_DB = NULL;
    char *err_msg = NULL;
    char *p_sql = "CREATE TABLE PERSON("\
                    "ID INT PRIMARY KEY NOT NULL,"\
                    "NAME TEXT NOT NULL,"\
                    "AGE INT NOT NULL);";

    char *str_sql = "INSERT INTO PERSON(ID, NAME, AGE) VALUES(1, 'toney', 23);"\
        "INSERT INTO PERSON(ID, NAME, AGE) VALUES(2, 'mark', 34);"\
        "INSERT INTO PERSON(ID, NAME, AGE) VALUES(3, 'woekd', 43);"\
        "INSERT INTO PERSON VALUES(4, 'YOU', 55);"\
        "SELECT * FROM PERSON;";

    if (SQLITE_OK != (rc = sqlite3_open("mytest.db", &p_DB)))
    {
        cout << "sqlite3_open() function  error  : "<< sqlite3_errmsg(p_DB) << endl;
        return rc;
    }

    if (SQLITE_OK != (rc = sqlite3_exec(p_DB, p_sql, callback, 0, &err_msg)))
    {
        cout << "sqlite3_exec() function error : " << err_msg << endl;
        sqlite3_free(err_msg);
    }

    if (SQLITE_OK != (rc = sqlite3_exec(p_DB, str_sql, callback, 0, &err_msg)))
    {
        cout << "sqlite3_exec() function error : " << err_msg << endl;
        sqlite3_free(err_msg);
    }

    sqlite3_close(p_DB);

    return rc;
}

運行結果：

 

實例二：

#include <stdio.h>
#include <string.h>
#include "../Sqlite3/sqlite3.h"

int callback(void *NotUsed, int argc, char **argv, char **azColName);

int connect_db(char const *p_db_name);

int update_db(sqlite3 *p_db);

int selec_clo_db(sqlite3 *p_db);

int main(int argc, char *argv[])
{
    connect_db("mytest.db");

    return 0;
}

int callback(void *NotUsed, int argc, char **argv, char **azColName)
{
    int i = 0;
    for (i = 0;  i < argc; ++i)
    {
        printf("%s = %s\n", azColName[i], argv[i] ? argv[i] : "NULL");
    }
    printf("\n");

    return 0;
}

int connect_db(char const *p_db_name)
{
    int rec = 0;
    sqlite3 *p_db = NULL;
    char *p_err_msg = NULL;
    char *p_sql = "SELECT * FROM PERSON;";

    if (NULL == p_db_name)
    {
        printf("DB Name  is NULL \n");
        return -1;
    }

    rec = sqlite3_open(p_db_name, &p_db);
    if (SQLITE_OK != rec)
    {
        fprintf(stdin, "sqlite3_open func err : %s\n", sqlite3_errmsg(p_db));
        return rec;
    }

    rec = sqlite3_exec(p_db, p_sql, callback, 0, &p_err_msg);
    if (SQLITE_OK != rec)
    {
        printf("sqlite3_exec function err : %s\n", p_err_msg);
        sqlite3_free(p_err_msg);
        sqlite3_close(p_db);
        return rec;
    }

    

    rec = update_db(p_db);
    if (0 != rec)
    {
        fprintf(stdin, "update_db function err\n");
    }

    return rec;
}

int update_db(sqlite3 *p_db)
{
    int rec = 0;
    char *p_sql = "UPDATE PERSON SET NAME = 'KING' WHERE ID = 2;";
    char *p_err_msg = NULL;

    if (NULL == p_db)
    {
        printf("update_db  func  p_db is NULL\n");
        return -1;
    }

    rec = sqlite3_exec(p_db, p_sql, NULL, 0, &p_err_msg);
    if (SQLITE_OK != rec)
    {
        printf("update_db  sqlite3_exec func err : %s\n", p_err_msg);
        sqlite3_free(p_err_msg);
        sqlite3_close(p_db);
        return rec;
    }

    printf("修改之后 !\n");
    rec = selec_clo_db(p_db);
    if (0 != rec)
    {
        printf("select_clo_db  func err \n");
    }

    return rec;
}

int selec_clo_db(sqlite3 *p_db)
{
    int rec = 0;
    char *p_sql = "SELECT * FROM PERSON;";
    char *p_err_msg = NULL;

    rec = sqlite3_exec(p_db, p_sql, callback, 0, &p_err_msg);
    if (SQLITE_OK != rec)
    {
        printf("selec_clo_db sqlite3_exec func err :%s\n", p_err_msg);
        sqlite3_free(p_err_msg);
    }

    sqlite3_close(p_db);

    return rec;
}

運行結果：