Skip to content

Commit 3459dcc

Browse files
author
Paultagoras
committed
Update StatementImpl.java
1 parent 202b0a4 commit 3459dcc

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

jdbc-v2/src/main/java/com/clickhouse/jdbc/StatementImpl.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -144,11 +144,11 @@ public ResultSetImpl executeQuery(String sql, QuerySettings settings) throws SQL
144144
checkClosed();
145145
QuerySettings mergedSettings = QuerySettings.merge(connection.getDefaultQuerySettings(), settings);
146146

147-
if (settings.getQueryId() != null) {
148-
lastQueryId = settings.getQueryId();
147+
if (mergedSettings.getQueryId() != null) {
148+
lastQueryId = mergedSettings.getQueryId();
149149
} else {
150150
lastQueryId = UUID.randomUUID().toString();
151-
settings.setQueryId(lastQueryId);
151+
mergedSettings.setQueryId(lastQueryId);
152152
}
153153
LOG.debug("Query ID: {}", lastQueryId);
154154

@@ -198,11 +198,11 @@ public int executeUpdate(String sql, QuerySettings settings) throws SQLException
198198

199199
QuerySettings mergedSettings = QuerySettings.merge(connection.getDefaultQuerySettings(), settings);
200200

201-
if (settings.getQueryId() != null) {
202-
lastQueryId = settings.getQueryId();
201+
if (mergedSettings.getQueryId() != null) {
202+
lastQueryId = mergedSettings.getQueryId();
203203
} else {
204204
lastQueryId = UUID.randomUUID().toString();
205-
settings.setQueryId(lastQueryId);
205+
mergedSettings.setQueryId(lastQueryId);
206206
}
207207

208208
lastSql = parseJdbcEscapeSyntax(sql);

0 commit comments

Comments
 (0)