Skip to content

Commit bc2318e

Browse files
IGNITE-27105 SQL: Add JDBC local query property
1 parent c555c0e commit bc2318e

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinConnection.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -301,14 +301,6 @@ public JdbcThinConnection(ConnectionProperties connProps) throws SQLException {
301301

302302
schema = JdbcUtils.normalizeSchema(connProps.getSchema());
303303

304-
if (connProps.isLocal()) {
305-
if (connProps.getAddresses().length != 1
306-
|| connProps.getAddresses()[0].portFrom() != connProps.getAddresses()[0].portTo()) {
307-
LOG.warning("Local flag is supposed to be used only when exactly one address is specified, " +
308-
"otherwise the local query may be executed on an unexpected node");
309-
}
310-
}
311-
312304
partitionAwareness = connProps.isPartitionAwareness();
313305

314306
if (partitionAwareness) {
@@ -325,6 +317,14 @@ public JdbcThinConnection(ConnectionProperties connProps) throws SQLException {
325317

326318
holdability = isTxAwareQueriesSupported ? CLOSE_CURSORS_AT_COMMIT : HOLD_CURSORS_OVER_COMMIT;
327319
txIsolation = defaultTransactionIsolation();
320+
321+
if (connProps.isLocal()) {
322+
if (connProps.getAddresses().length != 1
323+
|| connProps.getAddresses()[0].portFrom() != connProps.getAddresses()[0].portTo()) {
324+
LOG.warning("Local flag is supposed to be used only when exactly one address is specified, " +
325+
"otherwise the local query may be executed on an unexpected node");
326+
}
327+
}
328328
}
329329

330330
/** Create new binary context. */

0 commit comments

Comments
 (0)