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 0997ec95c9e Revise 25486 (#25611)
0997ec95c9e is described below
commit 0997ec95c9e699fab8e8289c5d3c111d02463910
Author: zhaojinchao <[email protected]>
AuthorDate: Fri May 12 18:09:38 2023 +0800
Revise 25486 (#25611)
---
.../QualifiedReadwriteSplittingPrimaryDataSourceRouterTest.java | 2 +-
...alifiedReadwriteSplittingTransactionalDataSourceRouterTest.java | 7 +++----
2 files changed, 4 insertions(+), 5 deletions(-)
diff --git
a/features/readwrite-splitting/core/src/test/java/org/apache/shardingsphere/readwritesplitting/route/qualified/type/QualifiedReadwriteSplittingPrimaryDataSourceRouterTest.java
b/features/readwrite-splitting/core/src/test/java/org/apache/shardingsphere/readwritesplitting/route/qualified/type/QualifiedReadwriteSplittingPrimaryDataSourceRouterTest.java
index 6c31a3604e2..1ebea240012 100644
---
a/features/readwrite-splitting/core/src/test/java/org/apache/shardingsphere/readwritesplitting/route/qualified/type/QualifiedReadwriteSplittingPrimaryDataSourceRouterTest.java
+++
b/features/readwrite-splitting/core/src/test/java/org/apache/shardingsphere/readwritesplitting/route/qualified/type/QualifiedReadwriteSplittingPrimaryDataSourceRouterTest.java
@@ -36,7 +36,7 @@ import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
@ExtendWith(MockitoExtension.class)
-public final class QualifiedReadwriteSplittingPrimaryDataSourceRouterTest {
+class QualifiedReadwriteSplittingPrimaryDataSourceRouterTest {
@Mock
private CommonSQLStatementContext<SQLStatement> sqlStatementContext;
diff --git
a/features/readwrite-splitting/core/src/test/java/org/apache/shardingsphere/readwritesplitting/route/qualified/type/QualifiedReadwriteSplittingTransactionalDataSourceRouterTest.java
b/features/readwrite-splitting/core/src/test/java/org/apache/shardingsphere/readwritesplitting/route/qualified/type/QualifiedReadwriteSplittingTransactionalDataSourceRouterTest.java
index b82ecb5c037..ab91cd98711 100644
---
a/features/readwrite-splitting/core/src/test/java/org/apache/shardingsphere/readwritesplitting/route/qualified/type/QualifiedReadwriteSplittingTransactionalDataSourceRouterTest.java
+++
b/features/readwrite-splitting/core/src/test/java/org/apache/shardingsphere/readwritesplitting/route/qualified/type/QualifiedReadwriteSplittingTransactionalDataSourceRouterTest.java
@@ -34,8 +34,8 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
-public final class
QualifiedReadwriteSplittingTransactionalDataSourceRouterTest {
-
+class QualifiedReadwriteSplittingTransactionalDataSourceRouterTest {
+
@Test
void assertWriteRouteTransaction() {
ConnectionContext connectionContext = mock(ConnectionContext.class);
@@ -46,7 +46,7 @@ public final class
QualifiedReadwriteSplittingTransactionalDataSourceRouterTest
when(connectionContext.getTransactionContext().isInTransaction()).thenReturn(Boolean.FALSE);
assertFalse(new
QualifiedReadwriteSplittingTransactionalDataSourceRouter(connectionContext).isQualified(null,
null));
}
-
+
@Test
void assertRoute() {
ReadwriteSplittingDataSourceRuleConfiguration
readwriteSplittingDataSourceRuleConfiguration =
@@ -59,5 +59,4 @@ public final class
QualifiedReadwriteSplittingTransactionalDataSourceRouterTest
rule = new
ReadwriteSplittingDataSourceRule(readwriteSplittingDataSourceRuleConfiguration,
TransactionalReadQueryStrategy.DYNAMIC, new
RoundRobinReadQueryLoadBalanceAlgorithm());
assertThat(new
QualifiedReadwriteSplittingTransactionalDataSourceRouter(new
ConnectionContext()).route(rule), is("read_ds_0"));
}
-
}