[TD-11220]<feature>(query): time related functions

src/inc/ttokendef.h

@@ -161,62 +161,62 @@
 #define TK_SLIMIT                         143
 #define TK_SOFFSET                        144
 #define TK_WHERE                          145
-#define TK_RESET                          146
-#define TK_QUERY                          147
-#define TK_SYNCDB                         148
-#define TK_ADD                            149
-#define TK_COLUMN                         150
-#define TK_MODIFY                         151
-#define TK_TAG                            152
-#define TK_CHANGE                         153
-#define TK_SET                            154
-#define TK_KILL                           155
-#define TK_CONNECTION                     156
-#define TK_STREAM                         157
-#define TK_COLON                          158
-#define TK_ABORT                          159
-#define TK_AFTER                          160
-#define TK_ATTACH                         161
-#define TK_BEFORE                         162
-#define TK_BEGIN                          163
-#define TK_CASCADE                        164
-#define TK_CLUSTER                        165
-#define TK_CONFLICT                       166
-#define TK_COPY                           167
-#define TK_DEFERRED                       168
-#define TK_DELIMITERS                     169
-#define TK_DETACH                         170
-#define TK_EACH                           171
-#define TK_END                            172
-#define TK_EXPLAIN                        173
-#define TK_FAIL                           174
-#define TK_FOR                            175
-#define TK_IGNORE                         176
-#define TK_IMMEDIATE                      177
-#define TK_INITIALLY                      178
-#define TK_INSTEAD                        179
-#define TK_KEY                            180
-#define TK_OF                             181
-#define TK_RAISE                          182
-#define TK_REPLACE                        183
-#define TK_RESTRICT                       184
-#define TK_ROW                            185
-#define TK_STATEMENT                      186
-#define TK_TRIGGER                        187
-#define TK_VIEW                           188
-#define TK_IPTOKEN                        189
-#define TK_SEMI                           190
-#define TK_NONE                           191
-#define TK_PREV                           192
-#define TK_LINEAR                         193
-#define TK_IMPORT                         194
-#define TK_TBNAME                         195
-#define TK_JOIN                           196
-#define TK_INSERT                         197
-#define TK_INTO                           198
-#define TK_VALUES                         199
-#define TK_FILE                           200
-
+#define TK_TODAY                          146
+#define TK_RESET                          147
+#define TK_QUERY                          148
+#define TK_SYNCDB                         149
+#define TK_ADD                            150
+#define TK_COLUMN                         151
+#define TK_MODIFY                         152
+#define TK_TAG                            153
+#define TK_CHANGE                         154
+#define TK_SET                            155
+#define TK_KILL                           156
+#define TK_CONNECTION                     157
+#define TK_STREAM                         158
+#define TK_COLON                          159
+#define TK_ABORT                          160
+#define TK_AFTER                          161
+#define TK_ATTACH                         162
+#define TK_BEFORE                         163
+#define TK_BEGIN                          164
+#define TK_CASCADE                        165
+#define TK_CLUSTER                        166
+#define TK_CONFLICT                       167
+#define TK_COPY                           168
+#define TK_DEFERRED                       169
+#define TK_DELIMITERS                     170
+#define TK_DETACH                         171
+#define TK_EACH                           172
+#define TK_END                            173
+#define TK_EXPLAIN                        174
+#define TK_FAIL                           175
+#define TK_FOR                            176
+#define TK_IGNORE                         177
+#define TK_IMMEDIATE                      178
+#define TK_INITIALLY                      179
+#define TK_INSTEAD                        180
+#define TK_KEY                            181
+#define TK_OF                             182
+#define TK_RAISE                          183
+#define TK_REPLACE                        184
+#define TK_RESTRICT                       185
+#define TK_ROW                            186
+#define TK_STATEMENT                      187
+#define TK_TRIGGER                        188
+#define TK_VIEW                           189
+#define TK_IPTOKEN                        190
+#define TK_SEMI                           191
+#define TK_NONE                           192
+#define TK_PREV                           193
+#define TK_LINEAR                         194
+#define TK_IMPORT                         195
+#define TK_TBNAME                         196
+#define TK_JOIN                           197
+#define TK_INSERT                         198
+#define TK_INTO                           199
+#define TK_VALUES                         200
+#define TK_FILE                           201
 
 #define TK_SPACE                          300
 #define TK_COMMENT                        301

src/query/inc/sql.y

@@ -748,6 +748,7 @@ expr(A) ::= MINUS(X) FLOAT(Y).   { X.n += Y.n; X.type = TK_FLOAT; A = tSqlExprCr
 expr(A) ::= PLUS(X) FLOAT(Y).    { X.n += Y.n; X.type = TK_FLOAT; A = tSqlExprCreateIdValue(pInfo, &X, TK_FLOAT);}
 expr(A) ::= STRING(X).           { A = tSqlExprCreateIdValue(pInfo, &X, TK_STRING);}
 expr(A) ::= NOW(X).              { A = tSqlExprCreateIdValue(pInfo, &X, TK_NOW); }
+expr(A) ::= TODAY(X).            { A = tSqlExprCreateIdValue(pInfo, &X, TK_TODAY); }
 expr(A) ::= VARIABLE(X).         { A = tSqlExprCreateIdValue(pInfo, &X, TK_VARIABLE);}
 expr(A) ::= PLUS(X) VARIABLE(Y).   { X.n += Y.n; X.type = TK_VARIABLE; A = tSqlExprCreateIdValue(pInfo, &X, TK_VARIABLE);}
 expr(A) ::= MINUS(X) VARIABLE(Y).  { X.n += Y.n; X.type = TK_VARIABLE; A = tSqlExprCreateIdValue(pInfo, &X, TK_VARIABLE);}
@@ -972,4 +973,4 @@ cmd ::= KILL QUERY INTEGER(X) COLON(Z) INTEGER(Y).        {X.n += (Z.n + Y.n); s
 %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 NMATCH KEY OF OFFSET RAISE REPLACE RESTRICT ROW STATEMENT TRIGGER VIEW ALL
-  NOW IPTOKEN SEMI NONE PREV LINEAR IMPORT TBNAME JOIN STABLE NULL INSERT INTO VALUES FILE.
+  NOW TODAY IPTOKEN SEMI NONE PREV LINEAR IMPORT TBNAME JOIN STABLE NULL INSERT INTO VALUES FILE.

src/query/src/qSqlParser.c

@@ -161,9 +161,13 @@ tSqlExpr *tSqlExprCreateIdValue(SSqlInfo* pInfo, SStrToken *pToken, int32_t optr
     }
     pSqlExpr->tokenId = optrType;
     pSqlExpr->type    = SQL_NODE_VALUE;
-  } else if (optrType == TK_NOW) {
+  } else if (optrType == TK_NOW || optrType == TK_TODAY) {
     // use nanosecond by default TODO set value after getting database precision
-    pSqlExpr->value.i64 = taosGetTimestamp(TSDB_TIME_PRECISION_NANO);
+    if (optrType == TK_NOW) {
+      pSqlExpr->value.i64 = taosGetTimestamp(TSDB_TIME_PRECISION_NANO);
+    } else {
+      pSqlExpr->value.i64 = taosGetTimestampToday() * 1000000000;
+    }
     pSqlExpr->value.nType = TSDB_DATA_TYPE_BIGINT;
     pSqlExpr->tokenId = TK_TIMESTAMP;  // TK_TIMESTAMP used to denote the time value is in microsecond
     pSqlExpr->type    = SQL_NODE_VALUE;

src/util/src/ttokenizer.c

@@ -159,6 +159,7 @@ static SKeyword keywordTable[] = {
     {"SOFFSET",      TK_SOFFSET},
     {"WHERE",        TK_WHERE},
     {"NOW",          TK_NOW},
+    {"TODAY",        TK_TODAY},
     {"INSERT",       TK_INSERT},
     {"INTO",         TK_INTO},
     {"VALUES",       TK_VALUES},