From 5c738986cb8ed48a288bb8cf6d624a043a89410a Mon Sep 17 00:00:00 2001 From: slguan Date: Sat, 15 Feb 2020 12:25:56 +0800 Subject: [PATCH] dnode Write.h --- src/dnode/inc/dnodeWrite.h | 45 ++++++++++++++++++++++++++++++-------- src/dnode/src/dnodeWrite.c | 41 +++++++++++++++++++++++++++++++++- 2 files changed, 76 insertions(+), 10 deletions(-) diff --git a/src/dnode/inc/dnodeWrite.h b/src/dnode/inc/dnodeWrite.h index 77ac78ea0e..e323f48020 100644 --- a/src/dnode/inc/dnodeWrite.h +++ b/src/dnode/inc/dnodeWrite.h @@ -25,31 +25,58 @@ extern "C" { #include "taosdef.h" #include "taosmsg.h" +/* + * Write data based on dnode + * If >= 0, it is affect rows + * If < 0, get error code from terrno + */ +int32_t dnodeWriteData(SShellSubmitMsg *msg); + /* * Check if table already exists */ -int32_t dnodeCheckTableExist(int vid, int sid, int64_t uid); +int32_t dnodeCheckTableExist(char *tableId); /* - * Create table with specified configuration and open it + * Create noraml table with specified configuration and open it */ -int32_t dnodeCreateTable(int vid, int sid, SCreateMsg *table); +int32_t dnodeCreateNormalTable(SCreateNormalTableMsg *table); /* - * Modify table configuration information + * Create stream table with specified configuration and open it */ -int32_t dnodeAlterTable(int vid, SMeterObj *table); +int32_t dnodeCreateStreamTable(SCreateStreamTableMsg *table); /* - * Remove table from local repository + * Create child table with specified configuration and open it */ -int32_t dnodeDropTable(int vid, int sid, int64_t uid); +int32_t dnodeCreateChildTable(SCreateChildTableMsg *table); /* - * Write data based on dnode + * Modify normal table configuration information + * */ -int32_t dnodeWriteData(SShellSubmitMsg *msg); +int32_t dnodeAlterNormalTable(SCreateNormalTableMsg *table); +/* + * Modify stream table configuration information + */ +int32_t dnodeAlterStreamTable(SCreateStreamTableMsg *table); + +/* + * Modify child table configuration information + */ +int32_t dnodeAlterChildTable(SCreateChildTableMsg *table); + +/* + * Remove all child tables of supertable from local repository + */ +int32_t dnodeDropSuperTable(int vid, int sid, int64_t uid); + +/* + * Remove table from local repository + */ +int32_t dnodeDropTable(int vid, int sid, int64_t uid); #ifdef __cplusplus } diff --git a/src/dnode/src/dnodeWrite.c b/src/dnode/src/dnodeWrite.c index d3c4e1a4de..4d51faa334 100644 --- a/src/dnode/src/dnodeWrite.c +++ b/src/dnode/src/dnodeWrite.c @@ -16,6 +16,45 @@ #define _DEFAULT_SOURCE #include "dnodeWrite.h" -int32_t dnodeCreateTable(int vid, int sid, SCreateTableMsg *table) { +#include "taoserror.h" +int32_t dnodeCheckTableExist(char *tableId) { + return 0; } + +int32_t dnodeWriteData(SShellSubmitMsg *msg) { + return 0; +} + +int32_t dnodeCreateNormalTable(SCreateNormalTableMsg *table); { + return 0; +} + +int32_t dnodeCreateStreamTable(SCreateStreamTableMsg *table) { + return 0; +} + +int32_t dnodeCreateChildTable(SCreateChildTableMsg *table) { + return 0; +} + +int32_t dnodeAlterNormalTable(SCreateNormalTableMsg *table) { + return 0; +} + +int32_t dnodeAlterStreamTable(SCreateStreamTableMsg *table) { + return 0; +} + +int32_t dnodeAlterChildTable(SCreateChildTableMsg *table) { + return 0; +} + +int32_t dnodeDropSuperTable(int vid, int sid, int64_t uid) { + return 0; +} + +int32_t dnodeDropTable(int vid, int sid, int64_t uid) { + return 0; +} + -- GitLab