sqlite3資料庫Linux 系統移植和使用

sqlite3資料庫是一個小型的資料庫，當資料量不大，要求不是特別高的時候，是個不錯的選擇。

在Linux上移植和使用也非常的方便。

本範例是在硬體全志r528 .linux5.4 上驗證的。

移植操作：

　　　1、原始碼下載

　　　　　　去官網進行下載原始碼SQLite Download Page，根據自己的選取選擇不同的版本。我發現我係統的menuconfig 上就帶sqlite3的資料庫，所以沒有在

官網上下載，直接勾選上。編譯出來的。

　　　 2、交叉編譯

　　進入sqlite-autoconf-3230100後執行以下指令生成Makefile檔案：

./configure CC=arm-hisiv400-linux-gcc--host=arm-hisiv400-linux--prefix=/home/rong//share/lishuangliang/sqlite/install

其中CC指定嵌入式平臺為arm-hisiv400-linux-gcc即海思的Hi3536；host項指定主機；prefix項指定安裝目錄；

需要注意的是每一項設定的等號兩邊不能有空格。接著執行make進行編譯，待編譯完成後執行make install進行安裝，

至此原始碼編譯安裝完成。（未驗證）
　　　　　　編譯出來有用的檔案有libsqlite3.so libsqlite3.so.0動態庫。sqlite3 可執行檔案。

　　　 3、設定部署編譯出來的庫和執行檔案

　　　　將libsqlite3.so libsqlite3.so.0動態庫拷貝到Linux系統的 /usr/lib/ 目錄下，

　　　　　　將sqlite3 拷貝到Linux系統的 /usr/bin/ 目錄下面。

應用編譯

　　　　將 libsqlite3.so libsqlite3.so.0 放在要編譯的應用程式一個目錄或其他目錄下都可以主要是編譯器要能找到。

　　　　sqlite3.h放在放在要編譯的應用程式一個目錄

　　設定交叉編譯必須加上 -lsqlite3 -L加上庫目錄 -I 加上標頭檔案目錄

　　如下是一個簡單的Makefile

# 方便起見一般都會先定義編譯器連結器
CC = arm-openwrt-linux-gcc 
LD = arm-openwrt-linux-gcc
FLAGS = -lsqlite3 -L /home/kerson/app/test_app/sqlit3  -I /home/kerson/app/test_app/sqlit3

# 正規表示式表示目錄下所有.c檔案，相當於：SRCS = main.c a.c b.c
SRCS = $(wildcard *.c)

# OBJS表示SRCS中把列表中的.c全部替換為.o，相當於：OBJS = main.o a.o b.o
OBJS = $(patsubst %c, %o, $(SRCS))

# 可執行檔案的名字
TARGET = test_sqlite

# .PHONE偽目標，具體含義百度一下一大堆介紹
.PHONY:all clean

# 要生成的目標檔案
all: $(TARGET)

# 第一行依賴關係：冒號後面為依賴的檔案，相當於Hello: main.o a.o b.o
# 第二行規則：$@表示目標檔案，$^表示所有依賴檔案，$<表示第一個依賴檔案
$(TARGET): $(OBJS)
    $(LD) $(FLAGS) -o $@ $^

# 上一句目標檔案依賴一大堆.o檔案，這句表示所有.o都由相應名字的.c檔案自動生成
%.o:%.c
    $(CC) $(FLAGS) -c $^

# make clean刪除所有.o和目標檔案
clean:
    rm -f $(OBJS) $(TARGET)

下面分享實驗程式碼。

主要是拼接SQL語句。之後用exec函數執行SQL語句。

主要的是查詢表格內容時，注意回撥函數是每查詢到一條記錄就執行一次回撥函數。

my_sqlite3.c


#include <stdlib.h>
#include <stdio.h>
#include <string.h>

#include "sqlite3.h"
#include "my_sqlite3.h"




/*
* @brief 開啟/建立資料庫
* @param 無
* @return 失敗返回NULL/成功返回資料庫db
*/

sqlite3 * sqlite3_open_database(char * db_name)
{
    int ret = 0;
    sqlite3* db;

    if(db_name == NULL || strlen(db_name) == 0){
        return NULL;
    }
    
    ret = sqlite3_open(db_name ,&db);
    if(ret != SQLITE_OK){
        printf("Open db error =:%s",sqlite3_errmsg(db));
        return NULL;
    }
    
    return db;
}


/*
* @brief 建立一個表
* @param db,
    table_name:表名字
    data_buf:列專案
* @return 失敗返回-1/成功返回0
*/

int sqlite3_create_table(sqlite3 *db, char * table_name,char *data_buf)
{
    char sql_str[128] ={0};
    char *err_msg = NULL;
    int ret =-1;
    if(table_name == NULL ||strlen(table_name) ==0){
        printf("input argc error\n");
        return -1;
    }

    sprintf(sql_str,"CREATE TABLE IF NOT EXISTS %s %s",table_name,data_buf);
    ret = sqlite3_exec(db,sql_str,0,0,&err_msg);
    if(ret != SQLITE_OK)
    {
        printf("Creat table %s error : %s", table_name,err_msg);
        sqlite3_free(err_msg);
    }else{
        ret = 0;
    }

    return ret;
}




/*
* @brief 刪除一個表
* @param db,
    table_name:表名字
* @return 失敗返回-1/成功返回0
*/
int sqlite3_delete_table(sqlite3 *db, char * table_name)
{
    char sql_str[128] ={0};
    char *err_msg = NULL;
    int ret =-1;
    if(table_name == NULL ||strlen(table_name) ==0){
        printf("input argc error\n");
        return -1;
    }

    sprintf(sql_str,"DROP TABLE %s",table_name);
    sqlite3_busy_timeout(db, 1000);
    ret = sqlite3_exec(db,sql_str,0,0,&err_msg);
    if(ret != SQLITE_OK)
    {
        printf("Delete table %s error : %s", table_name,err_msg);
        sqlite3_free(err_msg);
    }else{
        ret = 0;
    }
    return ret;

    
}


/*
* @brief 插入一條資料
* @param db,
    table_name:表名字
* @return 失敗返回-1/成功返回0
*/
int sqlite3_insert_single(sqlite3 *db,char *table_name,  char *data_buf)
{

    char sql_str[128] ={0};
    char *err_msg = NULL;
    int ret =-1;
    if(table_name == NULL ||strlen(table_name) ==0){
        printf("input argc error\n");
        return -1;
    }

    sprintf(sql_str,"INSERT INTO %s values %s",table_name,data_buf);
    sqlite3_busy_timeout(db, 1000);
    ret = sqlite3_exec(db,sql_str,0,0,&err_msg);
    if(ret != SQLITE_OK)
    {
        printf("insert table %s error : %s", table_name,err_msg);
        sqlite3_free(err_msg);
    }else{
        ret = 0;
    }
    return ret;
}



/*
* @brief 插入多條資料(利用顯示事物機制,效率高)
* @param db,
    table_name:表名字
    data_buf 多條插入的內容
* @return 失敗返回-1/成功返回0
*/

int sqlite3_insert_multi(sqlite3 *db,char *table_name,  char **data_buf ,int len)
{

    char sql_str[128] ={0};
    char *err_msg = NULL;
    int ret =-1 ,i =0;
    sqlite3_stmt * stmt;
    
    if(table_name == NULL ||strlen(table_name) ==0){
        printf("input argc error\n");
        return -1;
    }
    sprintf(sql_str,"INSERT INO %s values ?");

    sqlite3_exec(db,"BEGIN",0,0,0);
    ret = sqlite3_prepare(db,sql_str,strlen(sql_str),&stmt,0);
    if(ret != SQLITE_OK)
        return -1;
    
    while(data_buf[i] !=NULL && i < len){
        sqlite3_bind_text(stmt,1,data_buf[i],strlen(data_buf[i]),NULL);
        ret = sqlite3_step(stmt);
        if((ret != SQLITE_OK) && (ret != SQLITE_DONE)){
            break;
        }
        sqlite3_reset(stmt);
        i++;
    }
    sqlite3_finalize(stmt);
    if(i < len){
        sqlite3_exec(db,"ROLLBACK",0,0,0);
        return -1;
    }
    if(i == len){
        sqlite3_exec(db,"COMMIT",0,0,0);
        ret =0;
    }    


    return ret;
}



/*
* @brief 查詢回撥函數
* @param 

 data:由sqlite3_exec傳遞的初始化引數
 argc:表頭的列數
 col:表頭的名字陣列指標
 argv:表頭的資料陣列指標

* @return 失返回0
*/
int exec_handle(void *data, int argc, char **argv,char ** colname)
{
    /*查詢到一條結果將data+1*/    
    int i = *(int *)(data);
    *(int *)(data) = i+1;

    /*列印*/
    for(i =0;i<argc;i++){
        printf("NUM =%d %s\t%s\n",*(int *)(data),colname[i],argv[i]);
    }

    return 0;
}




/*
* @brief 查詢表格內容  sql語句：SELECT 列名稱 FROM 表名稱 WHERE 列 運運算元 值
列名稱為 * 代表所有的列
* @param db,
    table_name:表名字
* @return 失敗返回-1/成功返回0 查詢成功，無查詢結果，返回1 查詢成功，有查詢結果
*/
int sqlite3_select_exec(sqlite3 *db,char *table_name, char *col_name, char *where_cond)
{
    char sql_str[128] ={0};
    char *err_msg = NULL;
    int ret =-1;
    int data =0;
    if(table_name == NULL ||strlen(table_name) ==0){
        printf("input argc error\n");
        return -1;
    }

    sprintf(sql_str,"select %s from %s ",col_name,table_name);
    
    if(where_cond != NULL){
        strcat(sql_str," where ");
        strcat(sql_str,where_cond);
    }
    sqlite3_busy_timeout(db, 1000);
    ret = sqlite3_exec(db,sql_str,exec_handle,&data,&err_msg);
    if(ret != SQLITE_OK)
    {
        printf("select table %s error : %s", table_name,err_msg);
        sqlite3_free(err_msg);
    }else{

        if(data == 0){
            return 0; /*查詢成功，無查詢結果*/
        }else{
            return 1; /*查詢成功，有查詢結果*/
        }    
        
    }

}


/*
* @brief 查詢資料庫中的表格  sql語句：select name from sqlite_maseter where type ='table' order by name
列名稱為 * 代表所有的列
* @param db,
* @return 
*/
int sqlite3_get_tablename(sqlite3 *db)
{
    char sql_str[128] ={0};
    char *err_msg = NULL;
    int ret =-1;
    char ** dbresult;
    int i,j,nrow,ncolumn,index =0;

    sprintf(sql_str,"select name from sqlite_master where type ='table' order by name ");
    
    sqlite3_busy_timeout(db, 1000);
    ret = sqlite3_get_table(db,sql_str,&dbresult,&nrow,&ncolumn,&err_msg);
    if(ret == SQLITE_OK)
    {
        for(i=0;i <= nrow; i++)
            /*for(j=0;j< ncolumn;j++)*/
        {
            printf("%s \n",dbresult[index]);
            index++;
        }
    }
    else{

        printf(" get table error\n ");
    }

}




/*
* @brief 更新 sql語句：UPDATAE 表名 SET 新值 WHERE 列 運運算元 值
* @param db,
    table_name:表名字
* @return 失敗返回-1/成功返回0 查詢成功，無查詢結果，返回1 查詢成功，有查詢結果
*/
int sqlite3_update_single(sqlite3 *db,char *table_name, char *new_val, char *where_cond)
{
    char sql_str[128] ={0};
    char *err_msg = NULL;
    int ret =-1;

    if(table_name == NULL ||strlen(table_name) ==0){
        printf("input argc error\n");
        return -1;
    }

    sprintf(sql_str,"UPDATE %s SET %s",table_name,new_val);
    if(where_cond != NULL){
        strcat(sql_str," where ");
        strcat(sql_str,where_cond);
    }    
    sqlite3_busy_timeout(db, 1000);
    ret = sqlite3_exec(db,sql_str,0,0,&err_msg);
    if(ret != SQLITE_OK)
    {
        printf("UPDATE table %s error : %s", table_name,err_msg);
        sqlite3_free(err_msg);
        ret =-1;
    }else{

        ret = 0;    
    }
    return ret;

}


/*
* @brief 刪除 sql語句：DELETE FROM 表名稱 WHERE 列 運運算元 值
沒有where 為刪除所有。
* @param db,
    table_name:表名字
* @return 失敗返回-1/成功返回0 查詢成功，無查詢結果，返回1 查詢成功，有查詢結果
*/
int sqlite3_delete_single(sqlite3 *db,char *table_name,char *where_cond)
{
    char sql_str[128] ={0};
    char *err_msg = NULL;
    int ret =-1;
    int data =0;
    if(table_name == NULL ||strlen(table_name) ==0){
        printf("input argc error\n");
        return -1;
    }

    sprintf(sql_str,"DELETE FROM %s",table_name);
    if(where_cond != NULL){
        strcat(sql_str," where ");
        strcat(sql_str,where_cond);
    }
    sqlite3_busy_timeout(db, 1000);
    ret = sqlite3_exec(db,sql_str,exec_handle,&data,&err_msg);
    if(ret != SQLITE_OK)
    {
        printf("s table %s error : %s", table_name,err_msg);
        sqlite3_free(err_msg);
        ret =-1;
    }else{

        ret = 0;    
    }
    return ret;

}

標頭檔案

my_sqlite3.h


#ifndef _MY_SQLITE3_H_
#define _MY_SQLITE3_H_



sqlite3 * sqlite3_open_database(char * db_name);
int sqlite3_create_table(sqlite3 *db, char * table_name,char *data_buf);

int sqlite3_delete_table(sqlite3 *db, char * table_name);
int sqlite3_insert_single(sqlite3 *db,char *table_name,  char *data_buf);
int sqlite3_select_exec(sqlite3 *db,char *table_name, char *col_name, char *where_cond);
int exec_handle(void *data, int argc, char **argv,char ** colname);
int sqlite3_update_single(sqlite3 *db,char *table_name, char *new_val, char *where_cond);
int sqlite3_delete_single(sqlite3 *db,char *table_name,char *where_cond);
int sqlite3_get_tablename(sqlite3 *db);




#endif

測試程式碼

main.c


#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "sqlite3.h"
#include "my_sqlite3.h"

#define DB_NAME  "./test.db" 
#define DB_NAME1  "./data.db" 

#define TABLE_NAME "stu_table"
#define TABLE_NAME1 "場景表"

#define MAX_LEN 512


int main(int argc, char **argv)
{
    sqlite3 *db = NULL;
    char buf[MAX_LEN] ={0};
    char buf1[MAX_LEN] ={0};
    char *errmsg;
    int ret;

    db = sqlite3_open_database(DB_NAME);
    if(db == NULL){
        printf("open db error\n");
        return -1;
    }

    /*建立一個表*/
#if 0
    memset(sql,0,sizeof(sql));
    strcpy(sql,"creat table if not exists %s(name text ,score int);",TABLE_NAME);
    ret = sqlite3_exec(db,sql,NULL,NULL,&errmsg);
    if(ret !=0)
    {
        printf("sqlite3_exec:%s\n",errmsg);
    }
#endif
    memset(buf,0,sizeof(buf));
    strcpy(buf,"(Name text ,Score int)");
    ret = sqlite3_create_table(db,TABLE_NAME,buf);
    if(ret !=0)
    {
        return -1;
    }
    
    sqlite3_get_tablename(db); /*獲取有多少表格*/


    /*插入表中*/
    memset(buf,0,sizeof(buf));
    strcpy(buf,"('lili',86)");
    ret = sqlite3_insert_single(db,TABLE_NAME,buf);
    if(ret !=0)
    {
        return -1;
    }


    /*插入表中*/
    memset(buf,0,sizeof(buf));
    strcpy(buf,"('wangwu',99)");
    ret = sqlite3_insert_single(db,TABLE_NAME,buf);
    if(ret !=0)
    {
        return -1;
    }

    /*查詢*/
    printf("select all:\n");
    sqlite3_select_exec(db,TABLE_NAME,"*",NULL);
    printf("select Score > 90:\n");
    memset(buf,0,sizeof(buf));
    strcpy(buf,"Score > 90");
    sqlite3_select_exec(db,TABLE_NAME,"*",buf);
    
    /*更改*/
    memset(buf,0,sizeof(buf));
    strcpy(buf,"Score = 91");
    memset(buf1,0,sizeof(buf1));
    strcpy(buf1,"Score < 90");
    sqlite3_update_single(db,TABLE_NAME,buf,buf1);


    /*查詢*/
    printf("select all:\n");
    sqlite3_select_exec(db,TABLE_NAME,"*",NULL);
    printf("select Score > 90:\n");
    memset(buf,0,sizeof(buf));
    strcpy(buf,"Score > 90");
    sqlite3_select_exec(db,TABLE_NAME,"*",buf);

    /*刪除*/
    memset(buf,0,sizeof(buf));
    strcpy(buf,"Score > 90");
    sqlite3_delete_single(db,TABLE_NAME,buf);

    printf("select all:\n");
    sqlite3_select_exec(db,TABLE_NAME,"*",NULL);



    /*關閉資料庫*/
    sqlite3_close(db);


    db = sqlite3_open_database(DB_NAME1);
    if(db == NULL){
        printf("open db error\n");
        return -1;
    }

    sqlite3_get_tablename(db); /*獲取有多少表格*/


    /*查詢*/
    printf("select all:\n");
    sqlite3_select_exec(db,TABLE_NAME1,"*",NULL);

    /*更改*/
    memset(buf,0,sizeof(buf));
    strcpy(buf,"播放亮度 = 255");
    memset(buf1,0,sizeof(buf1));
    strcpy(buf1,"場景ID = 6");
    sqlite3_update_single(db,TABLE_NAME1,buf,buf1);


    /*查詢*/
    printf("select all:\n");
    sqlite3_select_exec(db,TABLE_NAME1,"*",NULL);


    /*關閉資料庫*/
    sqlite3_close(db);

 
    return 0;
}

具體其他更細節的SQL語句，需要什麼功能就百度搜尋，拼接執行。

參考資料：

(29條訊息) sqlite3資料庫移植詳解_dosthing的部落格-CSDN部落格_移植sqlite3