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

zhangliang 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 1395a578908 Refactor FirebirdStartTransactionPacket (#37599)
1395a578908 is described below

commit 1395a578908625d51392f57b9302601933f72563
Author: Liang Zhang <[email protected]>
AuthorDate: Thu Jan 1 12:53:12 2026 +0800

    Refactor FirebirdStartTransactionPacket (#37599)
    
    * Refactor FirebirdStartTransactionPacket
    
    * Refactor FirebirdStartTransactionPacket
---
 .../query/transaction/FirebirdStartTransactionPacket.java | 15 ++++++++++++---
 .../FirebirdStartTransactionCommandExecutor.java          |  4 ++--
 .../FirebirdStartTransactionCommandExecutorTest.java      |  4 ++--
 3 files changed, 16 insertions(+), 7 deletions(-)

diff --git 
a/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/packet/command/query/transaction/FirebirdStartTransactionPacket.java
 
b/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/packet/command/query/transaction/FirebirdStartTransactionPacket.java
index 303f0493e72..3404a4d4397 100644
--- 
a/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/packet/command/query/transaction/FirebirdStartTransactionPacket.java
+++ 
b/database/protocol/dialect/firebird/src/main/java/org/apache/shardingsphere/database/protocol/firebird/packet/command/query/transaction/FirebirdStartTransactionPacket.java
@@ -40,11 +40,21 @@ public final class FirebirdStartTransactionPacket extends 
FirebirdCommandPacket
         tpb.parseBuffer(payload.readBuffer());
     }
     
-    public boolean getAutocommit() {
+    /**
+     * Is auto commit.
+     *
+     * @return auto commit or not
+     */
+    public boolean isAutocommit() {
         return null != 
tpb.getValue(FirebirdTransactionParameterBufferType.AUTOCOMMIT);
     }
     
-    public boolean getReadOnly() {
+    /**
+     * Is read only.
+     *
+     * @return read only or not
+     */
+    public boolean isReadOnly() {
         return null != 
tpb.getValue(FirebirdTransactionParameterBufferType.READ);
     }
     
@@ -68,7 +78,6 @@ public final class FirebirdStartTransactionPacket extends 
FirebirdCommandPacket
     
     @Override
     protected void write(final FirebirdPacketPayload payload) {
-        
     }
     
     /**
diff --git 
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutor.java
 
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutor.java
index 676050d8960..4e556d13473 100644
--- 
a/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutor.java
+++ 
b/proxy/frontend/dialect/firebird/src/main/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutor.java
@@ -39,8 +39,8 @@ public final class FirebirdStartTransactionCommandExecutor 
implements CommandExe
     
     @Override
     public Collection<DatabasePacket> execute() {
-        connectionSession.setAutoCommit(packet.getAutocommit());
-        connectionSession.setReadOnly(packet.getReadOnly());
+        connectionSession.setAutoCommit(packet.isAutocommit());
+        connectionSession.setReadOnly(packet.isReadOnly());
         connectionSession.setIsolationLevel(packet.getIsolationLevel());
         int transactionId = 
FirebirdTransactionIdGenerator.getInstance().nextTransactionId(connectionSession.getConnectionId());
         return Collections.singleton(new 
FirebirdGenericResponsePacket().setHandle(transactionId));
diff --git 
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutorTest.java
 
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutorTest.java
index 8bf8e4efcab..6d57c80b0bb 100644
--- 
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutorTest.java
+++ 
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/transaction/FirebirdStartTransactionCommandExecutorTest.java
@@ -62,8 +62,8 @@ class FirebirdStartTransactionCommandExecutorTest {
     
     @Test
     void assertExecute() {
-        when(packet.getAutocommit()).thenReturn(true);
-        when(packet.getReadOnly()).thenReturn(true);
+        when(packet.isAutocommit()).thenReturn(true);
+        when(packet.isReadOnly()).thenReturn(true);
         
when(packet.getIsolationLevel()).thenReturn(TransactionIsolationLevel.SERIALIZABLE);
         FirebirdStartTransactionCommandExecutor executor = new 
FirebirdStartTransactionCommandExecutor(packet, connectionSession);
         Collection<DatabasePacket> actual = executor.execute();

Reply via email to