feat: support create table in mysql 8.x

Author: taozhi8833998

pegjs/mariadb.pegjs

@@ -1203,7 +1203,8 @@ column_ref_idx_list
     }
 
 cte_idx_column_definition
-  = LPAREN __ l:column_ref_idx_list __ RPAREN {
+  = LPAREN __ l:(column_ref_idx_list / expr_list) __ RPAREN {
+      if (l.type) return l.value
       return l
     }
 
@@ -3247,6 +3248,7 @@ cast_expr
       type: 'cast',
       keyword: c.toLowerCase(),
       expr: e,
+      symbol: 'as',
       target: t
     };
   }
@@ -3255,6 +3257,7 @@ cast_expr
       type: 'cast',
       keyword: c.toLowerCase(),
       expr: e,
+      symbol: 'as',
       target: {
         dataType: 'DECIMAL(' + precision + ')'
       }
@@ -3265,6 +3268,7 @@ cast_expr
         type: 'cast',
         keyword: c.toLowerCase(),
         expr: e,
+        symbol: 'as',
         target: {
           dataType: 'DECIMAL(' + precision + ', ' + scale + ')'
         }
@@ -3275,6 +3279,7 @@ cast_expr
       type: 'cast',
       keyword: c.toLowerCase(),
       expr: e,
+      symbol: 'as',
       target: {
         dataType: s + (t ? ' ' + t: '')
       }
@@ -3933,8 +3938,8 @@ binary_type
 
 
 character_string_type
-  = t:(KW_CHAR / KW_VARCHAR) __ LPAREN __ l:[0-9]+ __ RPAREN {
-    return { dataType: t, length: parseInt(l.join(''), 10), parentheses: true };
+  = t:(KW_CHAR / KW_VARCHAR) __ LPAREN __ l:[0-9]+ __ RPAREN __ s:('ARRAY'i)? {
+    return { dataType: t, length: parseInt(l.join(''), 10), parentheses: true, suffix: s && ['ARRAY']  };
   }
   / t:KW_CHAR { return { dataType: t }; }
   / t:KW_VARCHAR { return { dataType: t }; }

pegjs/mysql.pegjs

@@ -2093,7 +2093,8 @@ column_ref_idx_list
     }
 
 cte_idx_column_definition
-  = LPAREN __ l:column_ref_idx_list __ RPAREN {
+  = LPAREN __ l:(column_ref_idx_list / expr_list) __ RPAREN {
+      if (l.type) return l.value
       return l
     }
 
@@ -4253,8 +4254,8 @@ binary_type
   / t:KW_BINARY { return { dataType: t }; }
 
 character_string_type
-  = t:(KW_CHAR / KW_VARCHAR) __ LPAREN __ l:[0-9]+ __ RPAREN {
-    return { dataType: t, length: parseInt(l.join(''), 10), parentheses: true };
+  = t:(KW_CHAR / KW_VARCHAR) __ LPAREN __ l:[0-9]+ __ RPAREN __ s:('ARRAY'i)? {
+    return { dataType: t, length: parseInt(l.join(''), 10), parentheses: true, suffix: s && ['ARRAY']  };
   }
   / t:KW_CHAR { return { dataType: t }; }
   / t:KW_VARCHAR { return { dataType: t }; }

src/column.js

@@ -174,7 +174,7 @@ function columnToSQL(column, isDual) {
     result.push([toUpper(type), type && '(', columnsStr, type && ')'].filter(hasVal).join(''))
     return result.filter(hasVal).join(' ')
   }
-  if (expr.parentheses && Reflect.has(expr, 'array_index')) str = `(${str})`
+  if (expr.parentheses && Reflect.has(expr, 'array_index') && expr.type !== 'cast') str = `(${str})`
   if (expr.array_index && expr.type !== 'column_ref') {
     str = `${str}${arrayIndexToSQL(expr.array_index)}`
   }

src/func.js

@@ -23,7 +23,7 @@ function arrayDimensionToSymbol(target) {
 }
 
 function castToSQL(expr) {
-  const { arrows = [], collate, target, expr: expression, keyword, symbol, as: alias, properties = [] } = expr
+  const { arrows = [], collate, target, expr: expression, keyword, symbol, as: alias, parentheses: outParentheses, properties = [] } = expr
   const { length, dataType, parentheses, quoted, scale, suffix: dataTypeSuffix, expr: targetExpr } = target
   let str = targetExpr ? exprToSQL(targetExpr) : ''
   if (length != null) str = scale ? `${length}, ${scale}` : length
@@ -41,8 +41,8 @@ function castToSQL(expr) {
   if (alias) suffix += ` AS ${identifierToSql(alias)}`
   if (collate) suffix += ` ${commonTypeValue(collate).join(' ')}`
   const arrayDimension = arrayDimensionToSymbol(target)
-  const result = [prefix, symbolChar, quoted, dataType, quoted, arrayDimension, str, suffix]
-  return result.filter(hasVal).join('')
+  const result = [prefix, symbolChar, quoted, dataType, quoted, arrayDimension, str, suffix].filter(hasVal).join('')
+  return outParentheses ? `(${result})` : result
 }
 
 function extractFunToSQL(stmt) {

test/mysql-mariadb.spec.js

@@ -1023,6 +1023,16 @@ describe('mysql', () => {
           "SET @_mystoredprocedure_0 = '1', @_mystoredprocedure_1 = '2'"
         ]
       },
+      {
+        title: 'create table for key',
+        sql: [
+          `CREATE TABLE some_table (
+            col JSON,
+            KEY \`idx_col\` ((CAST(\`col\` AS CHAR(12) ARRAY)))
+          );`,
+          'CREATE TABLE `some_table` (`col` JSON, KEY idx_col ((CAST(`col` AS CHAR(12) ARRAY))))'
+        ]
+      },
     ]
     SQL_LIST.forEach(sqlInfo => {
       const { title, sql } = sqlInfo