(shardingsphere) branch master updated: Fix PostgreSQLComQueryExecutor databaseType. (#31423)

[duanzhengqiang]

This is an automated email from the ASF dual-hosted git repository.

duanzhengqiang 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 edefb063003 Fix PostgreSQLComQueryExecutor databaseType. (#31423)
edefb063003 is described below

commit edefb0630031adff5a83d2ad5fcf043a20be9d46
Author: Cong Hu <iamhuc...@gmail.com>
AuthorDate: Tue May 28 13:43:13 2024 +0800

    Fix PostgreSQLComQueryExecutor databaseType. (#31423)
---
 .../postgresql/command/query/simple/PostgreSQLComQueryExecutor.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/proxy/frontend/type/postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/query/simple/PostgreSQLComQueryExecutor.java
 
b/proxy/frontend/type/postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/query/simple/PostgreSQLComQueryExecutor.java
index 08a314e61b0..b6cf17a249f 100644
--- 
a/proxy/frontend/type/postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/query/simple/PostgreSQLComQueryExecutor.java
+++ 
b/proxy/frontend/type/postgresql/src/main/java/org/apache/shardingsphere/proxy/frontend/postgresql/command/query/simple/PostgreSQLComQueryExecutor.java
@@ -69,7 +69,7 @@ public final class PostgreSQLComQueryExecutor implements 
QueryCommandExecutor {
     
     public PostgreSQLComQueryExecutor(final PortalContext portalContext, final 
PostgreSQLComQueryPacket packet, final ConnectionSession connectionSession) 
throws SQLException {
         this.portalContext = portalContext;
-        DatabaseType databaseType = 
TypedSPILoader.getService(DatabaseType.class, "openGauss");
+        DatabaseType databaseType = 
TypedSPILoader.getService(DatabaseType.class, "PostgreSQL");
         SQLStatement sqlStatement = 
ProxySQLComQueryParser.parse(packet.getSQL(), databaseType, connectionSession);
         proxyBackendHandler = 
ProxyBackendHandlerFactory.newInstance(databaseType, packet.getSQL(), 
sqlStatement, connectionSession, packet.getHintValueContext());
     }