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

totalo 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 500fa90b97f Refactor DropTrafficRuleHandlerTest (#18467)
500fa90b97f is described below

commit 500fa90b97f12ee7b86e229beee4448df649b99b
Author: Liang Zhang <[email protected]>
AuthorDate: Tue Jun 21 00:23:20 2022 +0800

    Refactor DropTrafficRuleHandlerTest (#18467)
---
 .../updatable/DropTrafficRuleHandlerTest.java      | 35 ++++++++++------------
 1 file changed, 16 insertions(+), 19 deletions(-)

diff --git 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/DropTrafficRuleHandlerTest.java
 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/DropTrafficRuleHandlerTest.java
index f25bb0d69eb..249225d020c 100644
--- 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/DropTrafficRuleHandlerTest.java
+++ 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/test/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/DropTrafficRuleHandlerTest.java
@@ -46,17 +46,15 @@ public final class DropTrafficRuleHandlerTest extends 
ProxyContextRestorer {
     
     @Test(expected = RequiredRuleMissedException.class)
     public void assertExecuteWithNotExistRule() throws SQLException {
-        ContextManager contextManager = mockContextManager();
-        ProxyContext.init(contextManager);
+        mockContextManager();
         DropTrafficRuleHandler handler = new DropTrafficRuleHandler();
         handler.init(new 
DropTrafficRuleStatement(Collections.singleton("rule_name"), false), null);
         handler.execute();
     }
     
     @Test
-    public void assertExecute() throws SQLException {
+    public void assertExecuteWithIfExists() throws SQLException {
         ContextManager contextManager = mockContextManager();
-        ProxyContext.init(contextManager);
         DropTrafficRuleHandler handler = new DropTrafficRuleHandler();
         handler.init(new 
DropTrafficRuleStatement(Collections.singleton("rule_name_1"), false), null);
         handler.execute();
@@ -70,32 +68,30 @@ public final class DropTrafficRuleHandlerTest extends 
ProxyContextRestorer {
     }
     
     @Test
-    public void assertExecuteWithIfExists() throws SQLException {
+    public void assertExecuteWithNotExistRuleAndIfExists() throws SQLException 
{
         ContextManager contextManager = mockContextManager();
-        ProxyContext.init(contextManager);
         DropTrafficRuleHandler handler = new DropTrafficRuleHandler();
-        handler.init(new 
DropTrafficRuleStatement(Collections.singleton("rule_name_1"), false), null);
+        handler.init(new 
DropTrafficRuleStatement(Collections.singleton("rule_name_3"), true), null);
         handler.execute();
         TrafficRuleConfiguration updatedConfig = 
contextManager.getMetaDataContexts().getMetaData().getGlobalRuleMetaData().getSingleRule(TrafficRule.class).getConfiguration();
-        assertThat(updatedConfig.getTrafficStrategies().size(), is(1));
-        assertThat(updatedConfig.getLoadBalancers().size(), is(1));
-        assertThat(updatedConfig.getTrafficAlgorithms().size(), is(1));
-        assertThat(new 
ArrayList<>(updatedConfig.getTrafficStrategies()).get(0).getName(), 
is("rule_name_2"));
-        assertNotNull(updatedConfig.getTrafficAlgorithms().get("algorithm_2"));
-        assertNotNull(updatedConfig.getLoadBalancers().get("load_balancer_2"));
+        assertThat(updatedConfig.getTrafficStrategies().size(), is(2));
+        assertThat(updatedConfig.getLoadBalancers().size(), is(2));
+        assertThat(updatedConfig.getTrafficAlgorithms().size(), is(2));
     }
     
     @Test
-    public void assertExecuteWithNotExistRuleAndIfExists() throws SQLException 
{
+    public void assertExecute() throws SQLException {
         ContextManager contextManager = mockContextManager();
-        ProxyContext.init(contextManager);
         DropTrafficRuleHandler handler = new DropTrafficRuleHandler();
-        handler.init(new 
DropTrafficRuleStatement(Collections.singleton("rule_name_3"), true), null);
+        handler.init(new 
DropTrafficRuleStatement(Collections.singleton("rule_name_1"), false), null);
         handler.execute();
         TrafficRuleConfiguration updatedConfig = 
contextManager.getMetaDataContexts().getMetaData().getGlobalRuleMetaData().getSingleRule(TrafficRule.class).getConfiguration();
-        assertThat(updatedConfig.getTrafficStrategies().size(), is(2));
-        assertThat(updatedConfig.getLoadBalancers().size(), is(2));
-        assertThat(updatedConfig.getTrafficAlgorithms().size(), is(2));
+        assertThat(updatedConfig.getTrafficStrategies().size(), is(1));
+        assertThat(updatedConfig.getLoadBalancers().size(), is(1));
+        assertThat(updatedConfig.getTrafficAlgorithms().size(), is(1));
+        assertThat(new 
ArrayList<>(updatedConfig.getTrafficStrategies()).get(0).getName(), 
is("rule_name_2"));
+        assertNotNull(updatedConfig.getTrafficAlgorithms().get("algorithm_2"));
+        assertNotNull(updatedConfig.getLoadBalancers().get("load_balancer_2"));
     }
     
     private ContextManager mockContextManager() {
@@ -105,6 +101,7 @@ public final class DropTrafficRuleHandlerTest extends 
ProxyContextRestorer {
         TrafficRule rule = mock(TrafficRule.class);
         
when(rule.getConfiguration()).thenReturn(createTrafficRuleConfiguration());
         
when(globalRuleMetaData.getSingleRule(TrafficRule.class)).thenReturn(rule);
+        ProxyContext.init(result);
         return result;
     }
     

Reply via email to