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 =https://www.cnblogs.com/hylife/p/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 =https://www.cnblogs.com/hylife/p/= 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 =https://www.cnblogs.com/hylife/p/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

轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/545376.html

標籤：其它

上一篇：Postgres服務搭建使用

下一篇：Postgres服務搭建使用