diff --git a/core/src/main/java/com/alibaba/druid/sql/dialect/clickhouse/parser/CKStatementParser.java b/core/src/main/java/com/alibaba/druid/sql/dialect/clickhouse/parser/CKStatementParser.java index 8307c30b6..bb832025b 100644 --- a/core/src/main/java/com/alibaba/druid/sql/dialect/clickhouse/parser/CKStatementParser.java +++ b/core/src/main/java/com/alibaba/druid/sql/dialect/clickhouse/parser/CKStatementParser.java @@ -4,6 +4,7 @@ import com.alibaba.druid.DbType; import com.alibaba.druid.sql.ast.SQLName; import com.alibaba.druid.sql.ast.statement.SQLAlterStatement; import com.alibaba.druid.sql.ast.statement.SQLAlterTableStatement; +import com.alibaba.druid.sql.ast.statement.SQLColumnDefinition; import com.alibaba.druid.sql.ast.statement.SQLCreateViewStatement; import com.alibaba.druid.sql.ast.statement.SQLUpdateSetItem; import com.alibaba.druid.sql.ast.statement.SQLWithSubqueryClause; @@ -115,4 +116,7 @@ public class CKStatementParser extends SQLStatementParser { } } } + public void parseCreateViewAtDataType(SQLColumnDefinition column, SQLName expr) { + column.setDataType(this.exprParser.parseDataType()); + } } diff --git a/core/src/main/java/com/alibaba/druid/sql/dialect/odps/parser/OdpsStatementParser.java b/core/src/main/java/com/alibaba/druid/sql/dialect/odps/parser/OdpsStatementParser.java index d6e8b3a9d..0091ed50a 100644 --- a/core/src/main/java/com/alibaba/druid/sql/dialect/odps/parser/OdpsStatementParser.java +++ b/core/src/main/java/com/alibaba/druid/sql/dialect/odps/parser/OdpsStatementParser.java @@ -1740,8 +1740,6 @@ public class OdpsStatementParser extends HiveStatementParser { public void parseCreateViewAtDataType(SQLColumnDefinition column, SQLName expr) { if (expr.getSimpleName().startsWith("@")) { column.setDataType(this.exprParser.parseDataType()); - } else { - super.parseCreateViewAtDataType(column, expr); } } diff --git a/core/src/main/java/com/alibaba/druid/sql/parser/SQLStatementParser.java b/core/src/main/java/com/alibaba/druid/sql/parser/SQLStatementParser.java index 08af61764..2673b1e1d 100644 --- a/core/src/main/java/com/alibaba/druid/sql/parser/SQLStatementParser.java +++ b/core/src/main/java/com/alibaba/druid/sql/parser/SQLStatementParser.java @@ -4971,7 +4971,6 @@ public class SQLStatementParser extends SQLParser { public void parseCreateViewAfterName(SQLCreateViewStatement createView) { } public void parseCreateViewAtDataType(SQLColumnDefinition column, SQLName expr) { - column.setDataType(this.exprParser.parseDataType()); } public SQLCreateViewStatement parseCreateView() { SQLCreateViewStatement createView = new SQLCreateViewStatement(getDbType());