improve mysql parser

2023-03-04 19:17:16 +00:00 · 2022-06-12 05:20:51 +08:00
parent 08f14409f9
commit dd4c3f87c7
1 changed files with 13 additions and 2 deletions
@@ -6093,9 +6093,20 @@ public class MySqlStatementParser extends SQLStatementParser {
                            }
                            if (lexer.token() == Token.LPAREN) {
                                lexer.nextToken();
-                                SQLPartition partition = this.getExprParser().parsePartition();
+
+                                for (;;) {
+                                    SQLPartition partition = this.getExprParser().parsePartition();
+                                    item.addPartition(partition);
+                                    if (lexer.token() == COMMA) {
+                                        lexer.nextToken();
+
+                                        if(lexer.token() == PARTITION) {
+                                            continue;
+                                        }
+                                    }
+                                    break;
+                                }
                                accept(Token.RPAREN);
-                                item.addPartition(partition);
                            }
                            stmt.addItem(item);
                            return true;