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 ce1f59cdf41 Fix sonar issue on EncryptInsertCipherNameTokenGenerator 
(#34986)
ce1f59cdf41 is described below

commit ce1f59cdf4130a1d10008baa688de1ec0d145c4c
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Fri Mar 14 10:22:43 2025 +0800

    Fix sonar issue on EncryptInsertCipherNameTokenGenerator (#34986)
---
 .../generator/insert/EncryptInsertCipherNameTokenGenerator.java      | 5 +++--
 .../generator/insert/EncryptInsertDerivedColumnsTokenGenerator.java  | 3 ++-
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/insert/EncryptInsertCipherNameTokenGenerator.java
 
b/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/insert/EncryptInsertCipherNameTokenGenerator.java
index de801569e3f..34c8db35c6e 100644
--- 
a/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/insert/EncryptInsertCipherNameTokenGenerator.java
+++ 
b/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/insert/EncryptInsertCipherNameTokenGenerator.java
@@ -68,15 +68,16 @@ public final class EncryptInsertCipherNameTokenGenerator 
implements CollectionSQ
     public Collection<SQLToken> generateSQLTokens(final InsertStatementContext 
insertStatementContext) {
         Optional<InsertColumnsSegment> insertColumnsSegment = 
insertStatementContext.getSqlStatement().getInsertColumns();
         Preconditions.checkState(insertColumnsSegment.isPresent());
-        QuoteCharacter quoteCharacter = new 
DatabaseTypeRegistry(insertStatementContext.getDatabaseType()).getDialectDatabaseMetaData().getQuoteCharacter();
         Collection<ColumnSegment> insertColumns = 
insertColumnsSegment.get().getColumns();
         if (null != insertStatementContext.getInsertSelectContext()) {
             
checkInsertSelectEncryptor(insertStatementContext.getInsertSelectContext().getSelectStatementContext(),
 insertColumns);
         }
-        Optional<EncryptTable> encryptTable = 
rule.findEncryptTable(insertStatementContext.getSqlStatement().getTable().map(optional
 -> optional.getTableName().getIdentifier().getValue()).orElse(""));
+        Optional<EncryptTable> encryptTable = 
rule.findEncryptTable(insertStatementContext.getSqlStatement().getTable()
+                .map(optional -> 
optional.getTableName().getIdentifier().getValue()).orElse(""));
         if (!encryptTable.isPresent()) {
             return Collections.emptyList();
         }
+        QuoteCharacter quoteCharacter = new 
DatabaseTypeRegistry(insertStatementContext.getDatabaseType()).getDialectDatabaseMetaData().getQuoteCharacter();
         Collection<SQLToken> result = new LinkedList<>();
         for (ColumnSegment each : insertColumns) {
             String columnName = each.getIdentifier().getValue();
diff --git 
a/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/insert/EncryptInsertDerivedColumnsTokenGenerator.java
 
b/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/insert/EncryptInsertDerivedColumnsTokenGenerator.java
index 3c5cdd35faf..4f51e99d6cd 100644
--- 
a/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/insert/EncryptInsertDerivedColumnsTokenGenerator.java
+++ 
b/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/insert/EncryptInsertDerivedColumnsTokenGenerator.java
@@ -55,7 +55,8 @@ public final class EncryptInsertDerivedColumnsTokenGenerator 
implements Collecti
     
     @Override
     public Collection<SQLToken> generateSQLTokens(final InsertStatementContext 
insertStatementContext) {
-        Optional<EncryptTable> encryptTable = 
rule.findEncryptTable(insertStatementContext.getSqlStatement().getTable().map(optional
 -> optional.getTableName().getIdentifier().getValue()).orElse(""));
+        Optional<EncryptTable> encryptTable = 
rule.findEncryptTable(insertStatementContext.getSqlStatement().getTable()
+                .map(optional -> 
optional.getTableName().getIdentifier().getValue()).orElse(""));
         if (!encryptTable.isPresent()) {
             return Collections.emptyList();
         }

Reply via email to