You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by pa...@apache.org on 2021/06/30 02:26:50 UTC
[shardingsphere] branch master updated: fix npe when execute select
statement without schemaName (#11071)
This is an automated email from the ASF dual-hosted git repository.
panjuan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 55582d7 fix npe when execute select statement without schemaName (#11071)
55582d7 is described below
commit 55582d79e799252feccd04fc42191227de8c5fbe
Author: Zhengqiang Duan <st...@gmail.com>
AuthorDate: Wed Jun 30 10:26:13 2021 +0800
fix npe when execute select statement without schemaName (#11071)
---
.../backend/text/data/impl/SchemaAssignedDatabaseBackendHandler.java | 4 +++-
.../proxy/backend/text/data/impl/UnicastDatabaseBackendHandler.java | 4 +++-
2 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/data/impl/SchemaAssignedDatabaseBackendHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/data/impl/SchemaAssignedDatabaseBackendHandler.java
index 3038e50..e394255 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/data/impl/SchemaAssignedDatabaseBackendHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/data/impl/SchemaAssignedDatabaseBackendHandler.java
@@ -67,6 +67,8 @@ public final class SchemaAssignedDatabaseBackendHandler implements DatabaseBacke
@Override
public void close() throws SQLException {
- databaseCommunicationEngine.close();
+ if (null != databaseCommunicationEngine) {
+ databaseCommunicationEngine.close();
+ }
}
}
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/data/impl/UnicastDatabaseBackendHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/data/impl/UnicastDatabaseBackendHandler.java
index 054772f..b6b4259 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/data/impl/UnicastDatabaseBackendHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/data/impl/UnicastDatabaseBackendHandler.java
@@ -77,6 +77,8 @@ public final class UnicastDatabaseBackendHandler implements DatabaseBackendHandl
@Override
public void close() throws SQLException {
- databaseCommunicationEngine.close();
+ if (null != databaseCommunicationEngine) {
+ databaseCommunicationEngine.close();
+ }
}
}