IT评测·应用市场-qidao123.com技术社区

标题: 基于嵌入式Linux的数据库 [打印本页]

---

作者: 李优秀    时间: 2024-8-14 16:05
标题: 基于嵌入式Linux的数据库
数据库

数据库是在数据库管理系统和控制之下，存放在存储 介质上的数据集合。
基于嵌入式的数据库

基于嵌入式linux的数据库重要有SQlite，
Firebird,Berkeley DB,eXtremeDB
        Firebird是关系型数据库，功能强大，支持存储过 程，SQL兼容等
        SQlite关系型数据库体积小，支持ACID事务
        Berkeley DB中并没有数据库服务器的概念，它的程 序直接链接到应用程序中
        eXtremeDB是内存数据库，运行效率高
SQlite基础

SQLite的源码是C语言，其源代码完全开辟，SQLite
第一个Alpha版本诞生于2000年5月，他是一个轻量 级的嵌入式数据库。
SQLite有以下特性 零配置，无需安装和管理配置 存储在单一磁盘文件中的一个完备的数据库 数据库文件可以在不同字节序次的机器间自由共享支持数据库大小至2TB
充足小，全部源码大抵三万行C代码，250KB
比目前留下的大多数数据库对数据的利用更快
创建数据库

1.在线安装

sudo apt-get install sqlite3
2.本地安装

官网下载sqlite3，然后本地安装：sudo dpkg -i *.deb
3.SQlite3 基本命令

1.系统命令 以 . 开头的命令
        .help 帮助
        .quit 退出
        .schema查看表结构
        .databases 查看打开的数据库
        .table 

2.sql命令
基本的sql命令，不以 . 开头，但是都要 ； 末了
创建一张数据库的表
        stucreate table stu(id Integer,name char,score Integer);

插入一张记录
        insert into stu values(1001,'zhangsan',80);

插入部分字段记录
        insert into stu(name,score) values(1002,'lisi');

查询所有记录
        select *from stu
查询数据库部分内容字段
        select name,score from stu

根据属性查询
        select * from stu where score=80; select *from stu where score=80 and name='zhangsan';

删除一条记录
        delede from stu where id=1003; delete from stu where socre='90';
更新一条记录
        update stu set name='wangwu' where id=1001; update stu set name='wangwu',score=88 where id = 1001;
添加一列
        alter table stu add column address char;
删除一列
1.创建一张表 提取字段
create table stu1 as select id,name,score from stu;
2.删除原有表
drop table stu;
3.将新的表的名字改成原有的表名字
alter table stu1 rename to stu;

SQlite编程接口

4.API利用

1.int sqlite3_open(char *filename,sqlite3 **db)
        功能：打开sqlite数据库 参数：
        filename:数据库文件路径
        db:指向sqlite句柄的指针
返回值：
        成功返回0，失败返回错误码（非0值）
2.int sqlite3_close(sqlite3 *db);
        功能：关闭sqlite数据库 参数：
        db 利用数据库的指针
返回值：
               成功返回0，失败返回错误码
3.const char *sqlite3_errmsg(sqlite3 *db);
        功能：通过DB句柄得到数据库利用的错误信息
参数：
        db 利用数据库的指针       
        返回值： 返回错误信息的首地址
4.int sqlite3_exec(const char *sql, int (*callback)(void *,int,char**,char *8) void *, char **errmsg);
        功能：执行一条sql语句
参数
        db:数据库利用句柄
        sql：一条sql语句
        sqlite3*db,
        callback：回调函数，只有sql为查询语句的时间， 才会执行此语句
        void * ：给回调函数转达参数
        errmsg:错误信息
返回值：
        成功：SQLITE_OK
int (*callback)(void *,int,char**,char *8)
        功能：查询效果，是一个函数指针类型，转达一个函数名

回调函数接口：
typedef int(*sqlite3_callback)( void *para, int f_num, char ** f_value, char ** f_name)
        功能： 每找到一条记录自动执行一次回调函数
        para:转达给回调函数的参数
        f_num:记录中包含的字段数目
        f_value:包含每个字段值的指针数组
        f_name:包含每个字段名称的指针数组
返回值，
        成功返回0，失败返回-1
不使用回调函数执行SQL语句
int sqlite3_get_table( sqlite3 *db, const char *sql, char ***resultp,int *nrow, int *ncolumu,char **errmsg)
        功能：执行sql利用
        db:数据库句柄
        sql:sql语句
        resultp:用来指向sql执行效果的指针
        nrow:满意条件的记录的数目
        ncolumn:每条记录包含的字段数目
        errmsg:错误信息指针的地址
返回值：
        成功返回0，失败返回错误码

1. #include <stdio.h>  
2. #include <stdlib.h>  
3. #include <sqlite3.h>  
4.   
5. // sqlite3_callback 类型的回调函数  
6. int callback(void *NotUsed, int argc, char **argv, char **azColName){  
7.     int i;  
8.     for(i = 0; i<argc; i++){  
9.         printf("%s = %s\n", azColName[i], argv[i] ? argv[i] : "NULL");  
10.     }  
11.     printf("\n");  
12.     return 0;  
13. }  
14.   
15. int main() {  
16.     sqlite3 *db;  
17.     char *err_msg = 0;  
18.     int rc;  
19.     char **result;  
20.     int row, column;  
21.   
22.     // 打开数据库  
23.     rc = sqlite3_open("test.db", &db);  
24.     if (rc) {  
25.         fprintf(stderr, "无法打开数据库: %s\n", sqlite3_errmsg(db));  
26.         return 1;  
27.     }  
28.   
29.     // 使用 sqlite3_exec 和回调函数  
30.     rc = sqlite3_exec(db, "SELECT * FROM my_table", callback, 0, &err_msg);  
31.     if (rc != SQLITE_OK ){  
32.         fprintf(stderr, "SQL错误: %s\n", err_msg);  
33.         sqlite3_free(err_msg);  
34.         sqlite3_close(db);  
35.         return 1;  
36.     }  
37.   
38.     // 使用 sqlite3_get_table 获取结果  
39.     rc = sqlite3_get_table(db, "SELECT * FROM my_table", &result, &row, &column, &err_msg);  
40.     if (rc != SQLITE_OK) {  
41.         fprintf(stderr, "SQL错误: %s\n", err_msg);  
42.         sqlite3_free(err_msg);  
43.         sqlite3_close(db);  
44.         return 1;  
45.     }  
46.   
47.     // 输出 sqlite3_get_table 的结果  
48.     printf("sqlite3_get_table 结果:\n");  
49.     for (int i = 0; i < row + 1; i++) {  
50.         for (int j = 0; j < column; j++) {  
51.             printf("%s ", result[i*column + j] ? result[i*column + j] : "NULL");  
52.         }  
53.         printf("\n");  
54.     }  
55.   
56.     // 释放结果  
57.     sqlite3_free_table(result);  
58.   
59.     // 关闭数据库  
60.     sqlite3_close(db);  
61.   
62.     return 0;  
63. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

---

欢迎光临 IT评测·应用市场-qidao123.com技术社区 (https://dis.qidao123.com/)

Powered by Discuz! X3.4