feat: sql command 'compact database'
This commit is contained in:
parent
5abaf4409d
commit
b52ebb6fd5
|
@ -16,330 +16,330 @@
|
||||||
#ifndef _TD_COMMON_TOKEN_H_
|
#ifndef _TD_COMMON_TOKEN_H_
|
||||||
#define _TD_COMMON_TOKEN_H_
|
#define _TD_COMMON_TOKEN_H_
|
||||||
|
|
||||||
#define TK_OR 1
|
#define TK_OR 1
|
||||||
#define TK_AND 2
|
#define TK_AND 2
|
||||||
#define TK_UNION 3
|
#define TK_UNION 3
|
||||||
#define TK_ALL 4
|
#define TK_ALL 4
|
||||||
#define TK_MINUS 5
|
#define TK_MINUS 5
|
||||||
#define TK_EXCEPT 6
|
#define TK_EXCEPT 6
|
||||||
#define TK_INTERSECT 7
|
#define TK_INTERSECT 7
|
||||||
#define TK_NK_BITAND 8
|
#define TK_NK_BITAND 8
|
||||||
#define TK_NK_BITOR 9
|
#define TK_NK_BITOR 9
|
||||||
#define TK_NK_LSHIFT 10
|
#define TK_NK_LSHIFT 10
|
||||||
#define TK_NK_RSHIFT 11
|
#define TK_NK_RSHIFT 11
|
||||||
#define TK_NK_PLUS 12
|
#define TK_NK_PLUS 12
|
||||||
#define TK_NK_MINUS 13
|
#define TK_NK_MINUS 13
|
||||||
#define TK_NK_STAR 14
|
#define TK_NK_STAR 14
|
||||||
#define TK_NK_SLASH 15
|
#define TK_NK_SLASH 15
|
||||||
#define TK_NK_REM 16
|
#define TK_NK_REM 16
|
||||||
#define TK_NK_CONCAT 17
|
#define TK_NK_CONCAT 17
|
||||||
#define TK_CREATE 18
|
#define TK_CREATE 18
|
||||||
#define TK_ACCOUNT 19
|
#define TK_ACCOUNT 19
|
||||||
#define TK_NK_ID 20
|
#define TK_NK_ID 20
|
||||||
#define TK_PASS 21
|
#define TK_PASS 21
|
||||||
#define TK_NK_STRING 22
|
#define TK_NK_STRING 22
|
||||||
#define TK_ALTER 23
|
#define TK_ALTER 23
|
||||||
#define TK_PPS 24
|
#define TK_PPS 24
|
||||||
#define TK_TSERIES 25
|
#define TK_TSERIES 25
|
||||||
#define TK_STORAGE 26
|
#define TK_STORAGE 26
|
||||||
#define TK_STREAMS 27
|
#define TK_STREAMS 27
|
||||||
#define TK_QTIME 28
|
#define TK_QTIME 28
|
||||||
#define TK_DBS 29
|
#define TK_DBS 29
|
||||||
#define TK_USERS 30
|
#define TK_USERS 30
|
||||||
#define TK_CONNS 31
|
#define TK_CONNS 31
|
||||||
#define TK_STATE 32
|
#define TK_STATE 32
|
||||||
#define TK_USER 33
|
#define TK_USER 33
|
||||||
#define TK_ENABLE 34
|
#define TK_ENABLE 34
|
||||||
#define TK_NK_INTEGER 35
|
#define TK_NK_INTEGER 35
|
||||||
#define TK_SYSINFO 36
|
#define TK_SYSINFO 36
|
||||||
#define TK_DROP 37
|
#define TK_DROP 37
|
||||||
#define TK_GRANT 38
|
#define TK_GRANT 38
|
||||||
#define TK_ON 39
|
#define TK_ON 39
|
||||||
#define TK_TO 40
|
#define TK_TO 40
|
||||||
#define TK_REVOKE 41
|
#define TK_REVOKE 41
|
||||||
#define TK_FROM 42
|
#define TK_FROM 42
|
||||||
#define TK_SUBSCRIBE 43
|
#define TK_SUBSCRIBE 43
|
||||||
#define TK_NK_COMMA 44
|
#define TK_NK_COMMA 44
|
||||||
#define TK_READ 45
|
#define TK_READ 45
|
||||||
#define TK_WRITE 46
|
#define TK_WRITE 46
|
||||||
#define TK_NK_DOT 47
|
#define TK_NK_DOT 47
|
||||||
#define TK_DNODE 48
|
#define TK_DNODE 48
|
||||||
#define TK_PORT 49
|
#define TK_PORT 49
|
||||||
#define TK_DNODES 50
|
#define TK_DNODES 50
|
||||||
#define TK_NK_IPTOKEN 51
|
#define TK_NK_IPTOKEN 51
|
||||||
#define TK_FORCE 52
|
#define TK_FORCE 52
|
||||||
#define TK_LOCAL 53
|
#define TK_LOCAL 53
|
||||||
#define TK_QNODE 54
|
#define TK_QNODE 54
|
||||||
#define TK_BNODE 55
|
#define TK_BNODE 55
|
||||||
#define TK_SNODE 56
|
#define TK_SNODE 56
|
||||||
#define TK_MNODE 57
|
#define TK_MNODE 57
|
||||||
#define TK_DATABASE 58
|
#define TK_DATABASE 58
|
||||||
#define TK_USE 59
|
#define TK_USE 59
|
||||||
#define TK_FLUSH 60
|
#define TK_FLUSH 60
|
||||||
#define TK_TRIM 61
|
#define TK_TRIM 61
|
||||||
#define TK_IF 62
|
#define TK_COMPACT 62
|
||||||
#define TK_NOT 63
|
#define TK_IF 63
|
||||||
#define TK_EXISTS 64
|
#define TK_NOT 64
|
||||||
#define TK_BUFFER 65
|
#define TK_EXISTS 65
|
||||||
#define TK_CACHEMODEL 66
|
#define TK_BUFFER 66
|
||||||
#define TK_CACHESIZE 67
|
#define TK_CACHEMODEL 67
|
||||||
#define TK_COMP 68
|
#define TK_CACHESIZE 68
|
||||||
#define TK_DURATION 69
|
#define TK_COMP 69
|
||||||
#define TK_NK_VARIABLE 70
|
#define TK_DURATION 70
|
||||||
#define TK_MAXROWS 71
|
#define TK_NK_VARIABLE 71
|
||||||
#define TK_MINROWS 72
|
#define TK_MAXROWS 72
|
||||||
#define TK_KEEP 73
|
#define TK_MINROWS 73
|
||||||
#define TK_PAGES 74
|
#define TK_KEEP 74
|
||||||
#define TK_PAGESIZE 75
|
#define TK_PAGES 75
|
||||||
#define TK_TSDB_PAGESIZE 76
|
#define TK_PAGESIZE 76
|
||||||
#define TK_PRECISION 77
|
#define TK_TSDB_PAGESIZE 77
|
||||||
#define TK_REPLICA 78
|
#define TK_PRECISION 78
|
||||||
#define TK_VGROUPS 79
|
#define TK_REPLICA 79
|
||||||
#define TK_SINGLE_STABLE 80
|
#define TK_VGROUPS 80
|
||||||
#define TK_RETENTIONS 81
|
#define TK_SINGLE_STABLE 81
|
||||||
#define TK_SCHEMALESS 82
|
#define TK_RETENTIONS 82
|
||||||
#define TK_WAL_LEVEL 83
|
#define TK_SCHEMALESS 83
|
||||||
#define TK_WAL_FSYNC_PERIOD 84
|
#define TK_WAL_LEVEL 84
|
||||||
#define TK_WAL_RETENTION_PERIOD 85
|
#define TK_WAL_FSYNC_PERIOD 85
|
||||||
#define TK_WAL_RETENTION_SIZE 86
|
#define TK_WAL_RETENTION_PERIOD 86
|
||||||
#define TK_WAL_ROLL_PERIOD 87
|
#define TK_WAL_RETENTION_SIZE 87
|
||||||
#define TK_WAL_SEGMENT_SIZE 88
|
#define TK_WAL_ROLL_PERIOD 88
|
||||||
#define TK_STT_TRIGGER 89
|
#define TK_WAL_SEGMENT_SIZE 89
|
||||||
#define TK_TABLE_PREFIX 90
|
#define TK_STT_TRIGGER 90
|
||||||
#define TK_TABLE_SUFFIX 91
|
#define TK_TABLE_PREFIX 91
|
||||||
#define TK_NK_COLON 92
|
#define TK_TABLE_SUFFIX 92
|
||||||
#define TK_MAX_SPEED 93
|
#define TK_NK_COLON 93
|
||||||
#define TK_TABLE 94
|
#define TK_MAX_SPEED 94
|
||||||
#define TK_NK_LP 95
|
#define TK_TABLE 95
|
||||||
#define TK_NK_RP 96
|
#define TK_NK_LP 96
|
||||||
#define TK_STABLE 97
|
#define TK_NK_RP 97
|
||||||
#define TK_ADD 98
|
#define TK_STABLE 98
|
||||||
#define TK_COLUMN 99
|
#define TK_ADD 99
|
||||||
#define TK_MODIFY 100
|
#define TK_COLUMN 100
|
||||||
#define TK_RENAME 101
|
#define TK_MODIFY 101
|
||||||
#define TK_TAG 102
|
#define TK_RENAME 102
|
||||||
#define TK_SET 103
|
#define TK_TAG 103
|
||||||
#define TK_NK_EQ 104
|
#define TK_SET 104
|
||||||
#define TK_USING 105
|
#define TK_NK_EQ 105
|
||||||
#define TK_TAGS 106
|
#define TK_USING 106
|
||||||
#define TK_COMMENT 107
|
#define TK_TAGS 107
|
||||||
#define TK_BOOL 108
|
#define TK_COMMENT 108
|
||||||
#define TK_TINYINT 109
|
#define TK_BOOL 109
|
||||||
#define TK_SMALLINT 110
|
#define TK_TINYINT 110
|
||||||
#define TK_INT 111
|
#define TK_SMALLINT 111
|
||||||
#define TK_INTEGER 112
|
#define TK_INT 112
|
||||||
#define TK_BIGINT 113
|
#define TK_INTEGER 113
|
||||||
#define TK_FLOAT 114
|
#define TK_BIGINT 114
|
||||||
#define TK_DOUBLE 115
|
#define TK_FLOAT 115
|
||||||
#define TK_BINARY 116
|
#define TK_DOUBLE 116
|
||||||
#define TK_TIMESTAMP 117
|
#define TK_BINARY 117
|
||||||
#define TK_NCHAR 118
|
#define TK_TIMESTAMP 118
|
||||||
#define TK_UNSIGNED 119
|
#define TK_NCHAR 119
|
||||||
#define TK_JSON 120
|
#define TK_UNSIGNED 120
|
||||||
#define TK_VARCHAR 121
|
#define TK_JSON 121
|
||||||
#define TK_MEDIUMBLOB 122
|
#define TK_VARCHAR 122
|
||||||
#define TK_BLOB 123
|
#define TK_MEDIUMBLOB 123
|
||||||
#define TK_VARBINARY 124
|
#define TK_BLOB 124
|
||||||
#define TK_DECIMAL 125
|
#define TK_VARBINARY 125
|
||||||
#define TK_MAX_DELAY 126
|
#define TK_DECIMAL 126
|
||||||
#define TK_WATERMARK 127
|
#define TK_MAX_DELAY 127
|
||||||
#define TK_ROLLUP 128
|
#define TK_WATERMARK 128
|
||||||
#define TK_TTL 129
|
#define TK_ROLLUP 129
|
||||||
#define TK_SMA 130
|
#define TK_TTL 130
|
||||||
#define TK_DELETE_MARK 131
|
#define TK_SMA 131
|
||||||
#define TK_FIRST 132
|
#define TK_DELETE_MARK 132
|
||||||
#define TK_LAST 133
|
#define TK_FIRST 133
|
||||||
#define TK_SHOW 134
|
#define TK_LAST 134
|
||||||
#define TK_PRIVILEGES 135
|
#define TK_SHOW 135
|
||||||
#define TK_DATABASES 136
|
#define TK_PRIVILEGES 136
|
||||||
#define TK_TABLES 137
|
#define TK_DATABASES 137
|
||||||
#define TK_STABLES 138
|
#define TK_TABLES 138
|
||||||
#define TK_MNODES 139
|
#define TK_STABLES 139
|
||||||
#define TK_QNODES 140
|
#define TK_MNODES 140
|
||||||
#define TK_FUNCTIONS 141
|
#define TK_QNODES 141
|
||||||
#define TK_INDEXES 142
|
#define TK_FUNCTIONS 142
|
||||||
#define TK_ACCOUNTS 143
|
#define TK_INDEXES 143
|
||||||
#define TK_APPS 144
|
#define TK_ACCOUNTS 144
|
||||||
#define TK_CONNECTIONS 145
|
#define TK_APPS 145
|
||||||
#define TK_LICENCES 146
|
#define TK_CONNECTIONS 146
|
||||||
#define TK_GRANTS 147
|
#define TK_LICENCES 147
|
||||||
#define TK_QUERIES 148
|
#define TK_GRANTS 148
|
||||||
#define TK_SCORES 149
|
#define TK_QUERIES 149
|
||||||
#define TK_TOPICS 150
|
#define TK_SCORES 150
|
||||||
#define TK_VARIABLES 151
|
#define TK_TOPICS 151
|
||||||
#define TK_CLUSTER 152
|
#define TK_VARIABLES 152
|
||||||
#define TK_BNODES 153
|
#define TK_CLUSTER 153
|
||||||
#define TK_SNODES 154
|
#define TK_BNODES 154
|
||||||
#define TK_TRANSACTIONS 155
|
#define TK_SNODES 155
|
||||||
#define TK_DISTRIBUTED 156
|
#define TK_TRANSACTIONS 156
|
||||||
#define TK_CONSUMERS 157
|
#define TK_DISTRIBUTED 157
|
||||||
#define TK_SUBSCRIPTIONS 158
|
#define TK_CONSUMERS 158
|
||||||
#define TK_VNODES 159
|
#define TK_SUBSCRIPTIONS 159
|
||||||
#define TK_LIKE 160
|
#define TK_VNODES 160
|
||||||
#define TK_TBNAME 161
|
#define TK_LIKE 161
|
||||||
#define TK_QTAGS 162
|
#define TK_TBNAME 162
|
||||||
#define TK_AS 163
|
#define TK_QTAGS 163
|
||||||
#define TK_INDEX 164
|
#define TK_AS 164
|
||||||
#define TK_FUNCTION 165
|
#define TK_INDEX 165
|
||||||
#define TK_INTERVAL 166
|
#define TK_FUNCTION 166
|
||||||
#define TK_COUNT 167
|
#define TK_INTERVAL 167
|
||||||
#define TK_LAST_ROW 168
|
#define TK_COUNT 168
|
||||||
#define TK_TOPIC 169
|
#define TK_LAST_ROW 169
|
||||||
#define TK_WITH 170
|
#define TK_TOPIC 170
|
||||||
#define TK_META 171
|
#define TK_WITH 171
|
||||||
#define TK_CONSUMER 172
|
#define TK_META 172
|
||||||
#define TK_GROUP 173
|
#define TK_CONSUMER 173
|
||||||
#define TK_DESC 174
|
#define TK_GROUP 174
|
||||||
#define TK_DESCRIBE 175
|
#define TK_DESC 175
|
||||||
#define TK_RESET 176
|
#define TK_DESCRIBE 176
|
||||||
#define TK_QUERY 177
|
#define TK_RESET 177
|
||||||
#define TK_CACHE 178
|
#define TK_QUERY 178
|
||||||
#define TK_EXPLAIN 179
|
#define TK_CACHE 179
|
||||||
#define TK_ANALYZE 180
|
#define TK_EXPLAIN 180
|
||||||
#define TK_VERBOSE 181
|
#define TK_ANALYZE 181
|
||||||
#define TK_NK_BOOL 182
|
#define TK_VERBOSE 182
|
||||||
#define TK_RATIO 183
|
#define TK_NK_BOOL 183
|
||||||
#define TK_NK_FLOAT 184
|
#define TK_RATIO 184
|
||||||
#define TK_OUTPUTTYPE 185
|
#define TK_NK_FLOAT 185
|
||||||
#define TK_AGGREGATE 186
|
#define TK_OUTPUTTYPE 186
|
||||||
#define TK_BUFSIZE 187
|
#define TK_AGGREGATE 187
|
||||||
#define TK_STREAM 188
|
#define TK_BUFSIZE 188
|
||||||
#define TK_INTO 189
|
#define TK_STREAM 189
|
||||||
#define TK_TRIGGER 190
|
#define TK_INTO 190
|
||||||
#define TK_AT_ONCE 191
|
#define TK_TRIGGER 191
|
||||||
#define TK_WINDOW_CLOSE 192
|
#define TK_AT_ONCE 192
|
||||||
#define TK_IGNORE 193
|
#define TK_WINDOW_CLOSE 193
|
||||||
#define TK_EXPIRED 194
|
#define TK_IGNORE 194
|
||||||
#define TK_FILL_HISTORY 195
|
#define TK_EXPIRED 195
|
||||||
#define TK_SUBTABLE 196
|
#define TK_FILL_HISTORY 196
|
||||||
#define TK_KILL 197
|
#define TK_SUBTABLE 197
|
||||||
#define TK_CONNECTION 198
|
#define TK_KILL 198
|
||||||
#define TK_TRANSACTION 199
|
#define TK_CONNECTION 199
|
||||||
#define TK_BALANCE 200
|
#define TK_TRANSACTION 200
|
||||||
#define TK_VGROUP 201
|
#define TK_BALANCE 201
|
||||||
#define TK_MERGE 202
|
#define TK_VGROUP 202
|
||||||
#define TK_REDISTRIBUTE 203
|
#define TK_MERGE 203
|
||||||
#define TK_SPLIT 204
|
#define TK_REDISTRIBUTE 204
|
||||||
#define TK_DELETE 205
|
#define TK_SPLIT 205
|
||||||
#define TK_INSERT 206
|
#define TK_DELETE 206
|
||||||
#define TK_NULL 207
|
#define TK_INSERT 207
|
||||||
#define TK_NK_QUESTION 208
|
#define TK_NULL 208
|
||||||
#define TK_NK_ARROW 209
|
#define TK_NK_QUESTION 209
|
||||||
#define TK_ROWTS 210
|
#define TK_NK_ARROW 210
|
||||||
#define TK_QSTART 211
|
#define TK_ROWTS 211
|
||||||
#define TK_QEND 212
|
#define TK_QSTART 212
|
||||||
#define TK_QDURATION 213
|
#define TK_QEND 213
|
||||||
#define TK_WSTART 214
|
#define TK_QDURATION 214
|
||||||
#define TK_WEND 215
|
#define TK_WSTART 215
|
||||||
#define TK_WDURATION 216
|
#define TK_WEND 216
|
||||||
#define TK_IROWTS 217
|
#define TK_WDURATION 217
|
||||||
#define TK_ISFILLED 218
|
#define TK_IROWTS 218
|
||||||
#define TK_CAST 219
|
#define TK_ISFILLED 219
|
||||||
#define TK_NOW 220
|
#define TK_CAST 220
|
||||||
#define TK_TODAY 221
|
#define TK_NOW 221
|
||||||
#define TK_TIMEZONE 222
|
#define TK_TODAY 222
|
||||||
#define TK_CLIENT_VERSION 223
|
#define TK_TIMEZONE 223
|
||||||
#define TK_SERVER_VERSION 224
|
#define TK_CLIENT_VERSION 224
|
||||||
#define TK_SERVER_STATUS 225
|
#define TK_SERVER_VERSION 225
|
||||||
#define TK_CURRENT_USER 226
|
#define TK_SERVER_STATUS 226
|
||||||
#define TK_CASE 227
|
#define TK_CURRENT_USER 227
|
||||||
#define TK_END 228
|
#define TK_CASE 228
|
||||||
#define TK_WHEN 229
|
#define TK_END 229
|
||||||
#define TK_THEN 230
|
#define TK_WHEN 230
|
||||||
#define TK_ELSE 231
|
#define TK_THEN 231
|
||||||
#define TK_BETWEEN 232
|
#define TK_ELSE 232
|
||||||
#define TK_IS 233
|
#define TK_BETWEEN 233
|
||||||
#define TK_NK_LT 234
|
#define TK_IS 234
|
||||||
#define TK_NK_GT 235
|
#define TK_NK_LT 235
|
||||||
#define TK_NK_LE 236
|
#define TK_NK_GT 236
|
||||||
#define TK_NK_GE 237
|
#define TK_NK_LE 237
|
||||||
#define TK_NK_NE 238
|
#define TK_NK_GE 238
|
||||||
#define TK_MATCH 239
|
#define TK_NK_NE 239
|
||||||
#define TK_NMATCH 240
|
#define TK_MATCH 240
|
||||||
#define TK_CONTAINS 241
|
#define TK_NMATCH 241
|
||||||
#define TK_IN 242
|
#define TK_CONTAINS 242
|
||||||
#define TK_JOIN 243
|
#define TK_IN 243
|
||||||
#define TK_INNER 244
|
#define TK_JOIN 244
|
||||||
#define TK_SELECT 245
|
#define TK_INNER 245
|
||||||
#define TK_DISTINCT 246
|
#define TK_SELECT 246
|
||||||
#define TK_WHERE 247
|
#define TK_DISTINCT 247
|
||||||
#define TK_PARTITION 248
|
#define TK_WHERE 248
|
||||||
#define TK_BY 249
|
#define TK_PARTITION 249
|
||||||
#define TK_SESSION 250
|
#define TK_BY 250
|
||||||
#define TK_STATE_WINDOW 251
|
#define TK_SESSION 251
|
||||||
#define TK_EVENT_WINDOW 252
|
#define TK_STATE_WINDOW 252
|
||||||
#define TK_START 253
|
#define TK_EVENT_WINDOW 253
|
||||||
#define TK_SLIDING 254
|
#define TK_START 254
|
||||||
#define TK_FILL 255
|
#define TK_SLIDING 255
|
||||||
#define TK_VALUE 256
|
#define TK_FILL 256
|
||||||
#define TK_NONE 257
|
#define TK_VALUE 257
|
||||||
#define TK_PREV 258
|
#define TK_NONE 258
|
||||||
#define TK_LINEAR 259
|
#define TK_PREV 259
|
||||||
#define TK_NEXT 260
|
#define TK_LINEAR 260
|
||||||
#define TK_HAVING 261
|
#define TK_NEXT 261
|
||||||
#define TK_RANGE 262
|
#define TK_HAVING 262
|
||||||
#define TK_EVERY 263
|
#define TK_RANGE 263
|
||||||
#define TK_ORDER 264
|
#define TK_EVERY 264
|
||||||
#define TK_SLIMIT 265
|
#define TK_ORDER 265
|
||||||
#define TK_SOFFSET 266
|
#define TK_SLIMIT 266
|
||||||
#define TK_LIMIT 267
|
#define TK_SOFFSET 267
|
||||||
#define TK_OFFSET 268
|
#define TK_LIMIT 268
|
||||||
#define TK_ASC 269
|
#define TK_OFFSET 269
|
||||||
#define TK_NULLS 270
|
#define TK_ASC 270
|
||||||
#define TK_ABORT 271
|
#define TK_NULLS 271
|
||||||
#define TK_AFTER 272
|
#define TK_ABORT 272
|
||||||
#define TK_ATTACH 273
|
#define TK_AFTER 273
|
||||||
#define TK_BEFORE 274
|
#define TK_ATTACH 274
|
||||||
#define TK_BEGIN 275
|
#define TK_BEFORE 275
|
||||||
#define TK_BITAND 276
|
#define TK_BEGIN 276
|
||||||
#define TK_BITNOT 277
|
#define TK_BITAND 277
|
||||||
#define TK_BITOR 278
|
#define TK_BITNOT 278
|
||||||
#define TK_BLOCKS 279
|
#define TK_BITOR 279
|
||||||
#define TK_CHANGE 280
|
#define TK_BLOCKS 280
|
||||||
#define TK_COMMA 281
|
#define TK_CHANGE 281
|
||||||
#define TK_COMPACT 282
|
#define TK_COMMA 282
|
||||||
#define TK_CONCAT 283
|
#define TK_CONCAT 283
|
||||||
#define TK_CONFLICT 284
|
#define TK_CONFLICT 284
|
||||||
#define TK_COPY 285
|
#define TK_COPY 285
|
||||||
#define TK_DEFERRED 286
|
#define TK_DEFERRED 286
|
||||||
#define TK_DELIMITERS 287
|
#define TK_DELIMITERS 287
|
||||||
#define TK_DETACH 288
|
#define TK_DETACH 288
|
||||||
#define TK_DIVIDE 289
|
#define TK_DIVIDE 289
|
||||||
#define TK_DOT 290
|
#define TK_DOT 290
|
||||||
#define TK_EACH 291
|
#define TK_EACH 291
|
||||||
#define TK_FAIL 292
|
#define TK_FAIL 292
|
||||||
#define TK_FILE 293
|
#define TK_FILE 293
|
||||||
#define TK_FOR 294
|
#define TK_FOR 294
|
||||||
#define TK_GLOB 295
|
#define TK_GLOB 295
|
||||||
#define TK_ID 296
|
#define TK_ID 296
|
||||||
#define TK_IMMEDIATE 297
|
#define TK_IMMEDIATE 297
|
||||||
#define TK_IMPORT 298
|
#define TK_IMPORT 298
|
||||||
#define TK_INITIALLY 299
|
#define TK_INITIALLY 299
|
||||||
#define TK_INSTEAD 300
|
#define TK_INSTEAD 300
|
||||||
#define TK_ISNULL 301
|
#define TK_ISNULL 301
|
||||||
#define TK_KEY 302
|
#define TK_KEY 302
|
||||||
#define TK_MODULES 303
|
#define TK_MODULES 303
|
||||||
#define TK_NK_BITNOT 304
|
#define TK_NK_BITNOT 304
|
||||||
#define TK_NK_SEMI 305
|
#define TK_NK_SEMI 305
|
||||||
#define TK_NOTNULL 306
|
#define TK_NOTNULL 306
|
||||||
#define TK_OF 307
|
#define TK_OF 307
|
||||||
#define TK_PLUS 308
|
#define TK_PLUS 308
|
||||||
#define TK_PRIVILEGE 309
|
#define TK_PRIVILEGE 309
|
||||||
#define TK_RAISE 310
|
#define TK_RAISE 310
|
||||||
#define TK_REPLACE 311
|
#define TK_REPLACE 311
|
||||||
#define TK_RESTRICT 312
|
#define TK_RESTRICT 312
|
||||||
#define TK_ROW 313
|
#define TK_ROW 313
|
||||||
#define TK_SEMI 314
|
#define TK_SEMI 314
|
||||||
#define TK_STAR 315
|
#define TK_STAR 315
|
||||||
#define TK_STATEMENT 316
|
#define TK_STATEMENT 316
|
||||||
#define TK_STRICT 317
|
#define TK_STRICT 317
|
||||||
#define TK_STRING 318
|
#define TK_STRING 318
|
||||||
#define TK_TIMES 319
|
#define TK_TIMES 319
|
||||||
#define TK_UPDATE 320
|
#define TK_UPDATE 320
|
||||||
#define TK_VALUES 321
|
#define TK_VALUES 321
|
||||||
#define TK_VARIABLE 322
|
#define TK_VARIABLE 322
|
||||||
#define TK_VIEW 323
|
#define TK_VIEW 323
|
||||||
#define TK_WAL 324
|
#define TK_WAL 324
|
||||||
|
|
||||||
#define TK_NK_SPACE 600
|
#define TK_NK_SPACE 600
|
||||||
#define TK_NK_COMMENT 601
|
#define TK_NK_COMMENT 601
|
||||||
|
|
|
@ -123,6 +123,11 @@ typedef struct STrimDatabaseStmt {
|
||||||
int32_t maxSpeed;
|
int32_t maxSpeed;
|
||||||
} STrimDatabaseStmt;
|
} STrimDatabaseStmt;
|
||||||
|
|
||||||
|
typedef struct SCompactDatabaseStmt {
|
||||||
|
ENodeType type;
|
||||||
|
char dbName[TSDB_DB_NAME_LEN];
|
||||||
|
} SCompactDatabaseStmt;
|
||||||
|
|
||||||
typedef struct STableOptions {
|
typedef struct STableOptions {
|
||||||
ENodeType type;
|
ENodeType type;
|
||||||
bool commentNull;
|
bool commentNull;
|
||||||
|
|
|
@ -155,7 +155,7 @@ typedef enum ENodeType {
|
||||||
QUERY_NODE_EXPLAIN_STMT,
|
QUERY_NODE_EXPLAIN_STMT,
|
||||||
QUERY_NODE_DESCRIBE_STMT,
|
QUERY_NODE_DESCRIBE_STMT,
|
||||||
QUERY_NODE_RESET_QUERY_CACHE_STMT,
|
QUERY_NODE_RESET_QUERY_CACHE_STMT,
|
||||||
QUERY_NODE_COMPACT_STMT,
|
QUERY_NODE_COMPACT_DATABASE_STMT,
|
||||||
QUERY_NODE_CREATE_FUNCTION_STMT,
|
QUERY_NODE_CREATE_FUNCTION_STMT,
|
||||||
QUERY_NODE_DROP_FUNCTION_STMT,
|
QUERY_NODE_DROP_FUNCTION_STMT,
|
||||||
QUERY_NODE_CREATE_STREAM_STMT,
|
QUERY_NODE_CREATE_STREAM_STMT,
|
||||||
|
|
|
@ -165,6 +165,8 @@ const char* nodesNodeName(ENodeType type) {
|
||||||
return "ExplainStmt";
|
return "ExplainStmt";
|
||||||
case QUERY_NODE_DESCRIBE_STMT:
|
case QUERY_NODE_DESCRIBE_STMT:
|
||||||
return "DescribeStmt";
|
return "DescribeStmt";
|
||||||
|
case QUERY_NODE_COMPACT_DATABASE_STMT:
|
||||||
|
return "CompactDatabaseStmt";
|
||||||
case QUERY_NODE_CREATE_STREAM_STMT:
|
case QUERY_NODE_CREATE_STREAM_STMT:
|
||||||
return "CreateStreamStmt";
|
return "CreateStreamStmt";
|
||||||
case QUERY_NODE_DROP_STREAM_STMT:
|
case QUERY_NODE_DROP_STREAM_STMT:
|
||||||
|
@ -5675,6 +5677,18 @@ static int32_t jsonToDescribeStmt(const SJson* pJson, void* pObj) {
|
||||||
return code;
|
return code;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
static const char* jkCompactDatabaseStmtDbName = "DbName";
|
||||||
|
|
||||||
|
static int32_t compactDatabaseStmtToJson(const void* pObj, SJson* pJson) {
|
||||||
|
const SCompactDatabaseStmt* pNode = (const SCompactDatabaseStmt*)pObj;
|
||||||
|
return tjsonAddStringToObject(pJson, jkCompactDatabaseStmtDbName, pNode->dbName);
|
||||||
|
}
|
||||||
|
|
||||||
|
static int32_t jsonToCompactDatabaseStmt(const SJson* pJson, void* pObj) {
|
||||||
|
SCompactDatabaseStmt* pNode = (SCompactDatabaseStmt*)pObj;
|
||||||
|
return tjsonGetStringValue(pJson, jkCompactDatabaseStmtDbName, pNode->dbName);
|
||||||
|
}
|
||||||
|
|
||||||
static const char* jkCreateStreamStmtStreamName = "StreamName";
|
static const char* jkCreateStreamStmtStreamName = "StreamName";
|
||||||
static const char* jkCreateStreamStmtTargetDbName = "TargetDbName";
|
static const char* jkCreateStreamStmtTargetDbName = "TargetDbName";
|
||||||
static const char* jkCreateStreamStmtTargetTabName = "TargetTabName";
|
static const char* jkCreateStreamStmtTargetTabName = "TargetTabName";
|
||||||
|
@ -6386,6 +6400,8 @@ static int32_t specificNodeToJson(const void* pObj, SJson* pJson) {
|
||||||
return explainStmtToJson(pObj, pJson);
|
return explainStmtToJson(pObj, pJson);
|
||||||
case QUERY_NODE_DESCRIBE_STMT:
|
case QUERY_NODE_DESCRIBE_STMT:
|
||||||
return describeStmtToJson(pObj, pJson);
|
return describeStmtToJson(pObj, pJson);
|
||||||
|
case QUERY_NODE_COMPACT_DATABASE_STMT:
|
||||||
|
return compactDatabaseStmtToJson(pObj, pJson);
|
||||||
case QUERY_NODE_CREATE_STREAM_STMT:
|
case QUERY_NODE_CREATE_STREAM_STMT:
|
||||||
return createStreamStmtToJson(pObj, pJson);
|
return createStreamStmtToJson(pObj, pJson);
|
||||||
case QUERY_NODE_DROP_STREAM_STMT:
|
case QUERY_NODE_DROP_STREAM_STMT:
|
||||||
|
@ -6692,6 +6708,8 @@ static int32_t jsonToSpecificNode(const SJson* pJson, void* pObj) {
|
||||||
return jsonToExplainStmt(pJson, pObj);
|
return jsonToExplainStmt(pJson, pObj);
|
||||||
case QUERY_NODE_DESCRIBE_STMT:
|
case QUERY_NODE_DESCRIBE_STMT:
|
||||||
return jsonToDescribeStmt(pJson, pObj);
|
return jsonToDescribeStmt(pJson, pObj);
|
||||||
|
case QUERY_NODE_COMPACT_DATABASE_STMT:
|
||||||
|
return jsonToCompactDatabaseStmt(pJson, pObj);
|
||||||
case QUERY_NODE_CREATE_STREAM_STMT:
|
case QUERY_NODE_CREATE_STREAM_STMT:
|
||||||
return jsonToCreateStreamStmt(pJson, pObj);
|
return jsonToCreateStreamStmt(pJson, pObj);
|
||||||
case QUERY_NODE_DROP_STREAM_STMT:
|
case QUERY_NODE_DROP_STREAM_STMT:
|
||||||
|
|
|
@ -374,8 +374,8 @@ SNode* nodesMakeNode(ENodeType type) {
|
||||||
return makeNode(type, sizeof(SDescribeStmt));
|
return makeNode(type, sizeof(SDescribeStmt));
|
||||||
case QUERY_NODE_RESET_QUERY_CACHE_STMT:
|
case QUERY_NODE_RESET_QUERY_CACHE_STMT:
|
||||||
return makeNode(type, sizeof(SNode));
|
return makeNode(type, sizeof(SNode));
|
||||||
case QUERY_NODE_COMPACT_STMT:
|
case QUERY_NODE_COMPACT_DATABASE_STMT:
|
||||||
break;
|
return makeNode(type, sizeof(SCompactDatabaseStmt));
|
||||||
case QUERY_NODE_CREATE_FUNCTION_STMT:
|
case QUERY_NODE_CREATE_FUNCTION_STMT:
|
||||||
return makeNode(type, sizeof(SCreateFunctionStmt));
|
return makeNode(type, sizeof(SCreateFunctionStmt));
|
||||||
case QUERY_NODE_DROP_FUNCTION_STMT:
|
case QUERY_NODE_DROP_FUNCTION_STMT:
|
||||||
|
@ -919,7 +919,7 @@ void nodesDestroyNode(SNode* pNode) {
|
||||||
taosMemoryFree(((SDescribeStmt*)pNode)->pMeta);
|
taosMemoryFree(((SDescribeStmt*)pNode)->pMeta);
|
||||||
break;
|
break;
|
||||||
case QUERY_NODE_RESET_QUERY_CACHE_STMT: // no pointer field
|
case QUERY_NODE_RESET_QUERY_CACHE_STMT: // no pointer field
|
||||||
case QUERY_NODE_COMPACT_STMT: // no pointer field
|
case QUERY_NODE_COMPACT_DATABASE_STMT: // no pointer field
|
||||||
case QUERY_NODE_CREATE_FUNCTION_STMT: // no pointer field
|
case QUERY_NODE_CREATE_FUNCTION_STMT: // no pointer field
|
||||||
case QUERY_NODE_DROP_FUNCTION_STMT: // no pointer field
|
case QUERY_NODE_DROP_FUNCTION_STMT: // no pointer field
|
||||||
break;
|
break;
|
||||||
|
|
|
@ -151,6 +151,7 @@ SNode* createDropDatabaseStmt(SAstCreateContext* pCxt, bool ignoreNotExists, STo
|
||||||
SNode* createAlterDatabaseStmt(SAstCreateContext* pCxt, SToken* pDbName, SNode* pOptions);
|
SNode* createAlterDatabaseStmt(SAstCreateContext* pCxt, SToken* pDbName, SNode* pOptions);
|
||||||
SNode* createFlushDatabaseStmt(SAstCreateContext* pCxt, SToken* pDbName);
|
SNode* createFlushDatabaseStmt(SAstCreateContext* pCxt, SToken* pDbName);
|
||||||
SNode* createTrimDatabaseStmt(SAstCreateContext* pCxt, SToken* pDbName, int32_t maxSpeed);
|
SNode* createTrimDatabaseStmt(SAstCreateContext* pCxt, SToken* pDbName, int32_t maxSpeed);
|
||||||
|
SNode* createCompactStmt(SAstCreateContext* pCxt, SToken* pDbName);
|
||||||
SNode* createDefaultTableOptions(SAstCreateContext* pCxt);
|
SNode* createDefaultTableOptions(SAstCreateContext* pCxt);
|
||||||
SNode* createAlterTableOptions(SAstCreateContext* pCxt);
|
SNode* createAlterTableOptions(SAstCreateContext* pCxt);
|
||||||
SNode* setTableOption(SAstCreateContext* pCxt, SNode* pOptions, ETableOptionType type, void* pVal);
|
SNode* setTableOption(SAstCreateContext* pCxt, SNode* pOptions, ETableOptionType type, void* pVal);
|
||||||
|
@ -210,7 +211,6 @@ SNode* setExplainRatio(SAstCreateContext* pCxt, SNode* pOptions, const SToken* p
|
||||||
SNode* createExplainStmt(SAstCreateContext* pCxt, bool analyze, SNode* pOptions, SNode* pQuery);
|
SNode* createExplainStmt(SAstCreateContext* pCxt, bool analyze, SNode* pOptions, SNode* pQuery);
|
||||||
SNode* createDescribeStmt(SAstCreateContext* pCxt, SNode* pRealTable);
|
SNode* createDescribeStmt(SAstCreateContext* pCxt, SNode* pRealTable);
|
||||||
SNode* createResetQueryCacheStmt(SAstCreateContext* pCxt);
|
SNode* createResetQueryCacheStmt(SAstCreateContext* pCxt);
|
||||||
SNode* createCompactStmt(SAstCreateContext* pCxt, SNodeList* pVgroups);
|
|
||||||
SNode* createCreateFunctionStmt(SAstCreateContext* pCxt, bool ignoreExists, bool aggFunc, const SToken* pFuncName,
|
SNode* createCreateFunctionStmt(SAstCreateContext* pCxt, bool ignoreExists, bool aggFunc, const SToken* pFuncName,
|
||||||
const SToken* pLibPath, SDataType dataType, int32_t bufSize);
|
const SToken* pLibPath, SDataType dataType, int32_t bufSize);
|
||||||
SNode* createDropFunctionStmt(SAstCreateContext* pCxt, bool ignoreNotExists, const SToken* pFuncName);
|
SNode* createDropFunctionStmt(SAstCreateContext* pCxt, bool ignoreNotExists, const SToken* pFuncName);
|
||||||
|
|
|
@ -167,6 +167,7 @@ cmd ::= USE db_name(A).
|
||||||
cmd ::= ALTER DATABASE db_name(A) alter_db_options(B). { pCxt->pRootNode = createAlterDatabaseStmt(pCxt, &A, B); }
|
cmd ::= ALTER DATABASE db_name(A) alter_db_options(B). { pCxt->pRootNode = createAlterDatabaseStmt(pCxt, &A, B); }
|
||||||
cmd ::= FLUSH DATABASE db_name(A). { pCxt->pRootNode = createFlushDatabaseStmt(pCxt, &A); }
|
cmd ::= FLUSH DATABASE db_name(A). { pCxt->pRootNode = createFlushDatabaseStmt(pCxt, &A); }
|
||||||
cmd ::= TRIM DATABASE db_name(A) speed_opt(B). { pCxt->pRootNode = createTrimDatabaseStmt(pCxt, &A, B); }
|
cmd ::= TRIM DATABASE db_name(A) speed_opt(B). { pCxt->pRootNode = createTrimDatabaseStmt(pCxt, &A, B); }
|
||||||
|
cmd ::= COMPACT DATABASE db_name(A). { pCxt->pRootNode = createCompactStmt(pCxt, &A); }
|
||||||
|
|
||||||
%type not_exists_opt { bool }
|
%type not_exists_opt { bool }
|
||||||
%destructor not_exists_opt { }
|
%destructor not_exists_opt { }
|
||||||
|
@ -519,9 +520,6 @@ explain_options(A) ::= .
|
||||||
explain_options(A) ::= explain_options(B) VERBOSE NK_BOOL(C). { A = setExplainVerbose(pCxt, B, &C); }
|
explain_options(A) ::= explain_options(B) VERBOSE NK_BOOL(C). { A = setExplainVerbose(pCxt, B, &C); }
|
||||||
explain_options(A) ::= explain_options(B) RATIO NK_FLOAT(C). { A = setExplainRatio(pCxt, B, &C); }
|
explain_options(A) ::= explain_options(B) RATIO NK_FLOAT(C). { A = setExplainRatio(pCxt, B, &C); }
|
||||||
|
|
||||||
/************************************************ compact *************************************************************/
|
|
||||||
//cmd ::= COMPACT VNODES IN NK_LP integer_list NK_RP. { pCxt->errCode = generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_PAR_EXPRIE_STATEMENT); }
|
|
||||||
|
|
||||||
/************************************************ create/drop function ************************************************/
|
/************************************************ create/drop function ************************************************/
|
||||||
cmd ::= CREATE agg_func_opt(A) FUNCTION not_exists_opt(F) function_name(B)
|
cmd ::= CREATE agg_func_opt(A) FUNCTION not_exists_opt(F) function_name(B)
|
||||||
AS NK_STRING(C) OUTPUTTYPE type_name(D) bufsize_opt(E). { pCxt->pRootNode = createCreateFunctionStmt(pCxt, F, A, &B, &C, D, E); }
|
AS NK_STRING(C) OUTPUTTYPE type_name(D) bufsize_opt(E). { pCxt->pRootNode = createCreateFunctionStmt(pCxt, F, A, &B, &C, D, E); }
|
||||||
|
@ -1077,6 +1075,6 @@ null_ordering_opt(A) ::= .
|
||||||
null_ordering_opt(A) ::= NULLS FIRST. { A = NULL_ORDER_FIRST; }
|
null_ordering_opt(A) ::= NULLS FIRST. { A = NULL_ORDER_FIRST; }
|
||||||
null_ordering_opt(A) ::= NULLS LAST. { A = NULL_ORDER_LAST; }
|
null_ordering_opt(A) ::= NULLS LAST. { A = NULL_ORDER_LAST; }
|
||||||
|
|
||||||
%fallback ABORT AFTER ATTACH BEFORE BEGIN BITAND BITNOT BITOR BLOCKS CHANGE COMMA COMPACT CONCAT CONFLICT COPY DEFERRED DELIMITERS DETACH DIVIDE DOT EACH END FAIL
|
%fallback ABORT AFTER ATTACH BEFORE BEGIN BITAND BITNOT BITOR BLOCKS CHANGE COMMA CONCAT CONFLICT COPY DEFERRED DELIMITERS DETACH DIVIDE DOT EACH END FAIL
|
||||||
FILE FOR GLOB ID IMMEDIATE IMPORT INITIALLY INSTEAD ISNULL KEY MODULES NK_BITNOT NK_SEMI NOTNULL OF PLUS PRIVILEGE RAISE REPLACE RESTRICT ROW SEMI STAR STATEMENT
|
FILE FOR GLOB ID IMMEDIATE IMPORT INITIALLY INSTEAD ISNULL KEY MODULES NK_BITNOT NK_SEMI NOTNULL OF PLUS PRIVILEGE RAISE REPLACE RESTRICT ROW SEMI STAR STATEMENT
|
||||||
STRICT STRING TIMES UPDATE VALUES VARIABLE VIEW WAL.
|
STRICT STRING TIMES UPDATE VALUES VARIABLE VIEW WAL.
|
||||||
|
|
|
@ -1087,6 +1087,17 @@ SNode* createTrimDatabaseStmt(SAstCreateContext* pCxt, SToken* pDbName, int32_t
|
||||||
return (SNode*)pStmt;
|
return (SNode*)pStmt;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
SNode* createCompactStmt(SAstCreateContext* pCxt, SToken* pDbName) {
|
||||||
|
CHECK_PARSER_STATUS(pCxt);
|
||||||
|
if (!checkDbName(pCxt, pDbName, false)) {
|
||||||
|
return NULL;
|
||||||
|
}
|
||||||
|
SCompactDatabaseStmt* pStmt = (SCompactDatabaseStmt*)nodesMakeNode(QUERY_NODE_COMPACT_DATABASE_STMT);
|
||||||
|
CHECK_OUT_OF_MEM(pStmt);
|
||||||
|
COPY_STRING_FORM_ID_TOKEN(pStmt->dbName, pDbName);
|
||||||
|
return (SNode*)pStmt;
|
||||||
|
}
|
||||||
|
|
||||||
SNode* createDefaultTableOptions(SAstCreateContext* pCxt) {
|
SNode* createDefaultTableOptions(SAstCreateContext* pCxt) {
|
||||||
CHECK_PARSER_STATUS(pCxt);
|
CHECK_PARSER_STATUS(pCxt);
|
||||||
STableOptions* pOptions = (STableOptions*)nodesMakeNode(QUERY_NODE_TABLE_OPTIONS);
|
STableOptions* pOptions = (STableOptions*)nodesMakeNode(QUERY_NODE_TABLE_OPTIONS);
|
||||||
|
@ -1697,13 +1708,6 @@ SNode* createResetQueryCacheStmt(SAstCreateContext* pCxt) {
|
||||||
return pStmt;
|
return pStmt;
|
||||||
}
|
}
|
||||||
|
|
||||||
SNode* createCompactStmt(SAstCreateContext* pCxt, SNodeList* pVgroups) {
|
|
||||||
CHECK_PARSER_STATUS(pCxt);
|
|
||||||
SNode* pStmt = nodesMakeNode(QUERY_NODE_COMPACT_STMT);
|
|
||||||
CHECK_OUT_OF_MEM(pStmt);
|
|
||||||
return pStmt;
|
|
||||||
}
|
|
||||||
|
|
||||||
SNode* createCreateFunctionStmt(SAstCreateContext* pCxt, bool ignoreExists, bool aggFunc, const SToken* pFuncName,
|
SNode* createCreateFunctionStmt(SAstCreateContext* pCxt, bool ignoreExists, bool aggFunc, const SToken* pFuncName,
|
||||||
const SToken* pLibPath, SDataType dataType, int32_t bufSize) {
|
const SToken* pLibPath, SDataType dataType, int32_t bufSize) {
|
||||||
CHECK_PARSER_STATUS(pCxt);
|
CHECK_PARSER_STATUS(pCxt);
|
||||||
|
|
|
@ -61,6 +61,7 @@ static SKeyword keywordTable[] = {
|
||||||
{"COLUMN", TK_COLUMN},
|
{"COLUMN", TK_COLUMN},
|
||||||
{"COMMENT", TK_COMMENT},
|
{"COMMENT", TK_COMMENT},
|
||||||
{"COMP", TK_COMP},
|
{"COMP", TK_COMP},
|
||||||
|
{"COMPACT", TK_COMPACT},
|
||||||
{"CONNECTION", TK_CONNECTION},
|
{"CONNECTION", TK_CONNECTION},
|
||||||
{"CONNECTIONS", TK_CONNECTIONS},
|
{"CONNECTIONS", TK_CONNECTIONS},
|
||||||
{"CONNS", TK_CONNS},
|
{"CONNS", TK_CONNS},
|
||||||
|
|
|
@ -5445,7 +5445,7 @@ static int32_t translateDropCGroup(STranslateContext* pCxt, SDropCGroupStmt* pSt
|
||||||
}
|
}
|
||||||
|
|
||||||
static int32_t translateAlterLocal(STranslateContext* pCxt, SAlterLocalStmt* pStmt) {
|
static int32_t translateAlterLocal(STranslateContext* pCxt, SAlterLocalStmt* pStmt) {
|
||||||
// todo
|
// The statement is executed directly on the client without constructing a message.
|
||||||
return TSDB_CODE_SUCCESS;
|
return TSDB_CODE_SUCCESS;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -5460,6 +5460,14 @@ static int32_t translateDescribe(STranslateContext* pCxt, SDescribeStmt* pStmt)
|
||||||
return refreshGetTableMeta(pCxt, pStmt->dbName, pStmt->tableName, &pStmt->pMeta);
|
return refreshGetTableMeta(pCxt, pStmt->dbName, pStmt->tableName, &pStmt->pMeta);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
static int32_t translateCompact(STranslateContext* pCxt, SCompactDatabaseStmt* pStmt) {
|
||||||
|
SCompactDbReq compactReq = {0};
|
||||||
|
SName name;
|
||||||
|
tNameSetDbName(&name, pCxt->pParseCxt->acctId, pStmt->dbName, strlen(pStmt->dbName));
|
||||||
|
tNameGetFullDbName(&name, compactReq.db);
|
||||||
|
return buildCmdMsg(pCxt, TDMT_MND_COMPACT_DB, (FSerializeFunc)tSerializeSCompactDbReq, &compactReq);
|
||||||
|
}
|
||||||
|
|
||||||
static int32_t translateKillConnection(STranslateContext* pCxt, SKillStmt* pStmt) {
|
static int32_t translateKillConnection(STranslateContext* pCxt, SKillStmt* pStmt) {
|
||||||
SKillConnReq killReq = {0};
|
SKillConnReq killReq = {0};
|
||||||
killReq.connId = pStmt->targetId;
|
killReq.connId = pStmt->targetId;
|
||||||
|
@ -6015,6 +6023,9 @@ static int32_t translateQuery(STranslateContext* pCxt, SNode* pNode) {
|
||||||
case QUERY_NODE_DESCRIBE_STMT:
|
case QUERY_NODE_DESCRIBE_STMT:
|
||||||
code = translateDescribe(pCxt, (SDescribeStmt*)pNode);
|
code = translateDescribe(pCxt, (SDescribeStmt*)pNode);
|
||||||
break;
|
break;
|
||||||
|
case QUERY_NODE_COMPACT_DATABASE_STMT:
|
||||||
|
code = translateCompact(pCxt, (SCompactDatabaseStmt*)pNode);
|
||||||
|
break;
|
||||||
case QUERY_NODE_KILL_CONNECTION_STMT:
|
case QUERY_NODE_KILL_CONNECTION_STMT:
|
||||||
code = translateKillConnection(pCxt, (SKillStmt*)pNode);
|
code = translateKillConnection(pCxt, (SKillStmt*)pNode);
|
||||||
break;
|
break;
|
||||||
|
|
File diff suppressed because it is too large
Load Diff
|
@ -21,6 +21,23 @@ namespace ParserTest {
|
||||||
|
|
||||||
class ParserInitialCTest : public ParserDdlTest {};
|
class ParserInitialCTest : public ParserDdlTest {};
|
||||||
|
|
||||||
|
TEST_F(ParserInitialCTest, compact) {
|
||||||
|
SCompactDbReq expect = {0};
|
||||||
|
|
||||||
|
auto setCompactDbReq = [&](const char* pDb) { snprintf(expect.db, sizeof(expect.db), "0.%s", pDb); };
|
||||||
|
|
||||||
|
setCheckDdlFunc([&](const SQuery* pQuery, ParserStage stage) {
|
||||||
|
ASSERT_EQ(nodeType(pQuery->pRoot), QUERY_NODE_COMPACT_DATABASE_STMT);
|
||||||
|
ASSERT_EQ(pQuery->pCmdMsg->msgType, TDMT_MND_COMPACT_DB);
|
||||||
|
SCompactDbReq req = {0};
|
||||||
|
ASSERT_EQ(tDeserializeSCompactDbReq(pQuery->pCmdMsg->pMsg, pQuery->pCmdMsg->msgLen, &req), TSDB_CODE_SUCCESS);
|
||||||
|
ASSERT_EQ(std::string(req.db), std::string(expect.db));
|
||||||
|
});
|
||||||
|
|
||||||
|
setCompactDbReq("wxy_db");
|
||||||
|
run("COMPACT DATABASE wxy_db");
|
||||||
|
}
|
||||||
|
|
||||||
TEST_F(ParserInitialCTest, createAccount) {
|
TEST_F(ParserInitialCTest, createAccount) {
|
||||||
useDb("root", "test");
|
useDb("root", "test");
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue