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/04/13 09:47:56 UTC
[shardingsphere] branch master updated: Rename
PostgreSQLIdentifierPacket.getMessageType() to
PostgreSQLIdentifierPacket.getIdentifier() (#10072)
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 029a9f8 Rename PostgreSQLIdentifierPacket.getMessageType() to PostgreSQLIdentifierPacket.getIdentifier() (#10072)
029a9f8 is described below
commit 029a9f8a8336794cff5d8fc8db0f0cd04a7cc694
Author: Liang Zhang <te...@163.com>
AuthorDate: Tue Apr 13 17:47:26 2021 +0800
Rename PostgreSQLIdentifierPacket.getMessageType() to PostgreSQLIdentifierPacket.getIdentifier() (#10072)
---
.../db/protocol/postgresql/codec/PostgreSQLPacketCodecEngine.java | 2 +-
.../db/protocol/postgresql/packet/PostgreSQLIdentifierPacket.java | 6 +++---
.../packet/command/admin/PostgreSQLUnsupportedCommandPacket.java | 2 +-
.../packet/command/query/PostgreSQLRowDescriptionPacket.java | 2 +-
.../query/binary/bind/PostgreSQLBinaryResultSetRowPacket.java | 2 +-
.../command/query/binary/bind/PostgreSQLBindCompletePacket.java | 2 +-
.../packet/command/query/binary/bind/PostgreSQLComBindPacket.java | 2 +-
.../command/query/binary/describe/PostgreSQLComDescribePacket.java | 2 +-
.../command/query/binary/execute/PostgreSQLComExecutePacket.java | 2 +-
.../packet/command/query/binary/parse/PostgreSQLComParsePacket.java | 2 +-
.../command/query/binary/parse/PostgreSQLParseCompletePacket.java | 2 +-
.../packet/command/query/binary/sync/PostgreSQLComSyncPacket.java | 2 +-
.../packet/command/query/text/PostgreSQLComQueryPacket.java | 2 +-
.../packet/command/query/text/PostgreSQLDataRowPacket.java | 2 +-
.../postgresql/packet/generic/PostgreSQLComTerminationPacket.java | 2 +-
.../postgresql/packet/generic/PostgreSQLCommandCompletePacket.java | 2 +-
.../postgresql/packet/generic/PostgreSQLErrorResponsePacket.java | 2 +-
.../postgresql/packet/generic/PostgreSQLReadyForQueryPacket.java | 2 +-
.../packet/handshake/PostgreSQLAuthenticationMD5PasswordPacket.java | 2 +-
.../packet/handshake/PostgreSQLAuthenticationOKPacket.java | 2 +-
.../packet/handshake/PostgreSQLParameterStatusPacket.java | 2 +-
.../packet/handshake/PostgreSQLPasswordMessagePacket.java | 2 +-
.../protocol/postgresql/codec/PostgreSQLPacketCodecEngineTest.java | 2 +-
.../command/admin/PostgreSQLUnsupportedCommandPacketTest.java | 2 +-
.../packet/command/query/PostgreSQLRowDescriptionPacketTest.java | 2 +-
.../query/binary/bind/PostgreSQLBinaryResultSetRowPacketTest.java | 2 +-
.../command/query/binary/bind/PostgreSQLBindCompletePacketTest.java | 2 +-
.../command/query/binary/bind/PostgreSQLComBindPacketTest.java | 2 +-
.../query/binary/describe/PostgreSQLComDescribePacketTest.java | 2 +-
.../query/binary/execute/PostgreSQLComExecutePacketTest.java | 2 +-
.../command/query/binary/parse/PostgreSQLComParsePacketTest.java | 2 +-
.../query/binary/parse/PostgreSQLParseCompletePacketTest.java | 2 +-
.../command/query/binary/sync/PostgreSQLComSyncPacketTest.java | 2 +-
.../packet/command/query/text/PostgreSQLComQueryPacketTest.java | 2 +-
.../generic/PostgreSQLAuthenticationMD5PasswordPacketTest.java | 2 +-
.../packet/generic/PostgreSQLAuthenticationOKPacketTest.java | 2 +-
.../packet/generic/PostgreSQLComTerminationPacketTest.java | 2 +-
.../packet/generic/PostgreSQLCommandCompletePacketTest.java | 4 ++--
.../packet/generic/PostgreSQLParameterStatusPacketTest.java | 2 +-
.../packet/generic/PostgreSQLPasswordMessagePacketTest.java | 2 +-
.../packet/generic/PostgreSQLReadyForQueryPacketTest.java | 2 +-
41 files changed, 44 insertions(+), 44 deletions(-)
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/codec/PostgreSQLPacketCodecEngine.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/codec/PostgreSQLPacketCodecEngine.java
index 22c4b0c..043d68a 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/codec/PostgreSQLPacketCodecEngine.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/codec/PostgreSQLPacketCodecEngine.java
@@ -73,7 +73,7 @@ public final class PostgreSQLPacketCodecEngine implements DatabasePacketCodecEng
postgreSQLErrorResponsePacket.write(payload);
} finally {
if (message instanceof PostgreSQLIdentifierPacket) {
- out.writeByte(((PostgreSQLIdentifierPacket) message).getMessageType());
+ out.writeByte(((PostgreSQLIdentifierPacket) message).getIdentifier());
out.writeInt(payload.getByteBuf().readableBytes() + PAYLOAD_LENGTH);
}
out.writeBytes(payload.getByteBuf());
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/PostgreSQLIdentifierPacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/PostgreSQLIdentifierPacket.java
index b4dc5f1..6ac1bec 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/PostgreSQLIdentifierPacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/PostgreSQLIdentifierPacket.java
@@ -23,9 +23,9 @@ package org.apache.shardingsphere.db.protocol.postgresql.packet;
public interface PostgreSQLIdentifierPacket extends PostgreSQLPacket {
/**
- * Get message type.
+ * Get identifier.
*
- * @return message type
+ * @return identifier
*/
- char getMessageType();
+ char getIdentifier();
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/admin/PostgreSQLUnsupportedCommandPacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/admin/PostgreSQLUnsupportedCommandPacket.java
index cbf19d8..abeb837 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/admin/PostgreSQLUnsupportedCommandPacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/admin/PostgreSQLUnsupportedCommandPacket.java
@@ -29,7 +29,7 @@ import org.apache.shardingsphere.db.protocol.postgresql.payload.PostgreSQLPacket
public final class PostgreSQLUnsupportedCommandPacket extends PostgreSQLCommandPacket {
@Getter
- private final char messageType;
+ private final char identifier;
@Override
public void write(final PostgreSQLPacketPayload payload) {
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/PostgreSQLRowDescriptionPacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/PostgreSQLRowDescriptionPacket.java
index 721fb46..563a94b 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/PostgreSQLRowDescriptionPacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/PostgreSQLRowDescriptionPacket.java
@@ -51,7 +51,7 @@ public final class PostgreSQLRowDescriptionPacket implements PostgreSQLIdentifie
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.ROW_DESCRIPTION.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBinaryResultSetRowPacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBinaryResultSetRowPacket.java
index bece933..80b137b 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBinaryResultSetRowPacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBinaryResultSetRowPacket.java
@@ -50,7 +50,7 @@ public final class PostgreSQLBinaryResultSetRowPacket implements PostgreSQLIdent
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.DATA_ROW.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBindCompletePacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBindCompletePacket.java
index 22f49fb..734d397 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBindCompletePacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBindCompletePacket.java
@@ -31,7 +31,7 @@ public final class PostgreSQLBindCompletePacket implements PostgreSQLIdentifierP
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.BIND_COMPLETE.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLComBindPacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLComBindPacket.java
index 03f8afc..e9fb993 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLComBindPacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLComBindPacket.java
@@ -83,7 +83,7 @@ public final class PostgreSQLComBindPacket extends PostgreSQLCommandPacket {
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.BIND_COMMAND.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/describe/PostgreSQLComDescribePacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/describe/PostgreSQLComDescribePacket.java
index caa2e8e..b75b70d 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/describe/PostgreSQLComDescribePacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/describe/PostgreSQLComDescribePacket.java
@@ -37,7 +37,7 @@ public final class PostgreSQLComDescribePacket extends PostgreSQLCommandPacket {
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.DESCRIBE_COMMAND.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/execute/PostgreSQLComExecutePacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/execute/PostgreSQLComExecutePacket.java
index c721a5b..0831ef6 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/execute/PostgreSQLComExecutePacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/execute/PostgreSQLComExecutePacket.java
@@ -37,7 +37,7 @@ public final class PostgreSQLComExecutePacket extends PostgreSQLCommandPacket {
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.EXECUTE_COMMAND.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLComParsePacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLComParsePacket.java
index 4c55da6..94102dd 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLComParsePacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLComParsePacket.java
@@ -65,7 +65,7 @@ public final class PostgreSQLComParsePacket extends PostgreSQLCommandPacket {
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.PARSE_COMMAND.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLParseCompletePacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLParseCompletePacket.java
index 1cee482..d2019fb 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLParseCompletePacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLParseCompletePacket.java
@@ -31,7 +31,7 @@ public final class PostgreSQLParseCompletePacket implements PostgreSQLIdentifier
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.PARSE_COMPLETE.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/sync/PostgreSQLComSyncPacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/sync/PostgreSQLComSyncPacket.java
index 71d9158..c78c095 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/sync/PostgreSQLComSyncPacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/sync/PostgreSQLComSyncPacket.java
@@ -35,7 +35,7 @@ public final class PostgreSQLComSyncPacket extends PostgreSQLCommandPacket {
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.SYNC_COMMAND.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/text/PostgreSQLComQueryPacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/text/PostgreSQLComQueryPacket.java
index 0f899b4..e8133d8 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/text/PostgreSQLComQueryPacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/text/PostgreSQLComQueryPacket.java
@@ -40,7 +40,7 @@ public final class PostgreSQLComQueryPacket extends PostgreSQLCommandPacket {
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.SIMPLE_QUERY.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/text/PostgreSQLDataRowPacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/text/PostgreSQLDataRowPacket.java
index c98901b..0877507 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/text/PostgreSQLDataRowPacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/text/PostgreSQLDataRowPacket.java
@@ -69,7 +69,7 @@ public final class PostgreSQLDataRowPacket implements PostgreSQLIdentifierPacket
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.DATA_ROW.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLComTerminationPacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLComTerminationPacket.java
index 5e44cd9..87dc6a6 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLComTerminationPacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLComTerminationPacket.java
@@ -35,7 +35,7 @@ public final class PostgreSQLComTerminationPacket extends PostgreSQLCommandPacke
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.TERMINATE.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLCommandCompletePacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLCommandCompletePacket.java
index ebbc875..f808b2e 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLCommandCompletePacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLCommandCompletePacket.java
@@ -43,7 +43,7 @@ public final class PostgreSQLCommandCompletePacket implements PostgreSQLIdentifi
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.COMMAND_COMPLETE.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLErrorResponsePacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLErrorResponsePacket.java
index 6ed16c3..4432628 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLErrorResponsePacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLErrorResponsePacket.java
@@ -90,7 +90,7 @@ public final class PostgreSQLErrorResponsePacket implements PostgreSQLIdentifier
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.ERROR_RESPONSE.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLReadyForQueryPacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLReadyForQueryPacket.java
index fc71920..3c021e6 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLReadyForQueryPacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLReadyForQueryPacket.java
@@ -34,7 +34,7 @@ public final class PostgreSQLReadyForQueryPacket implements PostgreSQLIdentifier
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.READY_FOR_QUERY.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLAuthenticationMD5PasswordPacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLAuthenticationMD5PasswordPacket.java
index e73d1e4..c0940c0 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLAuthenticationMD5PasswordPacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLAuthenticationMD5PasswordPacket.java
@@ -39,7 +39,7 @@ public final class PostgreSQLAuthenticationMD5PasswordPacket implements PostgreS
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.AUTHENTICATION_REQUEST.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLAuthenticationOKPacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLAuthenticationOKPacket.java
index e56ebdb..f980b06 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLAuthenticationOKPacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLAuthenticationOKPacket.java
@@ -36,7 +36,7 @@ public final class PostgreSQLAuthenticationOKPacket implements PostgreSQLIdentif
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.AUTHENTICATION_REQUEST.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLParameterStatusPacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLParameterStatusPacket.java
index 369ea51..ef23231 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLParameterStatusPacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLParameterStatusPacket.java
@@ -39,7 +39,7 @@ public final class PostgreSQLParameterStatusPacket implements PostgreSQLIdentifi
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.PARAMETER_STATUS.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLPasswordMessagePacket.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLPasswordMessagePacket.java
index d1698a0..6af1176 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLPasswordMessagePacket.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/main/java/org/apache/shardingsphere/db/protocol/postgresql/packet/handshake/PostgreSQLPasswordMessagePacket.java
@@ -40,7 +40,7 @@ public final class PostgreSQLPasswordMessagePacket implements PostgreSQLIdentifi
}
@Override
- public char getMessageType() {
+ public char getIdentifier() {
return PostgreSQLCommandPacketType.PASSWORD_MESSAGE.getValue();
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/codec/PostgreSQLPacketCodecEngineTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/codec/PostgreSQLPacketCodecEngineTest.java
index 89c9158..e9db0ad 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/codec/PostgreSQLPacketCodecEngineTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/codec/PostgreSQLPacketCodecEngineTest.java
@@ -84,7 +84,7 @@ public final class PostgreSQLPacketCodecEngineTest {
when(byteBufAllocator.buffer()).thenReturn(payloadByteBuf);
when(payloadByteBuf.readableBytes()).thenReturn(50);
PostgreSQLIdentifierPacket actualMessage = mock(PostgreSQLIdentifierPacket.class);
- when(actualMessage.getMessageType()).thenReturn(PostgreSQLCommandPacketType.AUTHENTICATION_REQUEST.getValue());
+ when(actualMessage.getIdentifier()).thenReturn(PostgreSQLCommandPacketType.AUTHENTICATION_REQUEST.getValue());
new PostgreSQLPacketCodecEngine().encode(context, actualMessage, byteBuf);
verify(actualMessage).write(ArgumentMatchers.any());
verify(byteBuf).writeByte(PostgreSQLCommandPacketType.AUTHENTICATION_REQUEST.getValue());
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/admin/PostgreSQLUnsupportedCommandPacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/admin/PostgreSQLUnsupportedCommandPacketTest.java
index 6f97548..4f10317 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/admin/PostgreSQLUnsupportedCommandPacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/admin/PostgreSQLUnsupportedCommandPacketTest.java
@@ -44,6 +44,6 @@ public final class PostgreSQLUnsupportedCommandPacketTest {
@Test
public void assertGetMessageType() {
PostgreSQLUnsupportedCommandPacket rowPacket = new PostgreSQLUnsupportedCommandPacket(PostgreSQLCommandPacketType.AUTHENTICATION_REQUEST.getValue());
- assertThat(rowPacket.getMessageType(), is(PostgreSQLCommandPacketType.AUTHENTICATION_REQUEST.getValue()));
+ assertThat(rowPacket.getIdentifier(), is(PostgreSQLCommandPacketType.AUTHENTICATION_REQUEST.getValue()));
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/PostgreSQLRowDescriptionPacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/PostgreSQLRowDescriptionPacketTest.java
index 7f4a967..758f0b5 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/PostgreSQLRowDescriptionPacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/PostgreSQLRowDescriptionPacketTest.java
@@ -56,6 +56,6 @@ public final class PostgreSQLRowDescriptionPacketTest {
@Test
public void getMessageType() {
PostgreSQLRowDescriptionPacket packet = new PostgreSQLRowDescriptionPacket(0, Collections.emptyList());
- assertThat(packet.getMessageType(), is(PostgreSQLCommandPacketType.ROW_DESCRIPTION.getValue()));
+ assertThat(packet.getIdentifier(), is(PostgreSQLCommandPacketType.ROW_DESCRIPTION.getValue()));
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBinaryResultSetRowPacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBinaryResultSetRowPacketTest.java
index 6ee00ff..2f9c3f2 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBinaryResultSetRowPacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBinaryResultSetRowPacketTest.java
@@ -67,6 +67,6 @@ public final class PostgreSQLBinaryResultSetRowPacketTest {
@Test
public void assertGetMessageType() {
PostgreSQLBinaryResultSetRowPacket rowPacket = new PostgreSQLBinaryResultSetRowPacket(mock(BinaryRow.class));
- assertThat(rowPacket.getMessageType(), is(PostgreSQLCommandPacketType.DATA_ROW.getValue()));
+ assertThat(rowPacket.getIdentifier(), is(PostgreSQLCommandPacketType.DATA_ROW.getValue()));
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBindCompletePacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBindCompletePacketTest.java
index df91e9c..b5ef13c 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBindCompletePacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLBindCompletePacketTest.java
@@ -47,6 +47,6 @@ public final class PostgreSQLBindCompletePacketTest {
@Test
public void assertGetMessageType() {
PostgreSQLBindCompletePacket rowPacket = new PostgreSQLBindCompletePacket();
- assertThat(rowPacket.getMessageType(), is(PostgreSQLCommandPacketType.BIND_COMPLETE.getValue()));
+ assertThat(rowPacket.getIdentifier(), is(PostgreSQLCommandPacketType.BIND_COMPLETE.getValue()));
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLComBindPacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLComBindPacketTest.java
index dbe0288..8d84efe 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLComBindPacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/bind/PostgreSQLComBindPacketTest.java
@@ -76,6 +76,6 @@ public final class PostgreSQLComBindPacketTest {
@Test
public void getMessageType() {
PostgreSQLComBindPacket bindPacket = new PostgreSQLComBindPacket(payload, 1);
- assertThat(bindPacket.getMessageType(), is(PostgreSQLCommandPacketType.BIND_COMMAND.getValue()));
+ assertThat(bindPacket.getIdentifier(), is(PostgreSQLCommandPacketType.BIND_COMMAND.getValue()));
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/describe/PostgreSQLComDescribePacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/describe/PostgreSQLComDescribePacketTest.java
index 2f3393a..aeda908 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/describe/PostgreSQLComDescribePacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/describe/PostgreSQLComDescribePacketTest.java
@@ -37,7 +37,7 @@ public final class PostgreSQLComDescribePacketTest {
public void assertNewInstance() {
PostgreSQLComDescribePacket actual = new PostgreSQLComDescribePacket(payload);
actual.write(payload);
- assertThat(actual.getMessageType(), is('D'));
+ assertThat(actual.getIdentifier(), is('D'));
verify(payload).readInt4();
verify(payload).readInt1();
verify(payload).readStringNul();
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/execute/PostgreSQLComExecutePacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/execute/PostgreSQLComExecutePacketTest.java
index 227b9dd..2b4f96b 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/execute/PostgreSQLComExecutePacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/execute/PostgreSQLComExecutePacketTest.java
@@ -40,6 +40,6 @@ public final class PostgreSQLComExecutePacketTest {
verify(payload, atLeast(2)).readInt4();
verify(payload).readStringNul();
actual.write(payload);
- assertThat(actual.getMessageType(), is('E'));
+ assertThat(actual.getIdentifier(), is('E'));
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLComParsePacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLComParsePacketTest.java
index 90c593e..b9cdc68 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLComParsePacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLComParsePacketTest.java
@@ -46,7 +46,7 @@ public final class PostgreSQLComParsePacketTest {
when(payload.readStringNul()).thenReturn("sql");
PostgreSQLComParsePacket actual = new PostgreSQLComParsePacket(payload);
actual.write(payload);
- assertThat(actual.getMessageType(), is('P'));
+ assertThat(actual.getIdentifier(), is('P'));
assertThat(actual.getSql(), is("sql"));
assertThat(actual.getStatementId(), is("sql"));
List<PostgreSQLBinaryStatementParameterType> types = actual.getBinaryStatementParameterTypes();
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLParseCompletePacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLParseCompletePacketTest.java
index d316716..fb29192 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLParseCompletePacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/parse/PostgreSQLParseCompletePacketTest.java
@@ -30,6 +30,6 @@ public final class PostgreSQLParseCompletePacketTest {
public void assertNewInstance() {
PostgreSQLParseCompletePacket actual = new PostgreSQLParseCompletePacket();
actual.write(mock(PostgreSQLPacketPayload.class));
- assertThat(actual.getMessageType(), is('1'));
+ assertThat(actual.getIdentifier(), is('1'));
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/sync/PostgreSQLComSyncPacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/sync/PostgreSQLComSyncPacketTest.java
index 5bdb005..8c11509 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/sync/PostgreSQLComSyncPacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/binary/sync/PostgreSQLComSyncPacketTest.java
@@ -38,6 +38,6 @@ public final class PostgreSQLComSyncPacketTest {
PostgreSQLComSyncPacket actual = new PostgreSQLComSyncPacket(payload);
actual.write(payload);
verify(payload).readInt4();
- assertThat(actual.getMessageType(), is('S'));
+ assertThat(actual.getIdentifier(), is('S'));
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/text/PostgreSQLComQueryPacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/text/PostgreSQLComQueryPacketTest.java
index 2cf0d4d..57bd307 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/text/PostgreSQLComQueryPacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/command/query/text/PostgreSQLComQueryPacketTest.java
@@ -41,6 +41,6 @@ public final class PostgreSQLComQueryPacketTest {
actual.write(payload);
verify(payload).readInt4();
assertThat(actual.getSql(), is("sql"));
- assertThat(actual.getMessageType(), is('Q'));
+ assertThat(actual.getIdentifier(), is('Q'));
}
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLAuthenticationMD5PasswordPacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLAuthenticationMD5PasswordPacketTest.java
index 37a31c0..701b991 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLAuthenticationMD5PasswordPacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLAuthenticationMD5PasswordPacketTest.java
@@ -36,7 +36,7 @@ public final class PostgreSQLAuthenticationMD5PasswordPacketTest {
ByteBuf byteBuf = ByteBufTestUtils.createByteBuf(expectedLength);
PostgreSQLPacketPayload payload = new PostgreSQLPacketPayload(byteBuf);
PostgreSQLAuthenticationMD5PasswordPacket packet = new PostgreSQLAuthenticationMD5PasswordPacket(md5Salt);
- assertThat(packet.getMessageType(), is(PostgreSQLCommandPacketType.AUTHENTICATION_REQUEST.getValue()));
+ assertThat(packet.getIdentifier(), is(PostgreSQLCommandPacketType.AUTHENTICATION_REQUEST.getValue()));
packet.write(payload);
assertThat(byteBuf.writerIndex(), is(expectedLength));
assertThat(byteBuf.readInt(), is(5));
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLAuthenticationOKPacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLAuthenticationOKPacketTest.java
index 648d6a5..c2bddd8 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLAuthenticationOKPacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLAuthenticationOKPacketTest.java
@@ -43,7 +43,7 @@ public final class PostgreSQLAuthenticationOKPacketTest {
ByteBuf byteBuf = ByteBufTestUtils.createByteBuf(4);
PostgreSQLPacketPayload payload = new PostgreSQLPacketPayload(byteBuf);
PostgreSQLAuthenticationOKPacket packet = new PostgreSQLAuthenticationOKPacket(isSuccess);
- assertThat(packet.getMessageType(), is(PostgreSQLCommandPacketType.AUTHENTICATION_REQUEST.getValue()));
+ assertThat(packet.getIdentifier(), is(PostgreSQLCommandPacketType.AUTHENTICATION_REQUEST.getValue()));
packet.write(payload);
assertThat(byteBuf.writerIndex(), is(4));
assertThat(byteBuf.readInt(), is(isSuccess ? 0 : 1));
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLComTerminationPacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLComTerminationPacketTest.java
index 4006238..fd51ae8 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLComTerminationPacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLComTerminationPacketTest.java
@@ -34,7 +34,7 @@ public final class PostgreSQLComTerminationPacketTest {
byteBuf.writeInt(1);
PostgreSQLPacketPayload payload = new PostgreSQLPacketPayload(byteBuf);
PostgreSQLComTerminationPacket packet = new PostgreSQLComTerminationPacket(payload);
- assertThat(packet.getMessageType(), is(PostgreSQLCommandPacketType.TERMINATE.getValue()));
+ assertThat(packet.getIdentifier(), is(PostgreSQLCommandPacketType.TERMINATE.getValue()));
assertThat(byteBuf.readerIndex(), is(4));
packet.write(payload);
assertThat(byteBuf.writerIndex(), is(4));
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLCommandCompletePacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLCommandCompletePacketTest.java
index e5ce8dd..7e01501 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLCommandCompletePacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLCommandCompletePacketTest.java
@@ -35,7 +35,7 @@ public final class PostgreSQLCommandCompletePacketTest {
int expectedStringLength = expectedString.length();
PostgreSQLPacketPayload payload = new PostgreSQLPacketPayload(ByteBufTestUtils.createByteBuf(expectedStringLength + 1));
PostgreSQLCommandCompletePacket packet = new PostgreSQLCommandCompletePacket(sqlCommand, rowCount);
- assertThat(packet.getMessageType(), is(PostgreSQLCommandPacketType.COMMAND_COMPLETE.getValue()));
+ assertThat(packet.getIdentifier(), is(PostgreSQLCommandPacketType.COMMAND_COMPLETE.getValue()));
packet.write(payload);
assertThat(payload.readStringNul(), is(expectedString));
}
@@ -48,7 +48,7 @@ public final class PostgreSQLCommandCompletePacketTest {
int expectedStringLength = expectedString.length();
PostgreSQLPacketPayload payload = new PostgreSQLPacketPayload(ByteBufTestUtils.createByteBuf(expectedStringLength + 1));
PostgreSQLCommandCompletePacket packet = new PostgreSQLCommandCompletePacket(sqlCommand, rowCount);
- assertThat(packet.getMessageType(), is(PostgreSQLCommandPacketType.COMMAND_COMPLETE.getValue()));
+ assertThat(packet.getIdentifier(), is(PostgreSQLCommandPacketType.COMMAND_COMPLETE.getValue()));
packet.write(payload);
assertThat(payload.readStringNul(), is(expectedString));
}
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLParameterStatusPacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLParameterStatusPacketTest.java
index a1e4c22..7977bab 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLParameterStatusPacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLParameterStatusPacketTest.java
@@ -37,7 +37,7 @@ public final class PostgreSQLParameterStatusPacketTest {
ByteBuf byteBuf = ByteBufTestUtils.createByteBuf(expectedLength);
PostgreSQLPacketPayload payload = new PostgreSQLPacketPayload(byteBuf);
PostgreSQLParameterStatusPacket packet = new PostgreSQLParameterStatusPacket(key, value);
- assertThat(packet.getMessageType(), is(PostgreSQLCommandPacketType.PARAMETER_STATUS.getValue()));
+ assertThat(packet.getIdentifier(), is(PostgreSQLCommandPacketType.PARAMETER_STATUS.getValue()));
packet.write(payload);
assertThat(byteBuf.writerIndex(), is(expectedLength));
assertThat(payload.readStringNul(), is(key));
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLPasswordMessagePacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLPasswordMessagePacketTest.java
index 8c9a832..f93ea28 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLPasswordMessagePacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLPasswordMessagePacketTest.java
@@ -38,7 +38,7 @@ public final class PostgreSQLPasswordMessagePacketTest {
payload.writeInt4(expectedLength);
payload.writeStringNul(md5Digest);
PostgreSQLPasswordMessagePacket packet = new PostgreSQLPasswordMessagePacket(payload);
- assertThat(packet.getMessageType(), is(PostgreSQLCommandPacketType.PASSWORD_MESSAGE.getValue()));
+ assertThat(packet.getIdentifier(), is(PostgreSQLCommandPacketType.PASSWORD_MESSAGE.getValue()));
assertThat(packet.getMd5Digest(), is(md5Digest));
packet.write(payload);
assertThat(byteBuf.writerIndex(), is(expectedLength));
diff --git a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLReadyForQueryPacketTest.java b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLReadyForQueryPacketTest.java
index 1c9db47..8ccd9c0 100644
--- a/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLReadyForQueryPacketTest.java
+++ b/shardingsphere-db-protocol/shardingsphere-db-protocol-postgresql/src/test/java/org/apache/shardingsphere/db/protocol/postgresql/packet/generic/PostgreSQLReadyForQueryPacketTest.java
@@ -33,7 +33,7 @@ public final class PostgreSQLReadyForQueryPacketTest {
ByteBuf byteBuf = ByteBufTestUtils.createByteBuf(1);
PostgreSQLPacketPayload payload = new PostgreSQLPacketPayload(byteBuf);
PostgreSQLReadyForQueryPacket packet = new PostgreSQLReadyForQueryPacket();
- assertThat(packet.getMessageType(), is(PostgreSQLCommandPacketType.READY_FOR_QUERY.getValue()));
+ assertThat(packet.getIdentifier(), is(PostgreSQLCommandPacketType.READY_FOR_QUERY.getValue()));
packet.write(payload);
assertThat(byteBuf.writerIndex(), is(1));
assertThat(byteBuf.readByte(), is((byte) 'I'));