add cachelast db option

src/client/src/tscSQLParser.c

@@ -5442,6 +5442,7 @@ static void setCreateDBOption(SCreateDbMsg* pMsg, SCreateDBInfo* pCreateDb) {
   pMsg->quorum = pCreateDb->quorum;
   pMsg->ignoreExist = pCreateDb->ignoreExists;
   pMsg->update = pCreateDb->update;
+  pMsg->cacheLastRow = pCreateDb->cachelast;
 }
 
 int32_t parseCreateDBOptions(SSqlCmd* pCmd, SCreateDBInfo* pCreateDbSql) {

src/inc/ttokendef.h

@@ -114,114 +114,115 @@
 #define TK_COMP                            96
 #define TK_PRECISION                       97
 #define TK_UPDATE                          98
-#define TK_LP                              99
-#define TK_RP                             100
-#define TK_TAGS                           101
-#define TK_USING                          102
-#define TK_AS                             103
-#define TK_COMMA                          104
-#define TK_NULL                           105
-#define TK_SELECT                         106
-#define TK_UNION                          107
-#define TK_ALL                            108
-#define TK_FROM                           109
-#define TK_VARIABLE                       110
-#define TK_INTERVAL                       111
-#define TK_FILL                           112
-#define TK_SLIDING                        113
-#define TK_ORDER                          114
-#define TK_BY                             115
-#define TK_ASC                            116
-#define TK_DESC                           117
-#define TK_GROUP                          118
-#define TK_HAVING                         119
-#define TK_LIMIT                          120
-#define TK_OFFSET                         121
-#define TK_SLIMIT                         122
-#define TK_SOFFSET                        123
-#define TK_WHERE                          124
-#define TK_NOW                            125
-#define TK_RESET                          126
-#define TK_QUERY                          127
-#define TK_ADD                            128
-#define TK_COLUMN                         129
-#define TK_TAG                            130
-#define TK_CHANGE                         131
-#define TK_SET                            132
-#define TK_KILL                           133
-#define TK_CONNECTION                     134
-#define TK_STREAM                         135
-#define TK_COLON                          136
-#define TK_ABORT                          137
-#define TK_AFTER                          138
-#define TK_ATTACH                         139
-#define TK_BEFORE                         140
-#define TK_BEGIN                          141
-#define TK_CASCADE                        142
-#define TK_CLUSTER                        143
-#define TK_CONFLICT                       144
-#define TK_COPY                           145
-#define TK_DEFERRED                       146
-#define TK_DELIMITERS                     147
-#define TK_DETACH                         148
-#define TK_EACH                           149
-#define TK_END                            150
-#define TK_EXPLAIN                        151
-#define TK_FAIL                           152
-#define TK_FOR                            153
-#define TK_IGNORE                         154
-#define TK_IMMEDIATE                      155
-#define TK_INITIALLY                      156
-#define TK_INSTEAD                        157
-#define TK_MATCH                          158
-#define TK_KEY                            159
-#define TK_OF                             160
-#define TK_RAISE                          161
-#define TK_REPLACE                        162
-#define TK_RESTRICT                       163
-#define TK_ROW                            164
-#define TK_STATEMENT                      165
-#define TK_TRIGGER                        166
-#define TK_VIEW                           167
-#define TK_COUNT                          168
-#define TK_SUM                            169
-#define TK_AVG                            170
-#define TK_MIN                            171
-#define TK_MAX                            172
-#define TK_FIRST                          173
-#define TK_LAST                           174
-#define TK_TOP                            175
-#define TK_BOTTOM                         176
-#define TK_STDDEV                         177
-#define TK_PERCENTILE                     178
-#define TK_APERCENTILE                    179
-#define TK_LEASTSQUARES                   180
-#define TK_HISTOGRAM                      181
-#define TK_DIFF                           182
-#define TK_SPREAD                         183
-#define TK_TWA                            184
-#define TK_INTERP                         185
-#define TK_LAST_ROW                       186
-#define TK_RATE                           187
-#define TK_IRATE                          188
-#define TK_SUM_RATE                       189
-#define TK_SUM_IRATE                      190
-#define TK_AVG_RATE                       191
-#define TK_AVG_IRATE                      192
-#define TK_TBID                           193
-#define TK_SEMI                           194
-#define TK_NONE                           195
-#define TK_PREV                           196
-#define TK_LINEAR                         197
-#define TK_IMPORT                         198
-#define TK_METRIC                         199
-#define TK_TBNAME                         200
-#define TK_JOIN                           201
-#define TK_METRICS                        202
-#define TK_STABLE                         203
-#define TK_INSERT                         204
-#define TK_INTO                           205
-#define TK_VALUES                         206
+#define TK_CACHELAST                       99
+#define TK_LP                             100
+#define TK_RP                             101
+#define TK_TAGS                           102
+#define TK_USING                          103
+#define TK_AS                             104
+#define TK_COMMA                          105
+#define TK_NULL                           106
+#define TK_SELECT                         107
+#define TK_UNION                          108
+#define TK_ALL                            109
+#define TK_FROM                           110
+#define TK_VARIABLE                       111
+#define TK_INTERVAL                       112
+#define TK_FILL                           113
+#define TK_SLIDING                        114
+#define TK_ORDER                          115
+#define TK_BY                             116
+#define TK_ASC                            117
+#define TK_DESC                           118
+#define TK_GROUP                          119
+#define TK_HAVING                         120
+#define TK_LIMIT                          121
+#define TK_OFFSET                         122
+#define TK_SLIMIT                         123
+#define TK_SOFFSET                        124
+#define TK_WHERE                          125
+#define TK_NOW                            126
+#define TK_RESET                          127
+#define TK_QUERY                          128
+#define TK_ADD                            129
+#define TK_COLUMN                         130
+#define TK_TAG                            131
+#define TK_CHANGE                         132
+#define TK_SET                            133
+#define TK_KILL                           134
+#define TK_CONNECTION                     135
+#define TK_STREAM                         136
+#define TK_COLON                          137
+#define TK_ABORT                          138
+#define TK_AFTER                          139
+#define TK_ATTACH                         140
+#define TK_BEFORE                         141
+#define TK_BEGIN                          142
+#define TK_CASCADE                        143
+#define TK_CLUSTER                        144
+#define TK_CONFLICT                       145
+#define TK_COPY                           146
+#define TK_DEFERRED                       147
+#define TK_DELIMITERS                     148
+#define TK_DETACH                         149
+#define TK_EACH                           150
+#define TK_END                            151
+#define TK_EXPLAIN                        152
+#define TK_FAIL                           153
+#define TK_FOR                            154
+#define TK_IGNORE                         155
+#define TK_IMMEDIATE                      156
+#define TK_INITIALLY                      157
+#define TK_INSTEAD                        158
+#define TK_MATCH                          159
+#define TK_KEY                            160
+#define TK_OF                             161
+#define TK_RAISE                          162
+#define TK_REPLACE                        163
+#define TK_RESTRICT                       164
+#define TK_ROW                            165
+#define TK_STATEMENT                      166
+#define TK_TRIGGER                        167
+#define TK_VIEW                           168
+#define TK_COUNT                          169
+#define TK_SUM                            170
+#define TK_AVG                            171
+#define TK_MIN                            172
+#define TK_MAX                            173
+#define TK_FIRST                          174
+#define TK_LAST                           175
+#define TK_TOP                            176
+#define TK_BOTTOM                         177
+#define TK_STDDEV                         178
+#define TK_PERCENTILE                     179
+#define TK_APERCENTILE                    180
+#define TK_LEASTSQUARES                   181
+#define TK_HISTOGRAM                      182
+#define TK_DIFF                           183
+#define TK_SPREAD                         184
+#define TK_TWA                            185
+#define TK_INTERP                         186
+#define TK_LAST_ROW                       187
+#define TK_RATE                           188
+#define TK_IRATE                          189
+#define TK_SUM_RATE                       190
+#define TK_SUM_IRATE                      191
+#define TK_AVG_RATE                       192
+#define TK_AVG_IRATE                      193
+#define TK_TBID                           194
+#define TK_SEMI                           195
+#define TK_NONE                           196
+#define TK_PREV                           197
+#define TK_LINEAR                         198
+#define TK_IMPORT                         199
+#define TK_METRIC                         200
+#define TK_TBNAME                         201
+#define TK_JOIN                           202
+#define TK_METRICS                        203
+#define TK_STABLE                         204
+#define TK_INSERT                         205
+#define TK_INTO                           206
+#define TK_VALUES                         207
 
 
 #define TK_SPACE                          300

src/query/inc/qSqlparser.h

@@ -120,7 +120,8 @@ typedef struct SCreateDBInfo {
   int32_t   compressionLevel;
   SStrToken precision;
   bool      ignoreExists;
-  int8_t    update; 
+  int8_t    update;
+  int8_t    cachelast; 
   
   SArray *keep;
 } SCreateDBInfo;

src/query/src/qParserImpl.c

@@ -841,5 +841,6 @@ void setDefaultCreateDbOption(SCreateDBInfo *pDBInfo) {
   pDBInfo->keep = NULL;
 
   pDBInfo->update = -1;
+  pDBInfo->cachelast = 0;
   memset(&pDBInfo->precision, 0, sizeof(SStrToken));
 }

src/query/src/qTokenizer.c

@@ -238,6 +238,7 @@ static SKeyword keywordTable[] = {
     {"SUM_IRATE",    TK_SUM_IRATE},
     {"AVG_RATE",     TK_AVG_RATE},
     {"AVG_IRATE",    TK_AVG_IRATE},
+    {"CACHELAST",    TK_CACHELAST},
 };
 
 static const char isIdChar[] = {