sql.y 34.4 KB
Newer Older
H
hzcheng 已提交
1 2 3 4
//lemon parser file to generate sql parse by using finite-state-machine code used to parse sql
//usage: lemon sql.y
%token_prefix TK_

H
Haojun Liao 已提交
5 6
%token_type {SStrToken}
%default_type {SStrToken}
H
hzcheng 已提交
7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28
%extra_argument {SSqlInfo* pInfo}

%fallback ID BOOL TINYINT SMALLINT INTEGER BIGINT FLOAT DOUBLE STRING TIMESTAMP BINARY NCHAR.

%left OR.
%left AND.
%right NOT.
%left EQ NE ISNULL NOTNULL IS LIKE GLOB BETWEEN IN.
%left GT GE LT LE.
%left BITAND BITOR LSHIFT RSHIFT.
%left PLUS MINUS.
%left DIVIDE TIMES.
%left STAR SLASH REM.
%left CONCAT.
%right UMINUS UPLUS BITNOT.

%include {
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <assert.h>
#include <stdbool.h>
H
Haojun Liao 已提交
29 30
#include "qSqlparser.h"
#include "tcmdtype.h"
H
Haojun Liao 已提交
31
#include "ttoken.h"
H
Haojun Liao 已提交
32
#include "ttokendef.h"
H
hzcheng 已提交
33
#include "tutil.h"
H
Haojun Liao 已提交
34
#include "tvariant.h"
H
hzcheng 已提交
35 36 37
}

%syntax_error {
38
  pInfo->valid = false;
H
Haojun Liao 已提交
39
  int32_t outputBufLen = tListLen(pInfo->msg);
H
hzcheng 已提交
40 41 42 43 44 45 46 47 48
  int32_t len = 0;

  if(TOKEN.z) {
    char msg[] = "syntax error near \"%s\"";
    int32_t sqlLen = strlen(&TOKEN.z[0]);

    if (sqlLen + sizeof(msg)/sizeof(msg[0]) + 1 > outputBufLen) {
        char tmpstr[128] = {0};
        memcpy(tmpstr, &TOKEN.z[0], sizeof(tmpstr)/sizeof(tmpstr[0]) - 1);
H
Haojun Liao 已提交
49
        len = sprintf(pInfo->msg, msg, tmpstr);
H
hzcheng 已提交
50
    } else {
H
Haojun Liao 已提交
51
        len = sprintf(pInfo->msg, msg, &TOKEN.z[0]);
H
hzcheng 已提交
52 53 54
    }

  } else {
H
Haojun Liao 已提交
55
    len = sprintf(pInfo->msg, "Incomplete SQL statement");
H
hzcheng 已提交
56 57 58 59 60 61 62 63 64 65
  }

  assert(len <= outputBufLen);
}

%parse_accept       {}

program ::= cmd.    {}

//////////////////////////////////THE SHOW STATEMENT///////////////////////////////////////////
66
cmd ::= SHOW DATABASES.  { setShowOptions(pInfo, TSDB_MGMT_TABLE_DB, 0, 0);}
D
fix bug  
dapan1121 已提交
67
cmd ::= SHOW TOPICS.     { setShowOptions(pInfo, TSDB_MGMT_TABLE_TP, 0, 0);}
68 69 70 71 72 73 74 75 76
cmd ::= SHOW MNODES.     { setShowOptions(pInfo, TSDB_MGMT_TABLE_MNODE, 0, 0);}
cmd ::= SHOW DNODES.     { setShowOptions(pInfo, TSDB_MGMT_TABLE_DNODE, 0, 0);}
cmd ::= SHOW ACCOUNTS.   { setShowOptions(pInfo, TSDB_MGMT_TABLE_ACCT, 0, 0);}
cmd ::= SHOW USERS.      { setShowOptions(pInfo, TSDB_MGMT_TABLE_USER, 0, 0);}

cmd ::= SHOW MODULES.    { setShowOptions(pInfo, TSDB_MGMT_TABLE_MODULE, 0, 0);  }
cmd ::= SHOW QUERIES.    { setShowOptions(pInfo, TSDB_MGMT_TABLE_QUERIES, 0, 0);  }
cmd ::= SHOW CONNECTIONS.{ setShowOptions(pInfo, TSDB_MGMT_TABLE_CONNS, 0, 0);}
cmd ::= SHOW STREAMS.    { setShowOptions(pInfo, TSDB_MGMT_TABLE_STREAMS, 0, 0);  }
H
Haojun Liao 已提交
77
cmd ::= SHOW VARIABLES.  { setShowOptions(pInfo, TSDB_MGMT_TABLE_VARIABLES, 0, 0);  }
78 79 80 81 82
cmd ::= SHOW SCORES.     { setShowOptions(pInfo, TSDB_MGMT_TABLE_SCORES, 0, 0);   }
cmd ::= SHOW GRANTS.     { setShowOptions(pInfo, TSDB_MGMT_TABLE_GRANTS, 0, 0);   }

cmd ::= SHOW VNODES.                { setShowOptions(pInfo, TSDB_MGMT_TABLE_VNODES, 0, 0); }
cmd ::= SHOW VNODES IPTOKEN(X).     { setShowOptions(pInfo, TSDB_MGMT_TABLE_VNODES, &X, 0); }
L
lihui 已提交
83

84

H
Haojun Liao 已提交
85
%type dbPrefix {SStrToken}
86
dbPrefix(A) ::=.                   {A.n = 0; A.type = 0;}
H
hzcheng 已提交
87 88
dbPrefix(A) ::= ids(X) DOT.        {A = X;  }

H
Haojun Liao 已提交
89
%type cpxName {SStrToken}
H
hzcheng 已提交
90 91 92
cpxName(A) ::= .             {A.n = 0;  }
cpxName(A) ::= DOT ids(Y).   {A = Y; A.n += 1;    }

93 94
cmd ::= SHOW CREATE TABLE ids(X) cpxName(Y).    {
   X.n += Y.n;
H
Haojun Liao 已提交
95
   setDCLSqlElems(pInfo, TSDB_SQL_SHOW_CREATE_TABLE, 1, &X);
96
}    
97 98 99 100
cmd ::= SHOW CREATE STABLE ids(X) cpxName(Y).    {
   X.n += Y.n;
   setDCLSqlElems(pInfo, TSDB_SQL_SHOW_CREATE_STABLE, 1, &X);
}    
101 102

cmd ::= SHOW CREATE DATABASE ids(X). {
H
Haojun Liao 已提交
103
  setDCLSqlElems(pInfo, TSDB_SQL_SHOW_CREATE_DATABASE, 1, &X);
104 105
} 

H
hzcheng 已提交
106
cmd ::= SHOW dbPrefix(X) TABLES.         {
107
    setShowOptions(pInfo, TSDB_MGMT_TABLE_TABLE, &X, 0);
H
hzcheng 已提交
108 109 110
}

cmd ::= SHOW dbPrefix(X) TABLES LIKE ids(Y).         {
111
    setShowOptions(pInfo, TSDB_MGMT_TABLE_TABLE, &X, &Y);
H
hzcheng 已提交
112 113 114
}

cmd ::= SHOW dbPrefix(X) STABLES.      {
115
    setShowOptions(pInfo, TSDB_MGMT_TABLE_METRIC, &X, 0);
H
hzcheng 已提交
116 117 118
}

cmd ::= SHOW dbPrefix(X) STABLES LIKE ids(Y).      {
H
Haojun Liao 已提交
119
    SStrToken token;
H
Haojun Liao 已提交
120
    tSetDbName(&token, &X);
121
    setShowOptions(pInfo, TSDB_MGMT_TABLE_METRIC, &token, &Y);
H
hzcheng 已提交
122 123 124
}

cmd ::= SHOW dbPrefix(X) VGROUPS.    {
H
Haojun Liao 已提交
125
    SStrToken token;
H
Haojun Liao 已提交
126
    tSetDbName(&token, &X);
127
    setShowOptions(pInfo, TSDB_MGMT_TABLE_VGROUP, &token, 0);
H
hzcheng 已提交
128 129
}

L
[1361]  
lihui 已提交
130
cmd ::= SHOW dbPrefix(X) VGROUPS ids(Y).    {
H
Haojun Liao 已提交
131
    SStrToken token;
H
Haojun Liao 已提交
132
    tSetDbName(&token, &X);
H
hjxilinx 已提交
133
    setShowOptions(pInfo, TSDB_MGMT_TABLE_VGROUP, &token, &Y);
L
[1361]  
lihui 已提交
134 135
}

H
hzcheng 已提交
136 137 138
//drop configure for tables
cmd ::= DROP TABLE ifexists(Y) ids(X) cpxName(Z).   {
    X.n += Z.n;
D
fix bug  
dapan1121 已提交
139
    setDropDbTableInfo(pInfo, TSDB_SQL_DROP_TABLE, &X, &Y, -1, -1);
H
hzcheng 已提交
140 141
}

D
dapan1121 已提交
142 143 144
//drop stable
cmd ::= DROP STABLE ifexists(Y) ids(X) cpxName(Z).   {
    X.n += Z.n;
D
fix bug  
dapan1121 已提交
145
    setDropDbTableInfo(pInfo, TSDB_SQL_DROP_TABLE, &X, &Y, -1, TSDB_SUPER_TABLE);
D
dapan1121 已提交
146 147
}

D
fix bug  
dapan1121 已提交
148 149 150
cmd ::= DROP DATABASE ifexists(Y) ids(X).    { setDropDbTableInfo(pInfo, TSDB_SQL_DROP_DB, &X, &Y, TSDB_DB_TYPE_DEFAULT, -1); }
cmd ::= DROP TOPIC ifexists(Y) ids(X).    { setDropDbTableInfo(pInfo, TSDB_SQL_DROP_DB, &X, &Y, TSDB_DB_TYPE_TOPIC, -1); }

H
Haojun Liao 已提交
151 152 153
cmd ::= DROP DNODE ids(X).       { setDCLSqlElems(pInfo, TSDB_SQL_DROP_DNODE, 1, &X);    }
cmd ::= DROP USER ids(X).        { setDCLSqlElems(pInfo, TSDB_SQL_DROP_USER, 1, &X);     }
cmd ::= DROP ACCOUNT ids(X).     { setDCLSqlElems(pInfo, TSDB_SQL_DROP_ACCT, 1, &X);  }
H
hzcheng 已提交
154 155

/////////////////////////////////THE USE STATEMENT//////////////////////////////////////////
H
Haojun Liao 已提交
156
cmd ::= USE ids(X).              { setDCLSqlElems(pInfo, TSDB_SQL_USE_DB, 1, &X);}
H
hzcheng 已提交
157 158 159 160

/////////////////////////////////THE DESCRIBE STATEMENT/////////////////////////////////////
cmd ::= DESCRIBE ids(X) cpxName(Y). {
    X.n += Y.n;
H
Haojun Liao 已提交
161
    setDCLSqlElems(pInfo, TSDB_SQL_DESCRIBE_TABLE, 1, &X);
H
hzcheng 已提交
162 163 164
}

/////////////////////////////////THE ALTER STATEMENT////////////////////////////////////////
D
dapan1121 已提交
165 166
cmd ::= ALTER USER ids(X) PASS ids(Y).          { setAlterUserSql(pInfo, TSDB_ALTER_USER_PASSWD, &X, &Y, NULL);    }
cmd ::= ALTER USER ids(X) PRIVILEGE ids(Y).     { setAlterUserSql(pInfo, TSDB_ALTER_USER_PRIVILEGES, &X, NULL, &Y);}
H
Haojun Liao 已提交
167 168 169 170
cmd ::= ALTER DNODE ids(X) ids(Y).              { setDCLSqlElems(pInfo, TSDB_SQL_CFG_DNODE, 2, &X, &Y);          }
cmd ::= ALTER DNODE ids(X) ids(Y) ids(Z).       { setDCLSqlElems(pInfo, TSDB_SQL_CFG_DNODE, 3, &X, &Y, &Z);      }
cmd ::= ALTER LOCAL ids(X).                     { setDCLSqlElems(pInfo, TSDB_SQL_CFG_LOCAL, 1, &X);              }
cmd ::= ALTER LOCAL ids(X) ids(Y).              { setDCLSqlElems(pInfo, TSDB_SQL_CFG_LOCAL, 2, &X, &Y);          }
H
Haojun Liao 已提交
171
cmd ::= ALTER DATABASE ids(X) alter_db_optr(Y). { SStrToken t = {0};  setCreateDbInfo(pInfo, TSDB_SQL_ALTER_DB, &X, &Y, &t);}
D
fix bug  
dapan1121 已提交
172
cmd ::= ALTER TOPIC ids(X) alter_topic_optr(Y). { SStrToken t = {0};  setCreateDbInfo(pInfo, TSDB_SQL_ALTER_DB, &X, &Y, &t);}
H
hzcheng 已提交
173

D
dapan1121 已提交
174 175
cmd ::= ALTER ACCOUNT ids(X) acct_optr(Z).      { setCreateAcctSql(pInfo, TSDB_SQL_ALTER_ACCT, &X, NULL, &Z);}
cmd ::= ALTER ACCOUNT ids(X) PASS ids(Y) acct_optr(Z).      { setCreateAcctSql(pInfo, TSDB_SQL_ALTER_ACCT, &X, &Y, &Z);}
S
slguan 已提交
176

H
hzcheng 已提交
177 178 179
// An IDENTIFIER can be a generic identifier, or one of several keywords.
// Any non-standard keyword can also be an identifier.
// And "ids" is an identifer-or-string.
H
Haojun Liao 已提交
180
%type ids {SStrToken}
H
hzcheng 已提交
181 182 183
ids(A) ::= ID(X).        {A = X; }
ids(A) ::= STRING(X).    {A = X; }

H
Haojun Liao 已提交
184
%type ifexists {SStrToken}
185 186
ifexists(X) ::= IF EXISTS.          { X.n = 1;}
ifexists(X) ::= .                   { X.n = 0;}
H
hzcheng 已提交
187

H
Haojun Liao 已提交
188
%type ifnotexists {SStrToken}
189 190
ifnotexists(X) ::= IF NOT EXISTS.   { X.n = 1;}
ifnotexists(X) ::= .                { X.n = 0;}
H
hzcheng 已提交
191 192

/////////////////////////////////THE CREATE STATEMENT///////////////////////////////////////
S
slguan 已提交
193
//create option for dnode/db/user/account
H
Haojun Liao 已提交
194
cmd ::= CREATE DNODE   ids(X).     { setDCLSqlElems(pInfo, TSDB_SQL_CREATE_DNODE, 1, &X);}
S
slguan 已提交
195
cmd ::= CREATE ACCOUNT ids(X) PASS ids(Y) acct_optr(Z).
D
dapan1121 已提交
196
                                { setCreateAcctSql(pInfo, TSDB_SQL_CREATE_ACCT, &X, &Y, &Z);}
H
Haojun Liao 已提交
197
cmd ::= CREATE DATABASE ifnotexists(Z) ids(X) db_optr(Y).  { setCreateDbInfo(pInfo, TSDB_SQL_CREATE_DB, &X, &Y, &Z);}
D
fix bug  
dapan1121 已提交
198
cmd ::= CREATE TOPIC ifnotexists(Z) ids(X) topic_optr(Y).  { setCreateDbInfo(pInfo, TSDB_SQL_CREATE_DB, &X, &Y, &Z);}
D
dapan1121 已提交
199
cmd ::= CREATE USER ids(X) PASS ids(Y).     { setCreateUserSql(pInfo, &X, &Y);}
H
hzcheng 已提交
200

201 202
pps(Y) ::= .                                { Y.n = 0;   }
pps(Y) ::= PPS INTEGER(X).                  { Y = X;     }
S
slguan 已提交
203

204 205
tseries(Y) ::= .                            { Y.n = 0;   }
tseries(Y) ::= TSERIES INTEGER(X).          { Y = X;     }
S
slguan 已提交
206

207 208
dbs(Y) ::= .                                { Y.n = 0;   }
dbs(Y) ::= DBS INTEGER(X).                  { Y = X;     }
S
slguan 已提交
209

210 211
streams(Y) ::= .                            { Y.n = 0;   }
streams(Y) ::= STREAMS INTEGER(X).          { Y = X;     }
S
slguan 已提交
212

213 214
storage(Y) ::= .                            { Y.n = 0;   }
storage(Y) ::= STORAGE INTEGER(X).          { Y = X;     }
S
slguan 已提交
215

216 217
qtime(Y) ::= .                              { Y.n = 0;   }
qtime(Y) ::= QTIME INTEGER(X).              { Y = X;     }
S
slguan 已提交
218

219 220
users(Y) ::= .                              { Y.n = 0;   }
users(Y) ::= USERS INTEGER(X).              { Y = X;     }
S
slguan 已提交
221

222 223
conns(Y) ::= .                              { Y.n = 0;   }
conns(Y) ::= CONNS INTEGER(X).              { Y = X;     }
S
slguan 已提交
224

225 226
state(Y) ::= .                              { Y.n = 0;   }
state(Y) ::= STATE ids(X).                  { Y = X;     }
S
slguan 已提交
227

H
Haojun Liao 已提交
228
%type acct_optr {SCreateAcctInfo}
S
slguan 已提交
229
acct_optr(Y) ::= pps(C) tseries(D) storage(P) streams(F) qtime(Q) dbs(E) users(K) conns(L) state(M). {
230 231 232 233 234 235 236 237
    Y.maxUsers   = (K.n>0)?atoi(K.z):-1;
    Y.maxDbs     = (E.n>0)?atoi(E.z):-1;
    Y.maxTimeSeries = (D.n>0)?atoi(D.z):-1;
    Y.maxStreams = (F.n>0)?atoi(F.z):-1;
    Y.maxPointsPerSecond     = (C.n>0)?atoi(C.z):-1;
    Y.maxStorage = (P.n>0)?strtoll(P.z, NULL, 10):-1;
    Y.maxQueryTime   = (Q.n>0)?strtoll(Q.z, NULL, 10):-1;
    Y.maxConnections   = (L.n>0)?atoi(L.z):-1;
S
slguan 已提交
238 239 240
    Y.stat    = M;
}

H
Haojun Liao 已提交
241 242
%type keep {SArray*}
%destructor keep {taosArrayDestroy($$);}
243 244 245 246
keep(Y)    ::= KEEP tagitemlist(X).           { Y = X; }

cache(Y)   ::= CACHE INTEGER(X).              { Y = X; }
replica(Y) ::= REPLICA INTEGER(X).            { Y = X; }
247
quorum(Y)  ::= QUORUM INTEGER(X).             { Y = X; }
248
days(Y)    ::= DAYS INTEGER(X).               { Y = X; }
H
hjxilinx 已提交
249 250 251
minrows(Y) ::= MINROWS INTEGER(X).            { Y = X; }
maxrows(Y) ::= MAXROWS INTEGER(X).            { Y = X; }
blocks(Y)  ::= BLOCKS INTEGER(X).             { Y = X; }
252
ctime(Y)   ::= CTIME INTEGER(X).              { Y = X; }
H
hjxilinx 已提交
253
wal(Y)     ::= WAL INTEGER(X).                { Y = X; }
陶建辉(Jeff)'s avatar
陶建辉(Jeff) 已提交
254
fsync(Y)   ::= FSYNC INTEGER(X).              { Y = X; }
255 256
comp(Y)    ::= COMP INTEGER(X).               { Y = X; }
prec(Y)    ::= PRECISION STRING(X).           { Y = X; }
Y
yihaoDeng 已提交
257
update(Y)  ::= UPDATE INTEGER(X).             { Y = X; }     
D
dapan1121 已提交
258
cachelast(Y) ::= CACHELAST INTEGER(X).        { Y = X; }
D
fix bug  
dapan1121 已提交
259
partitions(Y) ::= PARTITIONS INTEGER(X).      { Y = X; }
260

H
Haojun Liao 已提交
261
%type db_optr {SCreateDbInfo}
D
fix bug  
dapan1121 已提交
262
db_optr(Y) ::= . {setDefaultCreateDbOption(&Y); Y.dbType = TSDB_DB_TYPE_DEFAULT;}
H
hjxilinx 已提交
263

264 265
db_optr(Y) ::= db_optr(Z) cache(X).          { Y = Z; Y.cacheBlockSize = strtol(X.z, NULL, 10); }
db_optr(Y) ::= db_optr(Z) replica(X).        { Y = Z; Y.replica = strtol(X.z, NULL, 10); }
266
db_optr(Y) ::= db_optr(Z) quorum(X).         { Y = Z; Y.quorum = strtol(X.z, NULL, 10); }
267
db_optr(Y) ::= db_optr(Z) days(X).           { Y = Z; Y.daysPerFile = strtol(X.z, NULL, 10); }
H
hjxilinx 已提交
268 269 270
db_optr(Y) ::= db_optr(Z) minrows(X).        { Y = Z; Y.minRowsPerBlock = strtod(X.z, NULL); }
db_optr(Y) ::= db_optr(Z) maxrows(X).        { Y = Z; Y.maxRowsPerBlock = strtod(X.z, NULL); }
db_optr(Y) ::= db_optr(Z) blocks(X).         { Y = Z; Y.numOfBlocks = strtol(X.z, NULL, 10); }
271
db_optr(Y) ::= db_optr(Z) ctime(X).          { Y = Z; Y.commitTime = strtol(X.z, NULL, 10); }
H
hjxilinx 已提交
272
db_optr(Y) ::= db_optr(Z) wal(X).            { Y = Z; Y.walLevel = strtol(X.z, NULL, 10); }
陶建辉(Jeff)'s avatar
陶建辉(Jeff) 已提交
273
db_optr(Y) ::= db_optr(Z) fsync(X).          { Y = Z; Y.fsyncPeriod = strtol(X.z, NULL, 10); }
274 275 276
db_optr(Y) ::= db_optr(Z) comp(X).           { Y = Z; Y.compressionLevel = strtol(X.z, NULL, 10); }
db_optr(Y) ::= db_optr(Z) prec(X).           { Y = Z; Y.precision = X; }
db_optr(Y) ::= db_optr(Z) keep(X).           { Y = Z; Y.keep = X; }
Y
yihaoDeng 已提交
277
db_optr(Y) ::= db_optr(Z) update(X).         { Y = Z; Y.update = strtol(X.z, NULL, 10); }
D
dapan1121 已提交
278
db_optr(Y) ::= db_optr(Z) cachelast(X).      { Y = Z; Y.cachelast = strtol(X.z, NULL, 10); }
279

D
fix bug  
dapan1121 已提交
280 281 282 283 284
%type topic_optr {SCreateDbInfo}

topic_optr(Y) ::= db_optr(Z).                       { Y = Z; Y.dbType = TSDB_DB_TYPE_TOPIC; }
topic_optr(Y) ::= topic_optr(Z) partitions(X).      { Y = Z; Y.partitions = strtol(X.z, NULL, 10); }

H
Haojun Liao 已提交
285
%type alter_db_optr {SCreateDbInfo}
D
fix bug  
dapan1121 已提交
286
alter_db_optr(Y) ::= . { setDefaultCreateDbOption(&Y); Y.dbType = TSDB_DB_TYPE_DEFAULT;}
S
slguan 已提交
287 288

alter_db_optr(Y) ::= alter_db_optr(Z) replica(X).     { Y = Z; Y.replica = strtol(X.z, NULL, 10); }
289
alter_db_optr(Y) ::= alter_db_optr(Z) quorum(X).      { Y = Z; Y.quorum = strtol(X.z, NULL, 10); }
H
hjxilinx 已提交
290 291 292 293
alter_db_optr(Y) ::= alter_db_optr(Z) keep(X).        { Y = Z; Y.keep = X; }
alter_db_optr(Y) ::= alter_db_optr(Z) blocks(X).      { Y = Z; Y.numOfBlocks = strtol(X.z, NULL, 10); }
alter_db_optr(Y) ::= alter_db_optr(Z) comp(X).        { Y = Z; Y.compressionLevel = strtol(X.z, NULL, 10); }
alter_db_optr(Y) ::= alter_db_optr(Z) wal(X).         { Y = Z; Y.walLevel = strtol(X.z, NULL, 10); }
H
Haojun Liao 已提交
294
alter_db_optr(Y) ::= alter_db_optr(Z) fsync(X).       { Y = Z; Y.fsyncPeriod = strtol(X.z, NULL, 10); }
295
alter_db_optr(Y) ::= alter_db_optr(Z) update(X).      { Y = Z; Y.update = strtol(X.z, NULL, 10); }
D
dapan1121 已提交
296
alter_db_optr(Y) ::= alter_db_optr(Z) cachelast(X).   { Y = Z; Y.cachelast = strtol(X.z, NULL, 10); }
H
hzcheng 已提交
297

D
fix bug  
dapan1121 已提交
298 299 300 301 302
%type alter_topic_optr {SCreateDbInfo}

alter_topic_optr(Y) ::= alter_db_optr(Z).                       { Y = Z; Y.dbType = TSDB_DB_TYPE_TOPIC; }
alter_topic_optr(Y) ::= alter_topic_optr(Z) partitions(X).      { Y = Z; Y.partitions = strtol(X.z, NULL, 10); }

H
hzcheng 已提交
303
%type typename {TAOS_FIELD}
dengyihao's avatar
dengyihao 已提交
304 305
typename(A) ::= ids(X). { 
  X.type = 0;
H
Haojun Liao 已提交
306
  tSetColumnType (&A, &X);
dengyihao's avatar
dengyihao 已提交
307
}
H
hzcheng 已提交
308 309 310

//define binary type, e.g., binary(10), nchar(10)
typename(A) ::= ids(X) LP signed(Y) RP.    {
311 312
  if (Y <= 0) {
    X.type = 0;
H
Haojun Liao 已提交
313
    tSetColumnType(&A, &X);
314 315
  } else {
    X.type = -Y;  // negative value of name length
H
Haojun Liao 已提交
316
    tSetColumnType(&A, &X);
317
  }
H
hzcheng 已提交
318 319
}

320 321 322 323
// define the unsigned number type
typename(A) ::= ids(X) UNSIGNED(Z). {
  X.type = 0;
  X.n = ((Z.z + Z.n) - X.z);
H
Haojun Liao 已提交
324
  tSetColumnType (&A, &X);
325 326
}

327 328
%type signed {int64_t}
signed(A) ::= INTEGER(X).         { A = strtol(X.z, NULL, 10); }
H
hzcheng 已提交
329 330 331 332
signed(A) ::= PLUS INTEGER(X).    { A = strtol(X.z, NULL, 10); }
signed(A) ::= MINUS INTEGER(X).   { A = -strtol(X.z, NULL, 10);}

////////////////////////////////// The CREATE TABLE statement ///////////////////////////////
333 334
cmd ::= CREATE TABLE  create_table_args.  {}
cmd ::= CREATE TABLE  create_stable_args. {}
D
dapan1121 已提交
335
cmd ::= CREATE STABLE create_stable_args. {}
336 337
cmd ::= CREATE TABLE create_table_list(Z). { pInfo->type = TSDB_SQL_CREATE_TABLE; pInfo->pCreateTableInfo = Z;}

H
Haojun Liao 已提交
338
%type create_table_list{SCreateTableSql*}
H
Haojun Liao 已提交
339
%destructor create_table_list{destroyCreateTableSql($$);}
340
create_table_list(A) ::= create_from_stable(Z). {
H
Haojun Liao 已提交
341
  SCreateTableSql* pCreateTable = calloc(1, sizeof(SCreateTableSql));
342 343 344 345 346 347 348 349 350 351
  pCreateTable->childTableInfo = taosArrayInit(4, sizeof(SCreatedTableInfo));

  taosArrayPush(pCreateTable->childTableInfo, &Z);
  pCreateTable->type = TSQL_CREATE_TABLE_FROM_STABLE;
  A = pCreateTable;
}

create_table_list(A) ::= create_table_list(X) create_from_stable(Z). {
  taosArrayPush(X->childTableInfo, &Z);
  A = X;
H
hzcheng 已提交
352 353
}

H
Haojun Liao 已提交
354
%type create_table_args{SCreateTableSql*}
355
create_table_args(A) ::= ifnotexists(U) ids(V) cpxName(Z) LP columnlist(X) RP. {
H
Haojun Liao 已提交
356
  A = tSetCreateTableInfo(X, NULL, NULL, TSQL_CREATE_TABLE);
D
dapan1121 已提交
357
  setSqlInfo(pInfo, A, NULL, TSDB_SQL_CREATE_TABLE);
358 359 360

  V.n += Z.n;
  setCreatedTableName(pInfo, &V, &U);
H
hzcheng 已提交
361 362
}

363
// create super table
H
Haojun Liao 已提交
364
%type create_stable_args{SCreateTableSql*}
D
dapan1121 已提交
365
create_stable_args(A) ::= ifnotexists(U) ids(V) cpxName(Z) LP columnlist(X) RP TAGS LP columnlist(Y) RP. {
H
Haojun Liao 已提交
366
  A = tSetCreateTableInfo(X, Y, NULL, TSQL_CREATE_STABLE);
D
dapan1121 已提交
367
  setSqlInfo(pInfo, A, NULL, TSDB_SQL_CREATE_TABLE);
368 369 370

  V.n += Z.n;
  setCreatedTableName(pInfo, &V, &U);
H
hzcheng 已提交
371 372
}

373 374
// create table by using super table
// create table table_name using super_table_name tags(tag_values1, tag_values2)
375 376 377 378
%type create_from_stable{SCreatedTableInfo}
create_from_stable(A) ::= ifnotexists(U) ids(V) cpxName(Z) USING ids(X) cpxName(F) TAGS LP tagitemlist(Y) RP.  {
  X.n += F.n;
  V.n += Z.n;
379
  A = createNewChildTableInfo(&X, NULL, Y, &V, &U);
H
hzcheng 已提交
380 381
}

382 383 384 385 386 387 388 389 390 391 392
create_from_stable(A) ::= ifnotexists(U) ids(V) cpxName(Z) USING ids(X) cpxName(F) LP tagNamelist(P) RP TAGS LP tagitemlist(Y) RP.  {
  X.n += F.n;
  V.n += Z.n;
  A = createNewChildTableInfo(&X, P, Y, &V, &U);
}

%type tagNamelist{SArray*}
%destructor tagNamelist {taosArrayDestroy($$);}
tagNamelist(A) ::= tagNamelist(X) COMMA ids(Y).  {taosArrayPush(X, &Y); A = X;  }
tagNamelist(A) ::= ids(X).                      {A = taosArrayInit(4, sizeof(SStrToken)); taosArrayPush(A, &X);}

H
hzcheng 已提交
393
// create stream
394
// create table table_name as select count(*) from super_table_name interval(time)
395
create_table_args(A) ::= ifnotexists(U) ids(V) cpxName(Z) AS select(S). {
H
Haojun Liao 已提交
396
  A = tSetCreateTableInfo(NULL, NULL, S, TSQL_CREATE_STREAM);
D
dapan1121 已提交
397
  setSqlInfo(pInfo, A, NULL, TSDB_SQL_CREATE_TABLE);
398

B
Bomin Zhang 已提交
399 400
  V.n += Z.n;
  setCreatedTableName(pInfo, &V, &U);
H
hzcheng 已提交
401 402 403
}

%type column{TAOS_FIELD}
H
Haojun Liao 已提交
404 405
%type columnlist{SArray*}
%destructor columnlist {taosArrayDestroy($$);}
H
Haojun Liao 已提交
406
columnlist(A) ::= columnlist(X) COMMA column(Y).  {taosArrayPush(X, &Y); A = X;  }
H
Haojun Liao 已提交
407
columnlist(A) ::= column(X).                      {A = taosArrayInit(4, sizeof(TAOS_FIELD)); taosArrayPush(A, &X);}
H
hzcheng 已提交
408 409 410 411

// The information used for a column is the name and type of column:
// tinyint smallint int bigint float double bool timestamp binary(x) nchar(x)
column(A) ::= ids(X) typename(Y).          {
H
Haojun Liao 已提交
412
  tSetColumnInfo(&A, &X, &Y);
H
hzcheng 已提交
413 414
}

H
Haojun Liao 已提交
415 416
%type tagitemlist {SArray*}
%destructor tagitemlist {taosArrayDestroy($$);}
H
hzcheng 已提交
417 418 419 420 421

%type tagitem {tVariant}
tagitemlist(A) ::= tagitemlist(X) COMMA tagitem(Y). { A = tVariantListAppend(X, &Y, -1);    }
tagitemlist(A) ::= tagitem(X).                      { A = tVariantListAppend(NULL, &X, -1); }

422 423 424 425
tagitem(A) ::= INTEGER(X).      { toTSDBType(X.type); tVariantCreate(&A, &X); }
tagitem(A) ::= FLOAT(X).        { toTSDBType(X.type); tVariantCreate(&A, &X); }
tagitem(A) ::= STRING(X).       { toTSDBType(X.type); tVariantCreate(&A, &X); }
tagitem(A) ::= BOOL(X).         { toTSDBType(X.type); tVariantCreate(&A, &X); }
S
slguan 已提交
426
tagitem(A) ::= NULL(X).         { X.type = 0; tVariantCreate(&A, &X); }
H
hzcheng 已提交
427 428 429 430 431 432 433 434 435 436 437 438 439 440 441

tagitem(A) ::= MINUS(X) INTEGER(Y).{
    X.n += Y.n;
    X.type = Y.type;
    toTSDBType(X.type);
    tVariantCreate(&A, &X);
}

tagitem(A) ::= MINUS(X) FLOAT(Y).  {
    X.n += Y.n;
    X.type = Y.type;
    toTSDBType(X.type);
    tVariantCreate(&A, &X);
}

S
slguan 已提交
442 443 444 445 446 447 448 449 450 451 452 453 454
tagitem(A) ::= PLUS(X) INTEGER(Y). {
    X.n += Y.n;
    X.type = Y.type;
    toTSDBType(X.type);
    tVariantCreate(&A, &X);
}

tagitem(A) ::= PLUS(X) FLOAT(Y).  {
    X.n += Y.n;
    X.type = Y.type;
    toTSDBType(X.type);
    tVariantCreate(&A, &X);
}
H
hzcheng 已提交
455 456

//////////////////////// The SELECT statement /////////////////////////////////
457 458
%type select {SSqlNode*}
%destructor select {destroySqlNode($$);}
Y
TD-2570  
yihaoDeng 已提交
459 460
select(A) ::= SELECT(T) selcollist(W) from(X) where_opt(Y) interval_opt(K) session_option(H) windowstate_option(D) fill_opt(F) sliding_opt(S) groupby_opt(P) orderby_opt(Z) having_opt(N) slimit_opt(G) limit_opt(L). {
  A = tSetQuerySqlNode(&T, W, X, Y, P, Z, &K, &H, &D, &S, F, &L, &G, N);
H
hzcheng 已提交
461 462
}

H
Haojun Liao 已提交
463 464
select(A) ::= LP select(B) RP. {A = B;}

465 466
%type union {SArray*}
%destructor union {destroyAllSqlNode($$);}
467
union(Y) ::= select(X). { Y = setSubclause(NULL, X); }
468
union(Y) ::= union(Z) UNION ALL select(X). { Y = appendSelectClause(Z, X); }
469

D
dapan1121 已提交
470
cmd ::= union(X). { setSqlInfo(pInfo, X, NULL, TSDB_SQL_SELECT); }
471

H
hjxilinx 已提交
472
// Support for the SQL exprssion without from & where subclauses, e.g.,
H
Haojun Liao 已提交
473 474 475 476
// select current_database()
// select server_version()
// select client_version()
// select server_state()
H
hjxilinx 已提交
477
select(A) ::= SELECT(T) selcollist(W). {
Y
TD-2570  
yihaoDeng 已提交
478
  A = tSetQuerySqlNode(&T, W, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);
H
hjxilinx 已提交
479 480
}

H
hzcheng 已提交
481 482 483
// selcollist is a list of expressions that are to become the return
// values of the SELECT statement.  The "*" in statements like
// "SELECT * FROM ..." is encoded as a special expression with an opcode of TK_ALL.
H
Haojun Liao 已提交
484
%type selcollist {SArray*}
D
dapan1121 已提交
485
%destructor selcollist {tSqlExprListDestroy($$);}
H
hzcheng 已提交
486

H
Haojun Liao 已提交
487
%type sclp {SArray*}
D
dapan1121 已提交
488
%destructor sclp {tSqlExprListDestroy($$);}
H
hzcheng 已提交
489 490
sclp(A) ::= selcollist(X) COMMA.             {A = X;}
sclp(A) ::= .                                {A = 0;}
dengyihao's avatar
TD-2571  
dengyihao 已提交
491 492
selcollist(A) ::= sclp(P) distinct(Z) expr(X) as(Y).     {
   A = tSqlExprListAppend(P, X,  Z.n? &Z:0, Y.n?&Y:0);
H
hzcheng 已提交
493 494 495
}

selcollist(A) ::= sclp(P) STAR. {
H
Haojun Liao 已提交
496
   tSqlExpr *pNode = tSqlExprCreateIdValue(NULL, TK_ALL);
dengyihao's avatar
TD-2571  
dengyihao 已提交
497
   A = tSqlExprListAppend(P, pNode, 0, 0);
H
hzcheng 已提交
498 499 500 501
}

// An option "AS <id>" phrase that can follow one of the expressions that
// define the result set, or one of the tables in the FROM clause.
H
Haojun Liao 已提交
502
%type as {SStrToken}
H
hzcheng 已提交
503 504 505 506
as(X) ::= AS ids(Y).    { X = Y;    }
as(X) ::= ids(Y).       { X = Y;    }
as(X) ::= .             { X.n = 0;  }

dengyihao's avatar
TD-2571  
dengyihao 已提交
507 508 509 510
%type distinct {SStrToken}
distinct(X) ::= DISTINCT(Y). { X = Y;  }
distinct(X) ::= .            { X.n = 0;}

H
hzcheng 已提交
511
// A complete FROM clause.
512
%type from {SRelationInfo*}
H
Haojun Liao 已提交
513
%destructor from {destroyRelationInfo($$);}
S
slguan 已提交
514
from(A) ::= FROM tablelist(X).                 {A = X;}
H
Haojun Liao 已提交
515 516 517 518 519 520 521
from(A) ::= FROM sub(X).                       {A = X;}

%type sub {SRelationInfo*}
%destructor sub {destroyRelationInfo($$);}
sub(A)  ::= LP union(Y) RP.                    {A = addSubqueryElem(NULL, Y, NULL);}
sub(A)  ::= LP union(Y) RP ids(Z).             {A = addSubqueryElem(NULL, Y, &Z);}
sub(A)  ::= sub(X) COMMA LP union(Y) RP ids(Z).{A = addSubqueryElem(X, Y, &Z);}
S
slguan 已提交
522

523
%type tablelist {SRelationInfo*}
H
Haojun Liao 已提交
524
%destructor tablelist {destroyRelationInfo($$);}
H
Haojun Liao 已提交
525 526
tablelist(A) ::= ids(X) cpxName(Y).                     {
  X.n += Y.n;
H
Haojun Liao 已提交
527
  A = setTableNameList(NULL, &X, NULL);
H
Haojun Liao 已提交
528 529 530
}

tablelist(A) ::= ids(X) cpxName(Y) ids(Z).             {
531
  X.n += Y.n;
H
Haojun Liao 已提交
532
  A = setTableNameList(NULL, &X, &Z);
H
Haojun Liao 已提交
533 534 535 536
}

tablelist(A) ::= tablelist(Y) COMMA ids(X) cpxName(Z).  {
  X.n += Z.n;
H
Haojun Liao 已提交
537
  A = setTableNameList(Y, &X, NULL);
H
Haojun Liao 已提交
538 539 540
}

tablelist(A) ::= tablelist(Y) COMMA ids(X) cpxName(Z) ids(F). {
541
  X.n += Z.n;
H
Haojun Liao 已提交
542
  A = setTableNameList(Y, &X, &F);
H
Haojun Liao 已提交
543
}
H
hzcheng 已提交
544 545

// The value of interval should be the form of "number+[a,s,m,h,d,n,y]" or "now"
H
Haojun Liao 已提交
546
%type tmvar {SStrToken}
H
hzcheng 已提交
547 548
tmvar(A) ::= VARIABLE(X).   {A = X;}

549
%type interval_opt {SIntervalVal}
550 551
interval_opt(N) ::= INTERVAL LP tmvar(E) RP.    {N.interval = E; N.offset.n = 0;}
interval_opt(N) ::= INTERVAL LP tmvar(E) COMMA tmvar(X) RP.    {N.interval = E; N.offset = X;}
552
interval_opt(N) ::= .                           {memset(&N, 0, sizeof(N));}
H
hzcheng 已提交
553

554 555 556 557 558 559 560
%type session_option {SSessionWindowVal}
session_option(X) ::= .                                                  {X.col.n = 0; X.gap.n = 0;}
session_option(X) ::= SESSION LP ids(V) cpxName(Z) COMMA tmvar(Y) RP.    {
   V.n += Z.n;
   X.col = V;
   X.gap = Y;
}
Y
TD-2570  
yihaoDeng 已提交
561 562
%type windowstate_option {SWindowStateVal}
windowstate_option(X) ::= .                                                  {X.col.n = 0;}
563
windowstate_option(X) ::= STATE_WINDOW LP ids(V) RP.                       {
Y
TD-2570  
yihaoDeng 已提交
564 565
   X.col = V;
}  
566

H
Haojun Liao 已提交
567 568
%type fill_opt {SArray*}
%destructor fill_opt {taosArrayDestroy($$);}
569
fill_opt(N) ::= .                                           { N = 0;     }
H
hzcheng 已提交
570 571 572 573 574
fill_opt(N) ::= FILL LP ID(Y) COMMA tagitemlist(X) RP.      {
    tVariant A = {0};
    toTSDBType(Y.type);
    tVariantCreate(&A, &Y);

H
Haojun Liao 已提交
575
    tVariantListInsert(X, &A, -1, 0);
H
hzcheng 已提交
576 577 578 579 580
    N = X;
}

fill_opt(N) ::= FILL LP ID(Y) RP.               {
    toTSDBType(Y.type);
581
    N = tVariantListAppendToken(NULL, &Y, -1);
H
hzcheng 已提交
582 583
}

H
Haojun Liao 已提交
584
%type sliding_opt {SStrToken}
H
hzcheng 已提交
585
sliding_opt(K) ::= SLIDING LP tmvar(E) RP.      {K = E;     }
H
hjxilinx 已提交
586
sliding_opt(K) ::= .                            {K.n = 0; K.z = NULL; K.type = 0;   }
H
hzcheng 已提交
587

H
Haojun Liao 已提交
588 589
%type orderby_opt {SArray*}
%destructor orderby_opt {taosArrayDestroy($$);}
H
hzcheng 已提交
590

H
Haojun Liao 已提交
591 592
%type sortlist {SArray*}
%destructor sortlist {taosArrayDestroy($$);}
H
hzcheng 已提交
593 594 595 596 597 598 599 600 601 602 603 604 605 606 607

%type sortitem {tVariant}
%destructor sortitem {tVariantDestroy(&$$);}

orderby_opt(A) ::= .                          {A = 0;}
orderby_opt(A) ::= ORDER BY sortlist(X).      {A = X;}

sortlist(A) ::= sortlist(X) COMMA item(Y) sortorder(Z). {
    A = tVariantListAppend(X, &Y, Z);
}

sortlist(A) ::= item(Y) sortorder(Z). {
  A = tVariantListAppend(NULL, &Y, Z);
}

608 609
%type item {tVariant}
item(A) ::= ids(X) cpxName(Y).   {
H
hzcheng 已提交
610
  toTSDBType(X.type);
611 612
  X.n += Y.n;

H
hzcheng 已提交
613 614 615 616
  tVariantCreate(&A, &X);
}

%type sortorder {int}
617 618 619
sortorder(A) ::= ASC.           { A = TSDB_ORDER_ASC; }
sortorder(A) ::= DESC.          { A = TSDB_ORDER_DESC;}
sortorder(A) ::= .              { A = TSDB_ORDER_ASC; }  // Ascending order by default
H
hzcheng 已提交
620 621

//group by clause
H
Haojun Liao 已提交
622 623 624 625
%type groupby_opt {SArray*}
%destructor groupby_opt {taosArrayDestroy($$);}
%type grouplist {SArray*}
%destructor grouplist {taosArrayDestroy($$);}
H
hzcheng 已提交
626

627 628
groupby_opt(A) ::= .                       { A = 0;}
groupby_opt(A) ::= GROUP BY grouplist(X).  { A = X;}
H
hzcheng 已提交
629 630 631 632 633 634 635 636 637 638

grouplist(A) ::= grouplist(X) COMMA item(Y).    {
  A = tVariantListAppend(X, &Y, -1);
}

grouplist(A) ::= item(X).                       {
  A = tVariantListAppend(NULL, &X, -1);
}

//having clause, ignore the input condition in having
H
Haojun Liao 已提交
639
%type having_opt {tSqlExpr*}
D
dapan1121 已提交
640
%destructor having_opt {tSqlExprDestroy($$);}
H
hzcheng 已提交
641 642 643 644 645 646
having_opt(A) ::=.                  {A = 0;}
having_opt(A) ::= HAVING expr(X).   {A = X;}

//limit-offset subclause
%type limit_opt {SLimitVal}
limit_opt(A) ::= .                     {A.limit = -1; A.offset = 0;}
647
limit_opt(A) ::= LIMIT signed(X).      {A.limit = X;  A.offset = 0;}
H
hzcheng 已提交
648
limit_opt(A) ::= LIMIT signed(X) OFFSET signed(Y).
649
                                       { A.limit = X;  A.offset = Y;}
H
hzcheng 已提交
650
limit_opt(A) ::= LIMIT signed(X) COMMA signed(Y).
651
                                       { A.limit = Y;  A.offset = X;}
H
hzcheng 已提交
652 653 654 655 656 657 658

%type slimit_opt {SLimitVal}
slimit_opt(A) ::= .                    {A.limit = -1; A.offset = 0;}
slimit_opt(A) ::= SLIMIT signed(X).    {A.limit = X;  A.offset = 0;}
slimit_opt(A) ::= SLIMIT signed(X) SOFFSET signed(Y).
                                       {A.limit = X;  A.offset = Y;}
slimit_opt(A) ::= SLIMIT signed(X) COMMA  signed(Y).
S
slguan 已提交
659
                                       {A.limit = Y;  A.offset = X;}
H
hzcheng 已提交
660

H
Haojun Liao 已提交
661
%type where_opt {tSqlExpr*}
D
dapan1121 已提交
662
%destructor where_opt {tSqlExprDestroy($$);}
H
hzcheng 已提交
663 664 665 666 667 668

where_opt(A) ::= .                    {A = 0;}
where_opt(A) ::= WHERE expr(X).       {A = X;}

/////////////////////////// Expression Processing /////////////////////////////
//
H
Haojun Liao 已提交
669
%type expr {tSqlExpr*}
D
dapan1121 已提交
670
%destructor expr {tSqlExprDestroy($$);}
H
hzcheng 已提交
671

672
expr(A) ::= LP(X) expr(Y) RP(Z).       {A = Y; A->token.z = X.z; A->token.n = (Z.z - X.z + 1);}
H
hzcheng 已提交
673

H
Haojun Liao 已提交
674 675 676 677 678 679 680 681 682 683 684 685 686
expr(A) ::= ID(X).               { A = tSqlExprCreateIdValue(&X, TK_ID);}
expr(A) ::= ID(X) DOT ID(Y).     { X.n += (1+Y.n); A = tSqlExprCreateIdValue(&X, TK_ID);}
expr(A) ::= ID(X) DOT STAR(Y).   { X.n += (1+Y.n); A = tSqlExprCreateIdValue(&X, TK_ALL);}

expr(A) ::= INTEGER(X).          { A = tSqlExprCreateIdValue(&X, TK_INTEGER);}
expr(A) ::= MINUS(X) INTEGER(Y). { X.n += Y.n; X.type = TK_INTEGER; A = tSqlExprCreateIdValue(&X, TK_INTEGER);}
expr(A) ::= PLUS(X)  INTEGER(Y). { X.n += Y.n; X.type = TK_INTEGER; A = tSqlExprCreateIdValue(&X, TK_INTEGER);}
expr(A) ::= FLOAT(X).            { A = tSqlExprCreateIdValue(&X, TK_FLOAT);}
expr(A) ::= MINUS(X) FLOAT(Y).   { X.n += Y.n; X.type = TK_FLOAT; A = tSqlExprCreateIdValue(&X, TK_FLOAT);}
expr(A) ::= PLUS(X) FLOAT(Y).    { X.n += Y.n; X.type = TK_FLOAT; A = tSqlExprCreateIdValue(&X, TK_FLOAT);}
expr(A) ::= STRING(X).           { A = tSqlExprCreateIdValue(&X, TK_STRING);}
expr(A) ::= NOW(X).              { A = tSqlExprCreateIdValue(&X, TK_NOW); }
expr(A) ::= VARIABLE(X).         { A = tSqlExprCreateIdValue(&X, TK_VARIABLE);}
D
dapan1121 已提交
687 688
expr(A) ::= PLUS(X) VARIABLE(Y).   { X.n += Y.n; X.type = TK_VARIABLE; A = tSqlExprCreateIdValue(&X, TK_VARIABLE);}
expr(A) ::= MINUS(X) VARIABLE(Y).  { X.n += Y.n; X.type = TK_VARIABLE; A = tSqlExprCreateIdValue(&X, TK_VARIABLE);}
H
Haojun Liao 已提交
689
expr(A) ::= BOOL(X).             { A = tSqlExprCreateIdValue(&X, TK_BOOL);}
690
expr(A) ::= NULL(X).             { A = tSqlExprCreateIdValue(&X, TK_NULL);}
H
Haojun Liao 已提交
691 692

// ordinary functions: min(x), max(x), top(k, 20)
D
dapan1121 已提交
693
expr(A) ::= ID(X) LP exprlist(Y) RP(E). { A = tSqlExprCreateFunction(Y, &X, &E, X.type); }
H
Haojun Liao 已提交
694 695

// for parsing sql functions with wildcard for parameters. e.g., count(*)/first(*)/last(*) operation
D
dapan1121 已提交
696
expr(A) ::= ID(X) LP STAR RP(Y).     { A = tSqlExprCreateFunction(NULL, &X, &Y, X.type); }
H
Haojun Liao 已提交
697 698

// is (not) null expression
D
dapan1121 已提交
699 700
expr(A) ::= expr(X) IS NULL.           {A = tSqlExprCreate(X, NULL, TK_ISNULL);}
expr(A) ::= expr(X) IS NOT NULL.       {A = tSqlExprCreate(X, NULL, TK_NOTNULL);}
H
Haojun Liao 已提交
701 702

// relational expression
D
dapan1121 已提交
703 704 705 706 707 708
expr(A) ::= expr(X) LT expr(Y).      {A = tSqlExprCreate(X, Y, TK_LT);}
expr(A) ::= expr(X) GT expr(Y).      {A = tSqlExprCreate(X, Y, TK_GT);}
expr(A) ::= expr(X) LE expr(Y).      {A = tSqlExprCreate(X, Y, TK_LE);}
expr(A) ::= expr(X) GE expr(Y).      {A = tSqlExprCreate(X, Y, TK_GE);}
expr(A) ::= expr(X) NE expr(Y).      {A = tSqlExprCreate(X, Y, TK_NE);}
expr(A) ::= expr(X) EQ expr(Y).      {A = tSqlExprCreate(X, Y, TK_EQ);}
H
Haojun Liao 已提交
709

H
Haojun Liao 已提交
710
expr(A) ::= expr(X) BETWEEN expr(Y) AND expr(Z).      { tSqlExpr* X2 = tSqlExprClone(X); A = tSqlExprCreate(tSqlExprCreate(X, Y, TK_GE), tSqlExprCreate(X2, Z, TK_LE), TK_AND);}
D
dapan1121 已提交
711

D
dapan1121 已提交
712 713
expr(A) ::= expr(X) AND expr(Y).     {A = tSqlExprCreate(X, Y, TK_AND);}
expr(A) ::= expr(X) OR  expr(Y).     {A = tSqlExprCreate(X, Y, TK_OR); }
H
Haojun Liao 已提交
714 715

// binary arithmetic expression
D
dapan1121 已提交
716 717 718 719 720
expr(A) ::= expr(X) PLUS  expr(Y).   {A = tSqlExprCreate(X, Y, TK_PLUS);  }
expr(A) ::= expr(X) MINUS expr(Y).   {A = tSqlExprCreate(X, Y, TK_MINUS); }
expr(A) ::= expr(X) STAR  expr(Y).   {A = tSqlExprCreate(X, Y, TK_STAR);  }
expr(A) ::= expr(X) SLASH expr(Y).   {A = tSqlExprCreate(X, Y, TK_DIVIDE);}
expr(A) ::= expr(X) REM   expr(Y).   {A = tSqlExprCreate(X, Y, TK_REM);   }
H
hzcheng 已提交
721

H
Haojun Liao 已提交
722
// like expression
D
dapan1121 已提交
723
expr(A) ::= expr(X) LIKE expr(Y).    {A = tSqlExprCreate(X, Y, TK_LIKE);  }
H
hzcheng 已提交
724 725

//in expression
H
Haojun Liao 已提交
726
expr(A) ::= expr(X) IN LP exprlist(Y) RP.   {A = tSqlExprCreate(X, (tSqlExpr*)Y, TK_IN); }
H
hzcheng 已提交
727

H
Haojun Liao 已提交
728
%type exprlist {SArray*}
D
dapan1121 已提交
729
%destructor exprlist {tSqlExprListDestroy($$);}
H
hzcheng 已提交
730

H
Haojun Liao 已提交
731
%type expritem {tSqlExpr*}
D
dapan1121 已提交
732
%destructor expritem {tSqlExprDestroy($$);}
H
hzcheng 已提交
733

dengyihao's avatar
TD-2571  
dengyihao 已提交
734 735
exprlist(A) ::= exprlist(X) COMMA expritem(Y). {A = tSqlExprListAppend(X,Y,0, 0);}
exprlist(A) ::= expritem(X).                   {A = tSqlExprListAppend(0,X,0, 0);}
H
Haojun Liao 已提交
736 737
expritem(A) ::= expr(X).                       {A = X;}
expritem(A) ::= .                              {A = 0;}
H
hzcheng 已提交
738 739

///////////////////////////////////reset query cache//////////////////////////////////////
H
Haojun Liao 已提交
740
cmd ::= RESET QUERY CACHE.  { setDCLSqlElems(pInfo, TSDB_SQL_RESET_CACHE, 0);}
H
hzcheng 已提交
741

742 743 744
///////////////////////////////////sync replica database//////////////////////////////////
cmd ::= SYNCDB ids(X) REPLICA.{ setDCLSqlElems(pInfo, TSDB_SQL_SYNC_DB_REPLICA, 1, &X);}

H
hzcheng 已提交
745 746 747
///////////////////////////////////ALTER TABLE statement//////////////////////////////////
cmd ::= ALTER TABLE ids(X) cpxName(F) ADD COLUMN columnlist(A).     {
    X.n += F.n;
H
Haojun Liao 已提交
748
    SAlterTableInfo* pAlterTable = tSetAlterTableInfo(&X, A, NULL, TSDB_ALTER_TABLE_ADD_COLUMN, -1);
D
dapan1121 已提交
749
    setSqlInfo(pInfo, pAlterTable, NULL, TSDB_SQL_ALTER_TABLE);
H
hzcheng 已提交
750 751 752 753 754 755
}

cmd ::= ALTER TABLE ids(X) cpxName(F) DROP COLUMN ids(A).     {
    X.n += F.n;

    toTSDBType(A.type);
H
Haojun Liao 已提交
756
    SArray* K = tVariantListAppendToken(NULL, &A, -1);
H
hzcheng 已提交
757

H
Haojun Liao 已提交
758
    SAlterTableInfo* pAlterTable = tSetAlterTableInfo(&X, NULL, K, TSDB_ALTER_TABLE_DROP_COLUMN, -1);
D
dapan1121 已提交
759
    setSqlInfo(pInfo, pAlterTable, NULL, TSDB_SQL_ALTER_TABLE);
H
hzcheng 已提交
760 761 762 763 764
}

//////////////////////////////////ALTER TAGS statement/////////////////////////////////////
cmd ::= ALTER TABLE ids(X) cpxName(Y) ADD TAG columnlist(A).        {
    X.n += Y.n;
H
Haojun Liao 已提交
765
    SAlterTableInfo* pAlterTable = tSetAlterTableInfo(&X, A, NULL, TSDB_ALTER_TABLE_ADD_TAG_COLUMN, -1);
D
dapan1121 已提交
766
    setSqlInfo(pInfo, pAlterTable, NULL, TSDB_SQL_ALTER_TABLE);
H
hzcheng 已提交
767 768 769 770 771
}
cmd ::= ALTER TABLE ids(X) cpxName(Z) DROP TAG ids(Y).          {
    X.n += Z.n;

    toTSDBType(Y.type);
H
Haojun Liao 已提交
772
    SArray* A = tVariantListAppendToken(NULL, &Y, -1);
H
hzcheng 已提交
773

H
Haojun Liao 已提交
774
    SAlterTableInfo* pAlterTable = tSetAlterTableInfo(&X, NULL, A, TSDB_ALTER_TABLE_DROP_TAG_COLUMN, -1);
D
dapan1121 已提交
775
    setSqlInfo(pInfo, pAlterTable, NULL, TSDB_SQL_ALTER_TABLE);
H
hzcheng 已提交
776 777 778 779 780 781
}

cmd ::= ALTER TABLE ids(X) cpxName(F) CHANGE TAG ids(Y) ids(Z). {
    X.n += F.n;

    toTSDBType(Y.type);
H
Haojun Liao 已提交
782
    SArray* A = tVariantListAppendToken(NULL, &Y, -1);
H
hzcheng 已提交
783 784

    toTSDBType(Z.type);
785
    A = tVariantListAppendToken(A, &Z, -1);
H
hzcheng 已提交
786

H
Haojun Liao 已提交
787
    SAlterTableInfo* pAlterTable = tSetAlterTableInfo(&X, NULL, A, TSDB_ALTER_TABLE_CHANGE_TAG_COLUMN, -1);
D
dapan1121 已提交
788
    setSqlInfo(pInfo, pAlterTable, NULL, TSDB_SQL_ALTER_TABLE);
H
hzcheng 已提交
789 790
}

791
cmd ::= ALTER TABLE ids(X) cpxName(F) SET TAG ids(Y) EQ tagitem(Z).     {
H
hzcheng 已提交
792 793 794
    X.n += F.n;

    toTSDBType(Y.type);
H
Haojun Liao 已提交
795
    SArray* A = tVariantListAppendToken(NULL, &Y, -1);
H
hzcheng 已提交
796 797
    A = tVariantListAppend(A, &Z, -1);

H
Haojun Liao 已提交
798
    SAlterTableInfo* pAlterTable = tSetAlterTableInfo(&X, NULL, A, TSDB_ALTER_TABLE_UPDATE_TAG_VAL, -1);
D
dapan1121 已提交
799 800 801 802 803 804 805
    setSqlInfo(pInfo, pAlterTable, NULL, TSDB_SQL_ALTER_TABLE);
}


///////////////////////////////////ALTER STABLE statement//////////////////////////////////
cmd ::= ALTER STABLE ids(X) cpxName(F) ADD COLUMN columnlist(A).     {
    X.n += F.n;
H
Haojun Liao 已提交
806
    SAlterTableInfo* pAlterTable = tSetAlterTableInfo(&X, A, NULL, TSDB_ALTER_TABLE_ADD_COLUMN, TSDB_SUPER_TABLE);
D
dapan1121 已提交
807 808 809 810 811 812 813 814 815
    setSqlInfo(pInfo, pAlterTable, NULL, TSDB_SQL_ALTER_TABLE);
}

cmd ::= ALTER STABLE ids(X) cpxName(F) DROP COLUMN ids(A).     {
    X.n += F.n;

    toTSDBType(A.type);
    SArray* K = tVariantListAppendToken(NULL, &A, -1);

H
Haojun Liao 已提交
816
    SAlterTableInfo* pAlterTable = tSetAlterTableInfo(&X, NULL, K, TSDB_ALTER_TABLE_DROP_COLUMN, TSDB_SUPER_TABLE);
D
dapan1121 已提交
817 818 819 820 821 822
    setSqlInfo(pInfo, pAlterTable, NULL, TSDB_SQL_ALTER_TABLE);
}

//////////////////////////////////ALTER TAGS statement/////////////////////////////////////
cmd ::= ALTER STABLE ids(X) cpxName(Y) ADD TAG columnlist(A).        {
    X.n += Y.n;
H
Haojun Liao 已提交
823
    SAlterTableInfo* pAlterTable = tSetAlterTableInfo(&X, A, NULL, TSDB_ALTER_TABLE_ADD_TAG_COLUMN, TSDB_SUPER_TABLE);
D
dapan1121 已提交
824 825 826 827 828 829 830 831
    setSqlInfo(pInfo, pAlterTable, NULL, TSDB_SQL_ALTER_TABLE);
}
cmd ::= ALTER STABLE ids(X) cpxName(Z) DROP TAG ids(Y).          {
    X.n += Z.n;

    toTSDBType(Y.type);
    SArray* A = tVariantListAppendToken(NULL, &Y, -1);

H
Haojun Liao 已提交
832
    SAlterTableInfo* pAlterTable = tSetAlterTableInfo(&X, NULL, A, TSDB_ALTER_TABLE_DROP_TAG_COLUMN, TSDB_SUPER_TABLE);
D
dapan1121 已提交
833 834 835 836 837 838 839 840 841 842 843 844
    setSqlInfo(pInfo, pAlterTable, NULL, TSDB_SQL_ALTER_TABLE);
}

cmd ::= ALTER STABLE ids(X) cpxName(F) CHANGE TAG ids(Y) ids(Z). {
    X.n += F.n;

    toTSDBType(Y.type);
    SArray* A = tVariantListAppendToken(NULL, &Y, -1);

    toTSDBType(Z.type);
    A = tVariantListAppendToken(A, &Z, -1);

H
Haojun Liao 已提交
845
    SAlterTableInfo* pAlterTable = tSetAlterTableInfo(&X, NULL, A, TSDB_ALTER_TABLE_CHANGE_TAG_COLUMN, TSDB_SUPER_TABLE);
D
dapan1121 已提交
846
    setSqlInfo(pInfo, pAlterTable, NULL, TSDB_SQL_ALTER_TABLE);
H
hzcheng 已提交
847 848 849
}

////////////////////////////////////////kill statement///////////////////////////////////////
D
dapan1121 已提交
850 851 852
cmd ::= KILL CONNECTION INTEGER(Y).   {setKillSql(pInfo, TSDB_SQL_KILL_CONNECTION, &Y);}
cmd ::= KILL STREAM INTEGER(X) COLON(Z) INTEGER(Y).       {X.n += (Z.n + Y.n); setKillSql(pInfo, TSDB_SQL_KILL_STREAM, &X);}
cmd ::= KILL QUERY INTEGER(X) COLON(Z) INTEGER(Y).        {X.n += (Z.n + Y.n); setKillSql(pInfo, TSDB_SQL_KILL_QUERY, &X);}
H
hzcheng 已提交
853 854 855 856

%fallback ID ABORT AFTER ASC ATTACH BEFORE BEGIN CASCADE CLUSTER CONFLICT COPY DATABASE DEFERRED
  DELIMITERS DESC DETACH EACH END EXPLAIN FAIL FOR GLOB IGNORE IMMEDIATE INITIALLY INSTEAD
  LIKE MATCH KEY OF OFFSET RAISE REPLACE RESTRICT ROW STATEMENT TRIGGER VIEW ALL
857
  NOW IPTOKEN SEMI NONE PREV LINEAR IMPORT TBNAME JOIN STABLE NULL INSERT INTO VALUES.