Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
c8557afd
T
TDengine
项目概览
taosdata
/
TDengine
12 个月 前同步成功
通知
1180
Star
22014
Fork
4786
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
c8557afd
编写于
1月 13, 2022
作者:
H
Hongze Cheng
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
more tdb
上级
7dbc861b
变更
7
隐藏空白更改
内联
并排
Showing
7 changed file
with
87 addition
and
13 deletion
+87
-13
source/libs/tdb/inc/tdb.h
source/libs/tdb/inc/tdb.h
+2
-2
source/libs/tdb/src/db/tdbDB.c
source/libs/tdb/src/db/tdbDB.c
+37
-4
source/libs/tdb/src/inc/tdbBtree.h
source/libs/tdb/src/inc/tdbBtree.h
+2
-0
source/libs/tdb/src/inc/tdbDB.h
source/libs/tdb/src/inc/tdbDB.h
+4
-2
source/libs/tdb/src/inc/tdbHash.h
source/libs/tdb/src/inc/tdbHash.h
+5
-3
source/libs/tdb/src/inc/tdbHeap.h
source/libs/tdb/src/inc/tdbHeap.h
+35
-0
source/libs/tdb/test/tdbTest.cpp
source/libs/tdb/test/tdbTest.cpp
+2
-2
未找到文件。
source/libs/tdb/inc/tdb.h
浏览文件 @
c8557afd
...
...
@@ -43,8 +43,8 @@ typedef struct {
}
TDB_KEY
,
TDB_VALUE
;
// TDB Operations
TDB_EXTERN
int
tdbCreateDB
(
TDB
**
dbpp
);
TDB_EXTERN
int
tdbOpenDB
(
TDB
*
dbp
,
tdb_db_t
type
,
uint32_t
flags
);
TDB_EXTERN
int
tdbCreateDB
(
TDB
**
dbpp
,
tdb_db_t
type
);
TDB_EXTERN
int
tdbOpenDB
(
TDB
*
dbp
,
uint32_t
flags
);
TDB_EXTERN
int
tdbCloseDB
(
TDB
*
dbp
,
uint32_t
flags
);
#ifdef __cplusplus
...
...
source/libs/tdb/src/db/tdbDB.c
浏览文件 @
c8557afd
...
...
@@ -16,19 +16,52 @@
#include "tdbDB.h"
#include "tdb.h"
TDB_EXTERN
int
tdbCreateDB
(
TDB
**
dbpp
)
{
TDB_EXTERN
int
tdbCreateDB
(
TDB
**
dbpp
,
tdb_db_t
type
)
{
TDB
*
dbp
;
int
ret
;
// dbp = malloc
dbp
=
calloc
(
1
,
sizeof
(
*
dbp
));
if
(
dbp
==
NULL
)
{
return
-
1
;
}
dbp
->
pageSize
=
TDB_DEFAULT_PGSIZE
;
dbp
->
type
=
type
;
switch
(
type
)
{
case
TDB_BTREE_T
:
// ret = tdbInitBtreeDB(dbp);
// if (ret < 0) goto _err;
break
;
case
TDB_HASH_T
:
// ret = tdbInitHashDB(dbp);
// if (ret < 0) goto _err;
break
;
case
TDB_HEAP_T
:
// ret = tdbInitHeapDB(dbp);
// if (ret < 0) goto _err;
break
;
default:
break
;
}
*
dbpp
=
dbp
;
return
0
;
_err:
if
(
dbp
)
{
free
(
dbp
);
}
*
dbpp
=
NULL
;
return
0
;
}
int
tdbOpenDB
(
TDB
*
dbp
,
tdb_db_t
type
,
uint32_t
flags
)
{
TDB_EXTERN
int
tdbOpenDB
(
TDB
*
dbp
,
uint32_t
flags
)
{
// TODO
return
0
;
}
int
tdbCloseDB
(
TDB
*
dbp
,
uint32_t
flags
)
{
TDB_EXTERN
int
tdbCloseDB
(
TDB
*
dbp
,
uint32_t
flags
)
{
// TODO
return
0
;
}
\ No newline at end of file
source/libs/tdb/src/inc/tdbBtree.h
浏览文件 @
c8557afd
...
...
@@ -26,6 +26,8 @@ typedef struct {
pgid_t
root
;
// root page number
}
TDB_BTREE
;
TDB_PUBLIC
int
tdbInitBtreeDB
(
TDB
*
dbp
);
#ifdef __cplusplus
}
#endif
...
...
source/libs/tdb/src/inc/tdbDB.h
浏览文件 @
c8557afd
...
...
@@ -19,6 +19,7 @@
#include "tdb.h"
#include "tdbBtree.h"
#include "tdbHash.h"
#include "tdbHeap.h"
#ifdef __cplusplus
extern
"C"
{
...
...
@@ -28,8 +29,9 @@ struct TDB {
pgsize_t
pageSize
;
tdb_db_t
type
;
union
{
TDB_BTREE
btree
;
TDB_HASH
hash
;
TDB_BTREE
*
btree
;
TDB_HASH
*
hash
;
TDB_HEAP
*
heap
;
}
dbam
;
// Different access methods
};
...
...
source/libs/tdb/src/inc/tdbHash.h
浏览文件 @
c8557afd
...
...
@@ -13,8 +13,8 @@
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#ifndef _TD_T
KV_HAHS
_H_
#define _TD_T
KV_HAHS
_H_
#ifndef _TD_T
DB_HASH
_H_
#define _TD_T
DB_HASH
_H_
#include "tdbDef.h"
...
...
@@ -26,8 +26,10 @@ typedef struct {
// TODO
}
TDB_HASH
;
TDB_PUBLIC
int
tdbInitHashDB
(
TDB
*
dbp
);
#ifdef __cplusplus
}
#endif
#endif
/*_TD_TKV_HAHS_H_*/
\ No newline at end of file
#endif
/*_TD_TDB_HASH_H_*/
\ No newline at end of file
source/libs/tdb/src/inc/tdbHeap.h
0 → 100644
浏览文件 @
c8557afd
/*
* Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
*
* This program is free software: you can use, redistribute, and/or modify
* it under the terms of the GNU Affero General Public License, version 3
* or later ("AGPL"), as published by the Free Software Foundation.
*
* This program is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#ifndef _TD_TDB_HEAP_H_
#define _TD_TDB_HEAP_H_
#include "tdbDef.h"
#ifdef __cplusplus
extern
"C"
{
#endif
typedef
struct
{
// TODO
}
TDB_HEAP
;
TDB_PUBLIC
int
tdbInitHeapDB
(
TDB
*
dbp
);
#ifdef __cplusplus
}
#endif
#endif
/*_TD_TDB_HEAP_H_*/
\ No newline at end of file
source/libs/tdb/test/tdbTest.cpp
浏览文件 @
c8557afd
...
...
@@ -6,9 +6,9 @@ TEST(tdb_api_test, tdb_create_open_close_db_test) {
int
ret
;
TDB
*
dbp
;
tdbCreateDB
(
&
dbp
);
tdbCreateDB
(
&
dbp
,
TDB_BTREE_T
);
tdbOpenDB
(
dbp
,
TDB_BTREE_T
,
0
);
tdbOpenDB
(
dbp
,
0
);
tdbCloseDB
(
dbp
,
0
);
}
\ No newline at end of file
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录