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

terrymanu 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 15c71f826c5 Fix code format (#39808)
15c71f826c5 is described below

commit 15c71f826c5d66659628f21be00a538859991716
Author: Liang Zhang <[email protected]>
AuthorDate: Sat Sep 12 00:21:09 2026 +0800

    Fix code format (#39808)
    
    * Remove useless codes
    
    * Fix code format
---
 .../generator/insert/EncryptInsertValuesTokenGenerator.java      | 9 +++------
 1 file changed, 3 insertions(+), 6 deletions(-)

diff --git 
a/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/insert/EncryptInsertValuesTokenGenerator.java
 
b/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/insert/EncryptInsertValuesTokenGenerator.java
index c6b453496eb..c60a39c7c42 100644
--- 
a/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/insert/EncryptInsertValuesTokenGenerator.java
+++ 
b/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/insert/EncryptInsertValuesTokenGenerator.java
@@ -105,8 +105,7 @@ public final class EncryptInsertValuesTokenGenerator 
implements OptionalSQLToken
         String tableName = 
insertStatementContext.getSqlStatement().getTable().map(optional -> 
optional.getTableName().getIdentifier().getValue()).orElse("");
         EncryptTable encryptTable = rule.getEncryptTable(tableName);
         int count = 0;
-        String schemaName = 
insertStatementContext.getTablesContext().getSchemaName()
-                .orElseGet(database::getDefaultSchemaName);
+        String schemaName = 
insertStatementContext.getTablesContext().getSchemaName().orElseGet(database::getDefaultSchemaName);
         for (InsertValueContext each : 
insertStatementContext.getInsertValueContexts()) {
             
applyInsertColumnTokens(insertValuesToken.getInsertValues().get(count), 
encryptToken(schemaName, encryptTable, insertStatementContext, each));
             count++;
@@ -118,8 +117,7 @@ public final class EncryptInsertValuesTokenGenerator 
implements OptionalSQLToken
         Collection<InsertValuesSegment> insertValuesSegments = 
insertStatementContext.getSqlStatement().getValues();
         InsertValuesToken result = new 
EncryptInsertValuesToken(getStartIndex(insertValuesSegments), 
getStopIndex(insertValuesSegments));
         EncryptTable encryptTable = rule.getEncryptTable(tableName);
-        String schemaName = 
insertStatementContext.getTablesContext().getSchemaName()
-                .orElseGet(database::getDefaultSchemaName);
+        String schemaName = 
insertStatementContext.getTablesContext().getSchemaName().orElseGet(database::getDefaultSchemaName);
         for (InsertValueContext each : 
insertStatementContext.getInsertValueContexts()) {
             InsertValue insertValueToken = new InsertValue(new 
LinkedList<>(each.getValueExpressions()));
             applyInsertColumnTokens(insertValueToken, encryptToken(schemaName, 
encryptTable, insertStatementContext, each));
@@ -163,8 +161,7 @@ public final class EncryptInsertValuesTokenGenerator 
implements OptionalSQLToken
             int parameterIndexCount = 
getParameterIndexCount(insertValueContext.getValueExpressions());
             generateCipherColumnToken(schemaName, tableName, encryptColumn, 
valueExpression, columnIndex, literalValue).ifPresent(result::add);
             if (encryptColumn.getAssistedQuery().isPresent()) {
-                addAssistedQueryColumn(schemaName, tableName, encryptColumn, 
valueExpression, columnIndex, literalValue, parameterIndexCount)
-                        .ifPresent(result::add);
+                addAssistedQueryColumn(schemaName, tableName, encryptColumn, 
valueExpression, columnIndex, literalValue, 
parameterIndexCount).ifPresent(result::add);
             }
             if (encryptColumn.getLikeQuery().isPresent()) {
                 addLikeQueryColumn(schemaName, tableName, encryptColumn, 
valueExpression, columnIndex, literalValue, 
parameterIndexCount).ifPresent(result::add);

Reply via email to