[shardingsphere] branch master updated: Return no generated key for PostgreSQL (#10627)

[panjuan]

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 7c42a4e  Return no generated key for PostgreSQL (#10627)
7c42a4e is described below

commit 7c42a4ec02cfcd62d41d7c5a8980f6ed1cf9f980
Author: 吴伟杰 <wuwei...@apache.org>
AuthorDate: Thu Jun 3 12:33:29 2021 +0800

    Return no generated key for PostgreSQL (#10627)
---
 .../shardingsphere/proxy/backend/communication/ProxySQLExecutor.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/ProxySQLExecutor.java
 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/ProxySQLExecutor.java
index 682d3eb..988bbe0 100644
--- 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/ProxySQLExecutor.java
+++ 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/ProxySQLExecutor.java
@@ -51,7 +51,7 @@ import 
org.apache.shardingsphere.proxy.backend.context.ProxyContext;
 import 
org.apache.shardingsphere.proxy.backend.exception.TableModifyInTransactionException;
 import org.apache.shardingsphere.sql.parser.sql.common.statement.SQLStatement;
 import 
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.DDLStatement;
-import 
org.apache.shardingsphere.sql.parser.sql.common.statement.dml.InsertStatement;
+import 
org.apache.shardingsphere.sql.parser.sql.dialect.statement.mysql.dml.MySQLInsertStatement;
 import org.apache.shardingsphere.transaction.core.TransactionType;
 
 import java.sql.Connection;
@@ -110,7 +110,7 @@ public final class ProxySQLExecutor {
     public Collection<ExecuteResult> execute(final ExecutionContext 
executionContext) throws SQLException {
         Collection<ShardingSphereRule> rules = 
ProxyContext.getInstance().getMetaDataContexts().getMetaData(backendConnection.getSchemaName()).getRuleMetaData().getRules();
         int maxConnectionsSizePerQuery = 
ProxyContext.getInstance().getMetaDataContexts().getProps().<Integer>getValue(ConfigurationPropertyKey.MAX_CONNECTIONS_SIZE_PER_QUERY);
-        boolean isReturnGeneratedKeys = 
executionContext.getSqlStatementContext().getSqlStatement() instanceof 
InsertStatement;
+        boolean isReturnGeneratedKeys = 
executionContext.getSqlStatementContext().getSqlStatement() instanceof 
MySQLInsertStatement;
         return execute(executionContext, rules, maxConnectionsSizePerQuery, 
isReturnGeneratedKeys);
     }