cmdnodes.h 9.0 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
/*
 * 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/>.
 */

16 17
#ifndef _TD_CMD_NODES_H_
#define _TD_CMD_NODES_H_
18 19 20 21 22

#ifdef __cplusplus
extern "C" {
#endif

23
#include "query.h"
X
Xiaoyu Wang 已提交
24
#include "querynodes.h"
25

X
Xiaoyu Wang 已提交
26
#define DESCRIBE_RESULT_COLS      4
27
#define DESCRIBE_RESULT_FIELD_LEN (TSDB_COL_NAME_LEN - 1 + VARSTR_HEADER_SIZE)
X
Xiaoyu Wang 已提交
28 29
#define DESCRIBE_RESULT_TYPE_LEN  (20 + VARSTR_HEADER_SIZE)
#define DESCRIBE_RESULT_NOTE_LEN  (8 + VARSTR_HEADER_SIZE)
30

X
Xiaoyu Wang 已提交
31 32 33 34 35 36 37 38
#define PRIVILEGE_TYPE_MASK(n) (1 << n)

#define PRIVILEGE_TYPE_ALL   PRIVILEGE_TYPE_MASK(0)
#define PRIVILEGE_TYPE_READ  PRIVILEGE_TYPE_MASK(1)
#define PRIVILEGE_TYPE_WRITE PRIVILEGE_TYPE_MASK(2)

#define PRIVILEGE_TYPE_TEST_MASK(val, mask) (((val) & (mask)) != 0)

39
typedef struct SDatabaseOptions {
X
Xiaoyu Wang 已提交
40 41 42 43 44
  ENodeType   type;
  int32_t     buffer;
  int8_t      cachelast;
  int8_t      compressionLevel;
  int32_t     daysPerFile;
X
Xiaoyu Wang 已提交
45
  SValueNode* pDaysPerFile;
X
Xiaoyu Wang 已提交
46 47 48 49
  int32_t     fsyncPeriod;
  int32_t     maxRowsPerBlock;
  int32_t     minRowsPerBlock;
  SNodeList*  pKeep;
X
Xiaoyu Wang 已提交
50
  int64_t     keep[3];
X
Xiaoyu Wang 已提交
51 52 53 54 55 56 57 58 59 60
  int32_t     pages;
  int32_t     pagesize;
  char        precisionStr[3];
  int8_t      precision;
  int8_t      replica;
  int8_t      strict;
  int8_t      walLevel;
  int32_t     numOfVgroups;
  int8_t      singleStable;
  SNodeList*  pRetentions;
X
Xiaoyu Wang 已提交
61
  int8_t      schemaless;
62
} SDatabaseOptions;
63

64
typedef struct SCreateDatabaseStmt {
X
Xiaoyu Wang 已提交
65 66 67
  ENodeType         type;
  char              dbName[TSDB_DB_NAME_LEN];
  bool              ignoreExists;
X
Xiaoyu Wang 已提交
68
  SDatabaseOptions* pOptions;
69
} SCreateDatabaseStmt;
70

71 72
typedef struct SUseDatabaseStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
73
  char      dbName[TSDB_DB_NAME_LEN];
74 75
} SUseDatabaseStmt;

76 77
typedef struct SDropDatabaseStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
78 79
  char      dbName[TSDB_DB_NAME_LEN];
  bool      ignoreNotExists;
80 81
} SDropDatabaseStmt;

82
typedef struct SAlterDatabaseStmt {
X
Xiaoyu Wang 已提交
83 84
  ENodeType         type;
  char              dbName[TSDB_DB_NAME_LEN];
85 86 87
  SDatabaseOptions* pOptions;
} SAlterDatabaseStmt;

X
Xiaoyu Wang 已提交
88
typedef struct STableOptions {
X
Xiaoyu Wang 已提交
89
  ENodeType  type;
90
  char       comment[TSDB_TB_COMMENT_LEN];
5
54liuyao 已提交
91
  double     filesFactor;
X
Xiaoyu Wang 已提交
92 93
  SNodeList* pRollupFuncs;
  int32_t    ttl;
94
  SNodeList* pSma;
X
Xiaoyu Wang 已提交
95 96 97 98
} STableOptions;

typedef struct SColumnDefNode {
  ENodeType type;
X
Xiaoyu Wang 已提交
99
  char      colName[TSDB_COL_NAME_LEN];
X
Xiaoyu Wang 已提交
100
  SDataType dataType;
101
  char      comments[TSDB_TB_COMMENT_LEN];
X
Xiaoyu Wang 已提交
102
  bool      sma;
X
Xiaoyu Wang 已提交
103 104 105
} SColumnDefNode;

typedef struct SCreateTableStmt {
X
Xiaoyu Wang 已提交
106 107 108 109 110 111
  ENodeType      type;
  char           dbName[TSDB_DB_NAME_LEN];
  char           tableName[TSDB_TABLE_NAME_LEN];
  bool           ignoreExists;
  SNodeList*     pCols;
  SNodeList*     pTags;
X
Xiaoyu Wang 已提交
112
  STableOptions* pOptions;
X
Xiaoyu Wang 已提交
113 114
} SCreateTableStmt;

115
typedef struct SCreateSubTableClause {
X
Xiaoyu Wang 已提交
116 117 118 119 120 121
  ENodeType  type;
  char       dbName[TSDB_DB_NAME_LEN];
  char       tableName[TSDB_TABLE_NAME_LEN];
  char       useDbName[TSDB_DB_NAME_LEN];
  char       useTableName[TSDB_TABLE_NAME_LEN];
  bool       ignoreExists;
122 123
  SNodeList* pSpecificTags;
  SNodeList* pValsOfTags;
124
} SCreateSubTableClause;
125 126

typedef struct SCreateMultiTableStmt {
X
Xiaoyu Wang 已提交
127
  ENodeType  type;
128 129
  SNodeList* pSubTables;
} SCreateMultiTableStmt;
X
Xiaoyu Wang 已提交
130

131 132
typedef struct SDropTableClause {
  ENodeType type;
X
Xiaoyu Wang 已提交
133 134 135
  char      dbName[TSDB_DB_NAME_LEN];
  char      tableName[TSDB_TABLE_NAME_LEN];
  bool      ignoreNotExists;
136 137 138
} SDropTableClause;

typedef struct SDropTableStmt {
X
Xiaoyu Wang 已提交
139
  ENodeType  type;
140 141 142
  SNodeList* pTables;
} SDropTableStmt;

143 144
typedef struct SDropSuperTableStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
145 146 147
  char      dbName[TSDB_DB_NAME_LEN];
  char      tableName[TSDB_TABLE_NAME_LEN];
  bool      ignoreNotExists;
148 149
} SDropSuperTableStmt;

150
typedef struct SAlterTableStmt {
X
Xiaoyu Wang 已提交
151 152 153 154 155 156
  ENodeType      type;
  char           dbName[TSDB_DB_NAME_LEN];
  char           tableName[TSDB_TABLE_NAME_LEN];
  int8_t         alterType;
  char           colName[TSDB_COL_NAME_LEN];
  char           newColName[TSDB_COL_NAME_LEN];
157
  STableOptions* pOptions;
X
Xiaoyu Wang 已提交
158 159
  SDataType      dataType;
  SValueNode*    pVal;
160 161
} SAlterTableStmt;

162 163
typedef struct SCreateUserStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
164 165
  char      useName[TSDB_USER_LEN];
  char      password[TSDB_USET_PASSWORD_LEN];
166 167 168 169
} SCreateUserStmt;

typedef struct SAlterUserStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
170 171 172
  char      useName[TSDB_USER_LEN];
  char      password[TSDB_USET_PASSWORD_LEN];
  int8_t    alterType;
173 174 175 176
} SAlterUserStmt;

typedef struct SDropUserStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
177
  char      useName[TSDB_USER_LEN];
178 179 180 181
} SDropUserStmt;

typedef struct SCreateDnodeStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
182 183
  char      fqdn[TSDB_FQDN_LEN];
  int32_t   port;
184 185 186 187
} SCreateDnodeStmt;

typedef struct SDropDnodeStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
188 189 190
  int32_t   dnodeId;
  char      fqdn[TSDB_FQDN_LEN];
  int32_t   port;
191 192
} SDropDnodeStmt;

193 194
typedef struct SAlterDnodeStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
195 196 197
  int32_t   dnodeId;
  char      config[TSDB_DNODE_CONFIG_LEN];
  char      value[TSDB_DNODE_VALUE_LEN];
198 199
} SAlterDnodeStmt;

200 201
typedef struct SShowStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
202 203
  SNode*    pDbName;         // SValueNode
  SNode*    pTbNamePattern;  // SValueNode
204 205
} SShowStmt;

206 207
typedef struct SShowCreatStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
208 209
  char      dbName[TSDB_DB_NAME_LEN];
  char      tableName[TSDB_TABLE_NAME_LEN];
210 211
} SShowCreatStmt;

X
Xiaoyu Wang 已提交
212
typedef enum EIndexType { INDEX_TYPE_SMA = 1, INDEX_TYPE_FULLTEXT } EIndexType;
X
Xiaoyu Wang 已提交
213 214

typedef struct SIndexOptions {
X
Xiaoyu Wang 已提交
215
  ENodeType  type;
X
Xiaoyu Wang 已提交
216
  SNodeList* pFuncs;
X
Xiaoyu Wang 已提交
217 218 219
  SNode*     pInterval;
  SNode*     pOffset;
  SNode*     pSliding;
X
Xiaoyu Wang 已提交
220 221 222
} SIndexOptions;

typedef struct SCreateIndexStmt {
X
Xiaoyu Wang 已提交
223 224 225 226 227 228
  ENodeType      type;
  EIndexType     indexType;
  bool           ignoreExists;
  char           indexName[TSDB_INDEX_NAME_LEN];
  char           tableName[TSDB_TABLE_NAME_LEN];
  SNodeList*     pCols;
X
Xiaoyu Wang 已提交
229 230 231
  SIndexOptions* pOptions;
} SCreateIndexStmt;

232 233
typedef struct SDropIndexStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
234 235 236
  bool      ignoreNotExists;
  char      indexName[TSDB_INDEX_NAME_LEN];
  char      tableName[TSDB_TABLE_NAME_LEN];
237 238
} SDropIndexStmt;

239
typedef struct SCreateComponentNodeStmt {
X
Xiaoyu Wang 已提交
240
  ENodeType type;
X
Xiaoyu Wang 已提交
241
  int32_t   dnodeId;
242
} SCreateComponentNodeStmt;
X
Xiaoyu Wang 已提交
243

244
typedef struct SDropComponentNodeStmt {
245
  ENodeType type;
X
Xiaoyu Wang 已提交
246
  int32_t   dnodeId;
247
} SDropComponentNodeStmt;
248 249

typedef struct SCreateTopicStmt {
250 251 252 253 254 255
  ENodeType type;
  char      topicName[TSDB_TABLE_NAME_LEN];
  char      subDbName[TSDB_DB_NAME_LEN];
  char      subSTbName[TSDB_TABLE_NAME_LEN];
  bool      ignoreExists;
  SNode*    pQuery;
256 257 258 259
} SCreateTopicStmt;

typedef struct SDropTopicStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
260 261
  char      topicName[TSDB_TABLE_NAME_LEN];
  bool      ignoreNotExists;
262 263
} SDropTopicStmt;

X
Xiaoyu Wang 已提交
264 265 266 267 268 269 270
typedef struct SDropCGroupStmt {
  ENodeType type;
  char      topicName[TSDB_TABLE_NAME_LEN];
  char      cgroup[TSDB_CGROUP_LEN];
  bool      ignoreNotExists;
} SDropCGroupStmt;

271 272
typedef struct SAlterLocalStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
273 274
  char      config[TSDB_DNODE_CONFIG_LEN];
  char      value[TSDB_DNODE_VALUE_LEN];
275 276
} SAlterLocalStmt;

277
typedef struct SDescribeStmt {
X
Xiaoyu Wang 已提交
278 279 280
  ENodeType   type;
  char        dbName[TSDB_DB_NAME_LEN];
  char        tableName[TSDB_TABLE_NAME_LEN];
281 282 283
  STableMeta* pMeta;
} SDescribeStmt;

284 285
typedef struct SKillStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
286
  int32_t   targetId;
287 288
} SKillStmt;

289 290
typedef struct SStreamOptions {
  ENodeType type;
X
Xiaoyu Wang 已提交
291
  int8_t    triggerType;
292
  SNode*    pDelay;
X
Xiaoyu Wang 已提交
293
  SNode*    pWatermark;
294 295 296
} SStreamOptions;

typedef struct SCreateStreamStmt {
X
Xiaoyu Wang 已提交
297 298 299 300 301
  ENodeType       type;
  char            streamName[TSDB_TABLE_NAME_LEN];
  char            targetDbName[TSDB_DB_NAME_LEN];
  char            targetTabName[TSDB_TABLE_NAME_LEN];
  bool            ignoreExists;
302
  SStreamOptions* pOptions;
X
Xiaoyu Wang 已提交
303
  SNode*          pQuery;
304 305 306 307
} SCreateStreamStmt;

typedef struct SDropStreamStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
308 309
  char      streamName[TSDB_TABLE_NAME_LEN];
  bool      ignoreNotExists;
310 311
} SDropStreamStmt;

312 313
typedef struct SCreateFunctionStmt {
  ENodeType type;
X
Xiaoyu Wang 已提交
314 315 316 317
  bool      ignoreExists;
  char      funcName[TSDB_FUNC_NAME_LEN];
  bool      isAgg;
  char      libraryPath[PATH_MAX];
318
  SDataType outputDt;
X
Xiaoyu Wang 已提交
319
  int32_t   bufSize;
320 321
} SCreateFunctionStmt;

322 323 324 325 326 327 328 329 330 331 332 333 334 335 336
typedef struct SDropFunctionStmt {
  ENodeType type;
  char      funcName[TSDB_FUNC_NAME_LEN];
  bool      ignoreNotExists;
} SDropFunctionStmt;

typedef struct SGrantStmt {
  ENodeType type;
  char      userName[TSDB_USER_LEN];
  char      dbName[TSDB_DB_NAME_LEN];
  int64_t   privileges;
} SGrantStmt;

typedef SGrantStmt SRevokeStmt;

X
Xiaoyu Wang 已提交
337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360
typedef struct SBalanceVgroupStmt {
  ENodeType type;
} SBalanceVgroupStmt;

typedef struct SMergeVgroupStmt {
  ENodeType type;
  int32_t   vgId1;
  int32_t   vgId2;
} SMergeVgroupStmt;

typedef struct SRedistributeVgroupStmt {
  ENodeType  type;
  int32_t    vgId;
  int32_t    dnodeId1;
  int32_t    dnodeId2;
  int32_t    dnodeId3;
  SNodeList* pDnodes;
} SRedistributeVgroupStmt;

typedef struct SSplitVgroupStmt {
  ENodeType type;
  int32_t   vgId;
} SSplitVgroupStmt;

361 362 363 364
#ifdef __cplusplus
}
#endif

365
#endif /*_TD_CMD_NODES_H_*/