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 0d6b991878d Fix code format (#39794)
0d6b991878d is described below
commit 0d6b991878dec031cf13077dbf192c339ba3fb77
Author: Liang Zhang <[email protected]>
AuthorDate: Fri Sep 11 01:16:09 2026 +0800
Fix code format (#39794)
---
.../binder/context/statement/type/dml/InsertStatementContext.java | 2 +-
.../ingest/incremental/wal/decode/TestDecodingPluginTest.java | 1 +
.../postgresql/sqlbuilder/PostgreSQLPipelineSQLBuilderTest.java | 3 +--
.../command/query/batch/FirebirdBatchedStatementsExecutorTest.java | 3 +--
4 files changed, 4 insertions(+), 5 deletions(-)
diff --git
a/infra/binder/core/src/main/java/org/apache/shardingsphere/infra/binder/context/statement/type/dml/InsertStatementContext.java
b/infra/binder/core/src/main/java/org/apache/shardingsphere/infra/binder/context/statement/type/dml/InsertStatementContext.java
index a06519cc5d2..0e0fd29c963 100644
---
a/infra/binder/core/src/main/java/org/apache/shardingsphere/infra/binder/context/statement/type/dml/InsertStatementContext.java
+++
b/infra/binder/core/src/main/java/org/apache/shardingsphere/infra/binder/context/statement/type/dml/InsertStatementContext.java
@@ -41,9 +41,9 @@ import java.util.Optional;
/**
* Insert SQL statement context.
*/
+@Getter
public final class InsertStatementContext implements SQLStatementContext,
ParameterAware, WhereContextAvailable {
- @Getter
private final InsertStatementBaseContext baseContext;
private InsertStatementBindingContext bindingContext;
diff --git
a/kernel/data-pipeline/dialect/postgresql/src/test/java/org/apache/shardingsphere/data/pipeline/postgresql/ingest/incremental/wal/decode/TestDecodingPluginTest.java
b/kernel/data-pipeline/dialect/postgresql/src/test/java/org/apache/shardingsphere/data/pipeline/postgresql/ingest/incremental/wal/decode/TestDecodingPluginTest.java
index 23a6dd1150d..c74c5d2e3c3 100644
---
a/kernel/data-pipeline/dialect/postgresql/src/test/java/org/apache/shardingsphere/data/pipeline/postgresql/ingest/incremental/wal/decode/TestDecodingPluginTest.java
+++
b/kernel/data-pipeline/dialect/postgresql/src/test/java/org/apache/shardingsphere/data/pipeline/postgresql/ingest/incremental/wal/decode/TestDecodingPluginTest.java
@@ -80,6 +80,7 @@ class TestDecodingPluginTest {
+ "
t_jsonb[jsonb]:'{\"test\":\"😊Emojiä¸\"}'").getBytes(StandardCharsets.UTF_8));
WriteRowEvent actual = (WriteRowEvent) new
TestDecodingPlugin(null).decode(data, logSequenceNumber);
assertThat(actual.getLogSequenceNumber(), is(logSequenceNumber));
+ assertThat(actual.getSchemaName(), is("public"));
assertThat(actual.getTableName(), is("test"));
assertThat(actual.getAfterRow().get(0), is(" 1 2 3' 😊ä¸"));
assertThat(actual.getAfterRow().get(1), is("{}"));
diff --git
a/kernel/data-pipeline/dialect/postgresql/src/test/java/org/apache/shardingsphere/data/pipeline/postgresql/sqlbuilder/PostgreSQLPipelineSQLBuilderTest.java
b/kernel/data-pipeline/dialect/postgresql/src/test/java/org/apache/shardingsphere/data/pipeline/postgresql/sqlbuilder/PostgreSQLPipelineSQLBuilderTest.java
index 5aa4ba93ffd..a3735175c77 100644
---
a/kernel/data-pipeline/dialect/postgresql/src/test/java/org/apache/shardingsphere/data/pipeline/postgresql/sqlbuilder/PostgreSQLPipelineSQLBuilderTest.java
+++
b/kernel/data-pipeline/dialect/postgresql/src/test/java/org/apache/shardingsphere/data/pipeline/postgresql/sqlbuilder/PostgreSQLPipelineSQLBuilderTest.java
@@ -47,7 +47,6 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Optional;
-import java.util.stream.Collectors;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.is;
@@ -159,7 +158,7 @@ class PostgreSQLPipelineSQLBuilderTest {
mockConstruction(PostgreSQLIndexSQLGenerator.class,
(mocked, mockContext) -> when(mocked.generate(materials)).thenReturn("CREATE
INDEX foo_index"))) {
freemarkerManager.when(() ->
PostgreSQLPipelineFreemarkerManager.getSQLByVersion(materials,
"component/table/%s/create.ftl", 10, 1)).thenReturn("CREATE TABLE foo;");
Collection<String> actual =
sqlBuilder.buildCreateTableSQLs(dataSource, "public", "foo_tbl");
- List<String> actualList =
actual.stream().map(String::trim).collect(Collectors.toList());
+ List<String> actualList =
actual.stream().map(String::trim).toList();
assertThat(actualList.size(), is(2));
assertThat(actualList.get(0), is("CREATE TABLE foo"));
assertThat(actualList.get(1), is("CREATE INDEX foo_index"));
diff --git
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/batch/FirebirdBatchedStatementsExecutorTest.java
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/batch/FirebirdBatchedStatementsExecutorTest.java
index 6456a868e13..2376993baa5 100644
---
a/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/batch/FirebirdBatchedStatementsExecutorTest.java
+++
b/proxy/frontend/dialect/firebird/src/test/java/org/apache/shardingsphere/proxy/frontend/firebird/command/query/batch/FirebirdBatchedStatementsExecutorTest.java
@@ -148,8 +148,7 @@ class FirebirdBatchedStatementsExecutorTest {
.thenReturn(firstPreparedStatement, secondPreparedStatement);
ContextManager contextManager = mockContextManager("ds_0", "ds_1");
when(ProxyContext.getInstance().getContextManager()).thenReturn(contextManager);
- FirebirdServerPreparedStatement firebirdPreparedStatement = new
FirebirdServerPreparedStatement("INSERT INTO t (id, col) VALUES (?, ?)",
- mockInsertStatementContext(), new HintValueContext());
+ FirebirdServerPreparedStatement firebirdPreparedStatement = new
FirebirdServerPreparedStatement("INSERT INTO t (id, col) VALUES (?, ?)",
mockInsertStatementContext(), new HintValueContext());
List<Object> params = Arrays.asList(1, "foo_1");
ExecutionUnit firstExecutionUnit = new ExecutionUnit("ds_0", new
SQLUnit(firebirdPreparedStatement.getSql(), params));
ExecutionUnit secondExecutionUnit = new ExecutionUnit("ds_1", new
SQLUnit(firebirdPreparedStatement.getSql(), params));