API 说明
读取 blob 数据
通过 KVDB 和 TSDB 的 API 可以返回 blob 对象,此时返回的 blob 对象里存放了 blob 数据的存储地址。该 API 可以将数据库里存放的 blob 数据读取出来,并存放至 blob->buf
。
size_t fdb_blob_read(fdb_db_t db, fdb_blob_t blob)
参数 | 描述 |
---|---|
db | 数据库对象 |
blob | blob 对象 |
返回 | 实际读取到的 blob 数据长度 |
初始化 KVDB
fdb_err_t fdb_kvdb_init(fdb_kvdb_t db, const char *name, const char *path, struct fdb_default_kv *default_kv, void *user_data)
参数 | 描述 |
---|---|
db | 数据库对象 |
name | 数据库名称 |
path | FAL 模式:分区表中的分区名,文件模式:数据库保存的路径 |
default_kv | 默认 KV 集合,第一次初始化时,将会把默认 KV 写入数据库中 |
user_data | 用户自定义数据,没有时传入 NULL |
返回 | 错误码 |
控制 KVDB
通过命令控制字,用户可以对数据库进行一些控制操作
void fdb_kvdb_control(fdb_kvdb_t db, int cmd, void *arg)
参数 | 描述 |
---|---|
db | 数据库对象 |
cmd | 命令控制字 |
arg | 控制的参数 |
返回 | 错误码 |
支持的命令控制字如下:
扇区大小与块大小
FlashDB 内部存储结构由 N 个扇区组成,每次格式化时是以扇区作为最小单位。而一个扇区通常是 Flash 块大小的 N 倍,比如: Nor Flash 的块大小一般为 4096。
默认 KVDB 会使用 1倍 的块大小作为扇区大小,即:4096。此时,该 KVDB 无法存入超过 4096 长度的 KV 。如果想要存入比如:10K 长度的 KV ,可以通过 control 函数,设置扇区大小为 12K,或者更大大小即可。
反初始化 KVDB
fdb_err_t fdb_kvdb_deinit(fdb_kvdb_t db)
参数 | 描述 |
---|---|
db | 数据库对象 |
设置 KV
使用此方法可以实现对 KV 的增加和修改功能。
增加 :当 KVDB 中不存在该名称的 KV 时,则会执行新增操作;
修改 :入参中的 KV 名称在当前 KVDB 中存在,则把该 KV 值修改为入参中的值;
通过 KV 的名字来获取其对应的值。支持两种接口
设置 blob 类型KV
fdb_err_t fdb_kv_set_blob(fdb_kvdb_t db, const char *key, fdb_blob_t blob)
参数 | 描述 |
---|---|
db | 数据库对象 |
key | KV 的名称 |
blob | blob 对象,做为 KV 的 value |
返回 | 错误码 |
设置 string 类型KV
fdb_err_t fdb_kv_set(fdb_kvdb_t db, const char *key, const char *value)
参数 | 描述 |
---|---|
db | 数据库对象 |
key | KV 的名称 |
value | KV 的 value |
返回 | 错误码 |
获取 KV
获取 blob 类型 KV
size_t fdb_kv_get_blob(fdb_kvdb_t db, const char *key, fdb_blob_t blob)
参数 | 描述 |
---|---|
db | 数据库对象 |
key | KV 的名称 |
blob | 通过 blob 对象,返回 KV 的 blob value |
返回 | 错误码 |
示例:
获取 KV 对象
与 fdb_kv_get_blob
API 不同,该 API 在 get 过程中并不会执行 value 数据的读取动作。返回的 KV 对象中存放了读取回来的 KV 属性,该 API 适用于 value 长度不确定,或 value 长度过长,需要分段读取的场景。
获取字符串类型 KV
注意 :
- 该函数不允许连续使用,使用时需使用 strdup 包裹,确保每次返回回来的字符串内存空间独立;
char *fdb_kv_get(fdb_kvdb_t db, const char *key)
参数 | 描述 |
---|---|
db | 数据库对象 |
key | KV 的名称 |
返回 | !=NULL: KV 的 value;NULL: 获取失败 |
fdb_err_t fdb_kv_del(fdb_kvdb_t db, const char *key)
参数 | 描述 |
---|---|
db | 数据库对象 |
key | KV 的名称 |
返回 | 错误码 |
重置 KVDB
将 KVDB 中的 KV 重置为 首次初始时 的默认值
fdb_err_t fdb_kv_set_default(fdb_kvdb_t db)
参数 | 描述 |
---|---|
db | 数据库对象 |
返回 | 错误码 |
打印 KVDB 中的 KV 信息
void fdb_kv_print(fdb_kvdb_t db)
参数 | 描述 |
---|---|
db | 数据库对象 |
返回 | 错误码 |
KV 对象转换为 blob 对象
fdb_blob_t fdb_kv_to_blob(fdb_kv_t kv, fdb_blob_t blob)
参数 | 描述 |
---|---|
kv | 待转换的 KV 对象 |
blob | 转换前的 blob 对象 |
返回 | 转换后的 blob 对象 |
初始化 KV 迭代器
fdb_kv_iterator_t fdb_kv_iterator_init(fdb_kv_iterator_t itr)
参数 | 描述 |
---|---|
itr | 待初始化的迭代器对象 |
返回 | 初始化后的迭代器对象 |
迭代 KV
使用该迭代器 API,可以遍历整个 KVDB 中的所有 KV。
初始化 TSDB
fdb_err_t fdb_tsdb_init(fdb_tsdb_t db, const char *name, const char *path, fdb_get_time get_time, size_t max_len, void *user_data)
参数 | 描述 |
---|---|
db | 数据库对象 |
name | 数据库名称 |
path | FAL 模式:分区表中的分区名,文件模式:数据库保存的路径 |
get_time | 获取当前时间戳的函数 |
max_len | 每条 TSL 的最大长度 |
user_data | 用户自定义数据,没有时传入 NULL |
返回 | 错误码 |
通过命令控制字,用户可以对数据库进行一些控制操作
支持的命令控制字如下:
反初始化 TSDB
fdb_err_t fdb_tsdb_deinit(fdb_tsdb_t db)
参数 | 描述 |
---|---|
db | 数据库对象 |
追加 TSL
对于 TSDB ,新增 TSL 的过程,就是往 TSDB 末尾追加新 TSL 的过程
fdb_err_t fdb_tsl_append(fdb_tsdb_t db, fdb_blob_t blob)
参数 | 描述 |
---|---|
db | 数据库对象 |
blob | blob 对象,做为 TSL 的数据 |
返回 | 错误码 |
迭代 TSL
遍历整个 TSDB 并执行迭代回调
void fdb_tsl_iter(fdb_tsdb_t db, fdb_tsl_cb cb, void *cb_arg)
参数 | 描述 |
---|---|
db | 数据库对象 |
cb | 回调函数,每次遍历到 TSL 时会执行该回调 |
cb_arg | 回调函数的参数 |
返回 | 错误码 |
按时间段迭代 TSL
按时间段范围,遍历整个 TSDB 并执行迭代回调
void fdb_tsl_iter_by_time(fdb_tsdb_t db, fdb_time_t from, fdb_time_t to, fdb_tsl_cb cb, void *cb_arg)
参数 | 描述 |
---|---|
db | 数据库对象 |
from | 开始时间戳 |
to | 结束时间戳 |
cb | 回调函数,每次遍历到 TSL 时会执行该回调 |
cb_arg | 回调函数的参数 |
返回 | 错误码 |
查询 TSL 的数量
按照传入的时间段,查询符合状态的 TSL 数量
size_t fdb_tsl_query_count(fdb_tsdb_t db, fdb_time_t from, fdb_time_t to, fdb_tsl_status_t status)
参数 | 描述 |
---|---|
db | 数据库对象 |
from | 开始时间戳 |
to | 结束时间戳 |
status | TSL 的状态条件 |
返回 | 数量 |
设置 TSL 状态
TSL 状态详见 enum fdb_tsl_status
,必须按照顺序设置 TSL 状态,
fdb_err_t fdb_tsl_set_status(fdb_tsdb_t db, fdb_tsl_t tsl, fdb_tsl_status_t status)
参数 | 描述 |
---|---|
db | 数据库对象 |
tsl | TSL 对象 |
status | TSL 的新状态 |
返回 | 错误码 |
void fdb_tsl_clean(fdb_tsdb_t db)
参数 | 描述 |
---|---|
db | 数据库对象 |
返回 | 错误码 |