From 5f68b39a5d72c21054e51d6bff3178a91b983533 Mon Sep 17 00:00:00 2001 From: huangzl Date: Mon, 7 Jun 2021 11:06:06 +0800 Subject: [PATCH] =?UTF-8?q?//when=20parsedStmt=20isDDL,Database=20is=20sho?= =?UTF-8?q?uld=20not=20ignore=20if=20we=20ignore=20the=20Database,Explicit?= =?UTF-8?q?=20assignment=20database=20name=20in=20sql=20is=20in=20need,Tha?= =?UTF-8?q?t=20=20maybe=20unreasonable.=20DDL=E8=AF=AD=E5=8F=A5=E9=9C=80?= =?UTF-8?q?=E8=A6=81=E6=B3=A8=E5=85=A5=E6=95=B0=E6=8D=AE=E5=BA=93=E5=90=8D?= =?UTF-8?q?=20sql=20example:=20String=20sql=3D"ALTER=20TABLE=20HITS02=20AD?= =?UTF-8?q?D=20COLUMN=20Added1=20UInt32=20FIRST";?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/ru/yandex/clickhouse/ClickHouseStatementImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/clickhouse-jdbc/src/main/java/ru/yandex/clickhouse/ClickHouseStatementImpl.java b/clickhouse-jdbc/src/main/java/ru/yandex/clickhouse/ClickHouseStatementImpl.java index 7699f5833..576f679eb 100644 --- a/clickhouse-jdbc/src/main/java/ru/yandex/clickhouse/ClickHouseStatementImpl.java +++ b/clickhouse-jdbc/src/main/java/ru/yandex/clickhouse/ClickHouseStatementImpl.java @@ -709,7 +709,8 @@ private InputStream getInputStream( Map additionalRequestParams ) throws ClickHouseException { String sql = parsedStmt.getSQL(); - boolean ignoreDatabase = parsedStmt.isRecognized() && !parsedStmt.isDML(); + //when parsedStmt isDDL,Database is should not ignore + boolean ignoreDatabase = parsedStmt.isRecognized() && !parsedStmt.isDML()&& !parsedStmt.isDDL(); log.debug("Executing SQL: {}", sql);