fix(configuration): add Configuration Consumer for UserConfigService (#…

…2198)

* add Configuration Consumer for UserConfigService

* fix autowired ConnectionAdapter bean

server/integration-test/src/test/java/com/oceanbase/odc/service/connection/ConnectionTestingTest.java

@@ -46,7 +46,7 @@ public class ConnectionTestingTest {
     @Mock
     private ConnectionSSLAdaptor sslAdaptor;
     @Mock
-    private DefaultConnectionAdapter environmentAdapter;
+    private ConnectionAdapter environmentAdapter;
 
     @Before
     public void setUp() throws Exception {

server/odc-service/src/main/java/com/oceanbase/odc/service/config/UserConfigService.java

@@ -21,6 +21,7 @@
 import java.util.Map;
 import java.util.Objects;
 import java.util.concurrent.TimeUnit;
+import java.util.function.Consumer;
 import java.util.stream.Collectors;
 
 import javax.annotation.PostConstruct;
@@ -59,6 +60,18 @@ public class UserConfigService {
             .maximumSize(500).expireAfterWrite(60, TimeUnit.SECONDS)
             .build(this::internalGetUserConfigurations);
 
+    private List<Consumer<Configuration>> configurationConsumers = new ArrayList<>();
+
+    @SkipAuthorize("odc internal usage")
+    public void addConfigurationConsumer(Consumer<Configuration> consumer) {
+        this.configurationConsumers.add(consumer);
+    }
+
+    @SkipAuthorize("odc internal usage")
+    public List<Consumer<Configuration>> getConfigurationConsumer() {
+        return this.configurationConsumers;
+    }
+
     @PostConstruct
     public void init() {
         List<ConfigurationMeta> allConfigMetas = userConfigMetaService.listAllConfigMetas();
@@ -96,6 +109,9 @@ public List<Configuration> listUserConfigurations(@NotNull Long userId) {
             if (keyToConfiguration.containsKey(configuration.getKey())) {
                 configuration.setValue(keyToConfiguration.get(configuration.getKey()).getValue());
             }
+            for (Consumer<Configuration> consumer : getConfigurationConsumer()) {
+                consumer.accept(configuration);
+            }
         }
         return configurations;
     }

server/odc-service/src/main/java/com/oceanbase/odc/service/connection/ConnectionService.java

@@ -167,7 +167,7 @@ public class ConnectionService {
     private ConnectProperties connectProperties;
 
     @Autowired
-    private DefaultConnectionAdapter environmentAdapter;
+    private ConnectionAdapter environmentAdapter;
 
     @Autowired
     private ConnectionSSLAdaptor connectionSSLAdaptor;

server/odc-service/src/main/java/com/oceanbase/odc/service/connection/ConnectionTesting.java

@@ -72,7 +72,7 @@ public class ConnectionTesting {
     @Autowired
     private ConnectProperties connectProperties;
     @Autowired
-    private DefaultConnectionAdapter environmentAdapter;
+    private ConnectionAdapter environmentAdapter;
     @Autowired
     private ConnectionSSLAdaptor connectionSSLAdaptor;
     @Autowired