This is an automated email from the ASF dual-hosted git repository.
kfaraz pushed a commit to branch 24.0.1
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/24.0.1 by this push:
new c778ccb28e Create a copy of the shared JDBC context (#13049) (#13281)
c778ccb28e is described below
commit c778ccb28e8d4e49adc69f4fd300bc96a586de78
Author: Clint Wylie <[email protected]>
AuthorDate: Sat Oct 29 06:27:12 2022 -0700
Create a copy of the shared JDBC context (#13049) (#13281)
Co-authored-by: Paul Rogers <[email protected]>
---
sql/src/main/java/org/apache/druid/sql/avatica/DruidConnection.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/sql/src/main/java/org/apache/druid/sql/avatica/DruidConnection.java
b/sql/src/main/java/org/apache/druid/sql/avatica/DruidConnection.java
index addebc2f2d..a792e28b3a 100644
--- a/sql/src/main/java/org/apache/druid/sql/avatica/DruidConnection.java
+++ b/sql/src/main/java/org/apache/druid/sql/avatica/DruidConnection.java
@@ -97,7 +97,7 @@ public class DruidConnection
final DruidJdbcStatement statement = new DruidJdbcStatement(
connectionId,
statementId,
- context,
+ context.copy(),
sqlStatementFactory
);
@@ -109,7 +109,7 @@ public class DruidConnection
public DruidJdbcPreparedStatement createPreparedStatement(
SqlStatementFactory sqlStatementFactory,
- SqlQueryPlus sqlRequest,
+ SqlQueryPlus sqlQueryPlus,
final long maxRowCount)
{
final int statementId = statementCounter.incrementAndGet();
@@ -127,7 +127,7 @@ public class DruidConnection
@SuppressWarnings("GuardedBy")
final PreparedStatement statement =
sqlStatementFactory.preparedStatement(
- sqlRequest.withContext(context)
+ sqlQueryPlus.withContext(context.copy())
);
final DruidJdbcPreparedStatement jdbcStmt = new
DruidJdbcPreparedStatement(
connectionId,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
