You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by wu...@apache.org on 2021/07/14 07:02:09 UTC

[shardingsphere] 02/02: Adapt #11278

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

wuweijie pushed a commit to branch opengauss_adapt
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git

commit 2953afc29ad584dbe7bd0ae3d87f3ebe63ec1737
Author: 吴伟杰 <wu...@apache.org>
AuthorDate: Wed Jul 14 15:01:05 2021 +0800

    Adapt #11278
---
 .../packet/command/query/binary/bind/OpenGaussComBatchBindPacket.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/OpenGaussComBatchBindPacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/OpenGaussComBatchBindPacket.java
index e93f370..e10fb0b 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/OpenGaussComBatchBindPacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/OpenGaussComBatchBindPacket.java
@@ -72,7 +72,7 @@ public final class OpenGaussComBatchBindPacket extends PostgreSQLCommandPacket {
         for (int i = 0; i < resultFormatsLength; i++) {
             resultFormats.add(PostgreSQLValueFormat.valueOf(payload.readInt2()));
         }
-        binaryStatement = PostgreSQLBinaryStatementRegistry.getInstance().getBinaryStatement(connectionId, statementId);
+        binaryStatement = PostgreSQLBinaryStatementRegistry.getInstance().get(connectionId, statementId);
         sql = null == binaryStatement ? null : binaryStatement.getSql();
         eachGroupParametersCount = payload.readInt2();
     }