You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by yx...@apache.org on 2022/08/14 15:08:24 UTC
[shardingsphere] branch master updated: For code format (#20171)
This is an automated email from the ASF dual-hosted git repository.
yx9o 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 8bde1b847e7 For code format (#20171)
8bde1b847e7 is described below
commit 8bde1b847e7c814852b7996c258a31922df23f57
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Sun Aug 14 23:08:19 2022 +0800
For code format (#20171)
---
.../shardingsphere/encrypt/distsql/parser/EncryptDistSqlTest.java | 7 +++----
.../data/pipeline/scenario/rulealtered/RuleAlteredJobWorker.java | 6 +++---
2 files changed, 6 insertions(+), 7 deletions(-)
diff --git a/shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-distsql/shardingsphere-encrypt-distsql-parser/src/test/java/org/apache/shardingsphere/encrypt/distsql/parser/EncryptDistSqlTest.java b/shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-distsql/shardingsphere-encrypt-distsql-parser/src/test/java/org/apache/shardingsphere/encrypt/distsql/parser/EncryptDistSqlTest.java
index f351cce9cb8..4c48222f3eb 100644
--- a/shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-distsql/shardingsphere-encrypt-distsql-parser/src/test/java/org/apache/shardingsphere/encrypt/distsql/parser/EncryptDistSqlTest.java
+++ b/shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-distsql/shardingsphere-encrypt-distsql-parser/src/test/java/org/apache/shardingsphere/encrypt/distsql/parser/EncryptDistSqlTest.java
@@ -49,9 +49,8 @@ public final class EncryptDistSqlTest {
CreateEncryptRuleStatement createEncryptRuleStatement = (CreateEncryptRuleStatement) getEncryptDistSQLStatement(sql);
assertThat(createEncryptRuleStatement.getRules().size(), is(1));
assertEncryptRule(createEncryptRuleStatement.getRules().iterator().next());
-
}
-
+
@Test
public void assertAlterEncryptRule() {
String sql = "ALTER ENCRYPT RULE t_encrypt (COLUMNS("
@@ -61,7 +60,7 @@ public final class EncryptDistSqlTest {
assertThat(alterEncryptRule.getRules().size(), is(1));
assertEncryptRule(alterEncryptRule.getRules().iterator().next());
}
-
+
private void assertEncryptRule(final EncryptRuleSegment encryptRuleSegment) {
assertThat(encryptRuleSegment.getTableName(), is("t_encrypt"));
assertThat(encryptRuleSegment.getColumns().size(), is(2));
@@ -82,7 +81,7 @@ public final class EncryptDistSqlTest {
assertThat(orderEncryptColumn.getEncryptor().getName(), is("MD5"));
assertThat(orderEncryptColumn.getEncryptor().getProps().size(), is(0));
}
-
+
@SneakyThrows(ReflectiveOperationException.class)
@SuppressWarnings("rawtypes")
private DistSQLStatement getEncryptDistSQLStatement(final String sql) {
diff --git a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/RuleAlteredJobWorker.java b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/RuleAlteredJobWorker.java
index 1e617a329f0..9e702a66c19 100644
--- a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/RuleAlteredJobWorker.java
+++ b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/RuleAlteredJobWorker.java
@@ -66,9 +66,9 @@ import java.util.stream.Collectors;
@SuppressWarnings("UnstableApiUsage")
@Slf4j
public final class RuleAlteredJobWorker {
-
+
private static final YamlRuleConfigurationSwapperEngine SWAPPER_ENGINE = new YamlRuleConfigurationSwapperEngine();
-
+
/**
* Is on rule altered action enabled.
*
@@ -82,7 +82,7 @@ public final class RuleAlteredJobWorker {
Optional<RuleAlteredDetector> detector = RuleAlteredDetectorFactory.findInstance(ruleConfig);
return detector.isPresent() && detector.get().getOnRuleAlteredActionConfig(ruleConfig).isPresent();
}
-
+
/**
* Create rule altered context.
*