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<String, String> 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);