Skip to content

Commit af58e42

Browse files
committed
chore: rm unused fn
1 parent cd1d14d commit af58e42

File tree

2 files changed

+4
-14
lines changed

2 files changed

+4
-14
lines changed

databend-jdbc/src/main/java/com/databend/jdbc/DatabendConnection.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -790,7 +790,10 @@ private Map<String, String> setAdditionalHeaders() {
790790
DatabendSession session = this.getSession();
791791
String warehouse = null;
792792
if (session != null ) {
793-
warehouse = session.getSettings().get("warehouse");
793+
Map<String, String> settings = session.getSettings();
794+
if (settings != null) {
795+
warehouse = settings.get("warehouse");
796+
}
794797
}
795798
if (warehouse == null && !this.driverUri.getWarehouse().isEmpty()) {
796799
warehouse = this.driverUri.getWarehouse();

databend-jdbc/src/main/java/com/databend/jdbc/DatabendStatement.java

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -165,19 +165,6 @@ private void clearCurrentResults() {
165165
currentResult.set(null);
166166
}
167167

168-
private void updateClientSession(QueryResults q) {
169-
if (q == null) {
170-
return;
171-
}
172-
DatabendSession session = q.getSession();
173-
if (session == null) {
174-
return;
175-
}
176-
// current query has result on update client session
177-
DatabendConnection connection = this.connection.get();
178-
connection.setSession(session);
179-
}
180-
181168
final boolean internalExecute(String sql, StageAttachment attachment) throws SQLException {
182169
clearCurrentResults();
183170
checkOpen();

0 commit comments

Comments
 (0)