qSqlparser.h 10.3 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/>.
 */

H
hjxilinx 已提交
16 17
#ifndef TDENGINE_QSQLPARSER_H
#define TDENGINE_QSQLPARSER_H
18 19 20 21 22 23 24 25

#ifdef __cplusplus
extern "C" {
#endif

#include "taos.h"
#include "taosmsg.h"
#include "tstoken.h"
H
Haojun Liao 已提交
26
#include "tstrbuild.h"
27 28
#include "tvariant.h"

H
Haojun Liao 已提交
29
#define ParseTOKENTYPE SStrToken
30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55
extern char tTokenTypeSwitcher[13];

#define toTSDBType(x)                          \
  do {                                         \
    if ((x) >= tListLen(tTokenTypeSwitcher)) { \
      (x) = TSDB_DATA_TYPE_BINARY;             \
    } else {                                   \
      (x) = tTokenTypeSwitcher[(x)];           \
    }                                          \
  } while (0)

typedef struct SLimitVal {
  int64_t limit;
  int64_t offset;
} SLimitVal;

typedef struct SOrderVal {
  uint32_t order;
  int32_t orderColId;
} SOrderVal;

typedef struct tVariantListItem {
  tVariant pVar;
  uint8_t  sortOrder;
} tVariantListItem;

56 57 58 59 60
typedef struct SIntervalVal {
  SStrToken interval;
  SStrToken offset;
} SIntervalVal;

61 62
typedef struct SQuerySQL {
  struct tSQLExprList *pSelection;   // select clause
H
Haojun Liao 已提交
63
  SArray *             from;         // from clause  SArray<tVariantListItem>
64
  struct tSQLExpr *    pWhere;       // where clause [optional]
H
Haojun Liao 已提交
65 66
  SArray *             pGroupby;     // groupby clause, only for tags[optional], SArray<tVariantListItem>
  SArray *             pSortOrder;   // orderby [optional], SArray<tVariantListItem>
H
Haojun Liao 已提交
67
  SStrToken            interval;     // interval [optional]
68
  SStrToken            offset;       // offset window [optional]
H
Haojun Liao 已提交
69
  SStrToken            sliding;      // sliding window [optional]
70 71
  SLimitVal            limit;        // limit offset [optional]
  SLimitVal            slimit;       // group limit offset [optional]
H
Haojun Liao 已提交
72
  SArray *             fillType;     // fill type[optional], SArray<tVariantListItem>
H
Haojun Liao 已提交
73
  SStrToken            selectToken;  // sql string
74 75
} SQuerySQL;

76 77 78
typedef struct SCreatedTableInfo {
  SStrToken  name;        // table name token
  SStrToken  stableName;  // super table name token , for using clause
79
  SArray    *pTagNames;   // create by using super table, tag name
80 81 82 83 84 85
  SArray    *pTagVals;    // create by using super table, tag value
  char      *fullname;    // table full name
  STagData   tagdata;     // true tag data, super table full name is in STagData
  int8_t     igExist;     // ignore if exists
} SCreatedTableInfo;

86
typedef struct SCreateTableSQL {
87 88 89 90
  SStrToken    name;  // table name, create table [name] xxx
  int8_t       type;  // create normal table/from super table/ stream
  bool         existCheck;

91
  struct {
92 93
    SArray    *pTagColumns; // SArray<TAOS_FIELD>
    SArray    *pColumns;    // SArray<TAOS_FIELD>
94
  } colInfo;
95 96 97

  SArray      *childTableInfo;        // SArray<SCreatedTableInfo>
  SQuerySQL   *pSelect;
98 99
} SCreateTableSQL;

H
Haojun Liao 已提交
100
typedef struct SAlterTableInfo {
H
Haojun Liao 已提交
101
  SStrToken     name;
D
dapan1121 已提交
102
  int16_t       tableType;
103 104
  int16_t       type;
  STagData      tagData;
H
Haojun Liao 已提交
105 106
  SArray       *pAddColumns; // SArray<TAOS_FIELD>
  SArray       *varList;  // set t=val or: change src dst, SArray<tVariantListItem>
H
Haojun Liao 已提交
107
} SAlterTableInfo;
108

H
Haojun Liao 已提交
109
typedef struct SCreateDbInfo {
H
Haojun Liao 已提交
110
  SStrToken dbname;
111 112
  int32_t   replica;
  int32_t   cacheBlockSize;
H
hjxilinx 已提交
113 114
  int32_t   maxTablesPerVnode;
  int32_t   numOfBlocks;
115
  int32_t   daysPerFile;
H
hjxilinx 已提交
116 117
  int32_t   minRowsPerBlock;
  int32_t   maxRowsPerBlock;
陶建辉(Jeff)'s avatar
陶建辉(Jeff) 已提交
118
  int32_t   fsyncPeriod;
119
  int64_t   commitTime;
H
hjxilinx 已提交
120
  int32_t   walLevel;
121
  int32_t   quorum;
122
  int32_t   compressionLevel;
H
Haojun Liao 已提交
123
  SStrToken precision;
124
  bool      ignoreExists;
D
dapan1121 已提交
125 126
  int8_t    update;
  int8_t    cachelast; 
H
Haojun Liao 已提交
127
  SArray    *keep;
D
dapan1121 已提交
128 129
  int8_t    dbType;
  int16_t   partitions;
H
Haojun Liao 已提交
130
} SCreateDbInfo;
131

D
dapan1121 已提交
132 133 134 135 136 137
typedef struct SCreateFuncInfo {
  SStrToken name;
  SStrToken path;
} SCreateFuncInfo;


H
Haojun Liao 已提交
138
typedef struct SCreateAcctInfo {
139 140 141 142 143 144 145 146
  int32_t   maxUsers;
  int32_t   maxDbs;
  int32_t   maxTimeSeries;
  int32_t   maxStreams;
  int32_t   maxPointsPerSecond;
  int64_t   maxStorage;
  int64_t   maxQueryTime;
  int32_t   maxConnections;
H
Haojun Liao 已提交
147
  SStrToken stat;
H
Haojun Liao 已提交
148
} SCreateAcctInfo;
149 150 151

typedef struct SShowInfo {
  uint8_t showType;
H
Haojun Liao 已提交
152 153
  SStrToken prefix;
  SStrToken pattern;
154 155 156
} SShowInfo;

typedef struct SUserInfo {
H
Haojun Liao 已提交
157 158 159
  SStrToken user;
  SStrToken passwd;
  SStrToken privilege;
160 161 162
  int16_t   type;
} SUserInfo;

H
Haojun Liao 已提交
163 164 165
typedef struct SMiscInfo {
  SArray    *a;         // SArray<SStrToken>
  bool       existsCheck;
D
dapan1121 已提交
166
  int16_t    dbType;
D
dapan1121 已提交
167
  int16_t    tableType;
H
Haojun Liao 已提交
168
  SUserInfo  user;
169
  union {
H
Haojun Liao 已提交
170 171
    SCreateDbInfo   dbOpt;
    SCreateAcctInfo acctOpt;
D
dapan1121 已提交
172
    SCreateFuncInfo funcOpt;
H
Haojun Liao 已提交
173 174
    SShowInfo       showOpt;
    SStrToken       id;
175
  };
H
Haojun Liao 已提交
176
} SMiscInfo;
177 178 179 180 181 182 183

typedef struct SSubclauseInfo {  // "UNION" multiple select sub-clause
  SQuerySQL **pClause;
  int32_t     numOfClause;
} SSubclauseInfo;

typedef struct SSqlInfo {
H
Haojun Liao 已提交
184 185
  int32_t            type;
  bool               valid;
H
Haojun Liao 已提交
186 187
  SSubclauseInfo     subclauseInfo;
  char               msg[256];
188
  union {
H
Haojun Liao 已提交
189 190 191
    SCreateTableSQL  *pCreateTableInfo;
    SAlterTableInfo  *pAlterInfo;
    SMiscInfo        *pMiscInfo;
192 193 194 195
  };
} SSqlInfo;

typedef struct tSQLExpr {
H
Haojun Liao 已提交
196
  uint32_t         nSQLOptr;    // TK_FUNCTION: sql function, TK_LE: less than(binary expr)
197 198 199
  
  // the full sql string of function(col, param), which is actually the raw
  // field name, since the function name is kept in nSQLOptr already
H
Haojun Liao 已提交
200 201 202 203 204
  SStrToken        operand;
  SStrToken        colInfo;     // field id
  tVariant         val;         // value only for string, float, int
  SStrToken        token;       // original sql expr string

H
[td-32]  
hjxilinx 已提交
205 206 207
  struct tSQLExpr *pLeft;       // left child
  struct tSQLExpr *pRight;      // right child
  struct tSQLExprList *pParam;  // function parameters
208 209 210
} tSQLExpr;

// used in select clause. select <tSQLExprList> from xxx
H
Haojun Liao 已提交
211
typedef struct tSqlExprItem {
212 213
  tSQLExpr *pNode;      // The list of expressions
  char *    aliasName;  // alias name, null-terminated string
dengyihao's avatar
TD-2571  
dengyihao 已提交
214
  bool      distinct;
H
Haojun Liao 已提交
215
} tSqlExprItem;
216

217
// todo refactor by using SArray
218 219 220
typedef struct tSQLExprList {
  int32_t       nExpr;  /* Number of expressions on the list */
  int32_t       nAlloc; /* Number of entries allocated below */
H
Haojun Liao 已提交
221
  tSqlExprItem *a;      /* One entry for each expression */
222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238
} tSQLExprList;

/**
 *
 * @param yyp      The parser
 * @param yymajor  The major token code number
 * @param yyminor  The value for the token
 */
void Parse(void *yyp, int yymajor, ParseTOKENTYPE yyminor, SSqlInfo *);

/**
 *
 * @param p         The parser to be deleted
 * @param freeProc  Function used to reclaim memory
 */
void ParseFree(void *p, void (*freeProc)(void *));

H
Haojun Liao 已提交
239 240 241
SArray *tVariantListAppend(SArray *pList, tVariant *pVar, uint8_t sortOrder);
SArray *tVariantListInsert(SArray *pList, tVariant *pVar, uint8_t sortOrder, int32_t index);
SArray *tVariantListAppendToken(SArray *pList, SStrToken *pAliasToken, uint8_t sortOrder);
242

H
Haojun Liao 已提交
243
tSQLExpr *tSqlExprCreate(tSQLExpr *pLeft, tSQLExpr *pRight, int32_t optrType);
244

D
dapan1121 已提交
245 246
tSQLExpr *tSqlExprClone(tSQLExpr *pSrc);

H
Haojun Liao 已提交
247
void tSqlExprDestroy(tSQLExpr *pExpr);
248

dengyihao's avatar
TD-2571  
dengyihao 已提交
249
tSQLExprList *tSqlExprListAppend(tSQLExprList *pList, tSQLExpr *pNode, SStrToken *pDistinct, SStrToken *pToken);
250

H
Haojun Liao 已提交
251
void tSqlExprListDestroy(tSQLExprList *pList);
252

H
Haojun Liao 已提交
253
SQuerySQL *tSetQuerySqlElems(SStrToken *pSelectToken, tSQLExprList *pSelection, SArray *pFrom, tSQLExpr *pWhere,
H
Haojun Liao 已提交
254 255
                             SArray *pGroupby, SArray *pSortOrder, SIntervalVal *pInterval,
                             SStrToken *pSliding, SArray *pFill, SLimitVal *pLimit, SLimitVal *pGLimit);
256

H
Haojun Liao 已提交
257
SCreateTableSQL *tSetCreateSqlElems(SArray *pCols, SArray *pTags, SQuerySQL *pSelect, int32_t type);
258

H
Haojun Liao 已提交
259
void tSqlExprNodeDestroy(tSQLExpr *pExpr);
260

H
Haojun Liao 已提交
261
SAlterTableInfo *  tAlterTableSqlElems(SStrToken *pTableName, SArray *pCols, SArray *pVals, int32_t type, int16_t tableTable);
262
SCreatedTableInfo createNewChildTableInfo(SStrToken *pTableName, SArray *pTagNames, SArray *pTagVals, SStrToken *pToken, SStrToken* igExists);
263 264 265

void destroyAllSelectClause(SSubclauseInfo *pSql);
void doDestroyQuerySql(SQuerySQL *pSql);
266
void freeCreateTableInfo(void* p);
267

H
Haojun Liao 已提交
268
SSqlInfo       *      setSqlInfo(SSqlInfo *pInfo, void *pSqlExprInfo, SStrToken *pTableName, int32_t type);
269 270 271 272
SSubclauseInfo *setSubclause(SSubclauseInfo *pClause, void *pSqlExprInfo);

SSubclauseInfo *appendSelectClause(SSubclauseInfo *pInfo, void *pSubclause);

273
void setCreatedTableName(SSqlInfo *pInfo, SStrToken *pTableNameToken, SStrToken *pIfNotExists);
274

H
Haojun Liao 已提交
275
void SqlInfoDestroy(SSqlInfo *pInfo);
276 277

void setDCLSQLElems(SSqlInfo *pInfo, int32_t type, int32_t nParams, ...);
D
dapan1121 已提交
278
void setDropDbTableInfo(SSqlInfo *pInfo, int32_t type, SStrToken* pToken, SStrToken* existsCheck,int16_t dbType,int16_t tableType);
H
Haojun Liao 已提交
279
void setShowOptions(SSqlInfo *pInfo, int32_t type, SStrToken* prefix, SStrToken* pPatterns);
280

H
Haojun Liao 已提交
281
void setCreateDbInfo(SSqlInfo *pInfo, int32_t type, SStrToken *pToken, SCreateDbInfo *pDB, SStrToken *pIgExists);
282

H
Haojun Liao 已提交
283
void setCreateAcctSql(SSqlInfo *pInfo, int32_t type, SStrToken *pName, SStrToken *pPwd, SCreateAcctInfo *pAcctInfo);
H
Haojun Liao 已提交
284 285 286
void setCreateUserSql(SSqlInfo *pInfo, SStrToken *pName, SStrToken *pPasswd);
void setKillSql(SSqlInfo *pInfo, int32_t type, SStrToken *ip);
void setAlterUserSql(SSqlInfo *pInfo, int16_t type, SStrToken *pName, SStrToken* pPwd, SStrToken *pPrivilege);
287

H
Haojun Liao 已提交
288
void setDefaultCreateDbOption(SCreateDbInfo *pDBInfo);
D
dapan1121 已提交
289
void setDefaultCreateTopicOption(SCreateDbInfo *pDBInfo);
290 291

// prefix show db.tables;
H
Haojun Liao 已提交
292
void setDbName(SStrToken *pCpxName, SStrToken *pDb);
293

H
Haojun Liao 已提交
294
tSQLExpr *tSqlExprIdValueCreate(SStrToken *pToken, int32_t optrType);
295

H
Haojun Liao 已提交
296
tSQLExpr *tSqlExprCreateFunction(tSQLExprList *pList, SStrToken *pFuncToken, SStrToken *endToken, int32_t optType);
297

H
Haojun Liao 已提交
298
void tSqlSetColumnInfo(TAOS_FIELD *pField, SStrToken *pName, TAOS_FIELD *pType);
299

H
Haojun Liao 已提交
300
void tSqlSetColumnType(TAOS_FIELD *pField, SStrToken *type);
301 302 303

void *ParseAlloc(void *(*mallocProc)(size_t));

304
enum {
H
[td-32]  
hjxilinx 已提交
305 306
  TSQL_NODE_TYPE_EXPR  = 0x1,
  TSQL_NODE_TYPE_ID    = 0x2,
307 308 309 310
  TSQL_NODE_TYPE_VALUE = 0x4,
};

#define NON_ARITHMEIC_EXPR 0
H
[td-32]  
hjxilinx 已提交
311 312
#define NORMAL_ARITHMETIC  1
#define AGG_ARIGHTMEIC     2
313

314
SSqlInfo qSQLParse(const char *str);
315

316 317 318 319
#ifdef __cplusplus
}
#endif

H
hjxilinx 已提交
320
#endif  // TDENGINE_QSQLPARSER_H