fix: 修复使用多数据源 + seata 分布式事务时，数据源解密错误的问题

mybatis-flex-core/src/main/java/com/mybatisflex/core/datasource/DataSourceManager.java

@@ -21,6 +21,9 @@ import org.apache.ibatis.logging.LogFactory;
 import javax.sql.DataSource;
 import java.lang.reflect.Method;
 
+/**
+ * @author michael
+ */
 public class DataSourceManager {
 
     private static DataSourceDecipher decipher;

mybatis-flex-core/src/main/java/com/mybatisflex/core/datasource/FlexDataSource.java

@@ -49,8 +49,13 @@ public class FlexDataSource extends AbstractDataSource {
     private final DataSource defaultDataSource;
 
     public FlexDataSource(String dataSourceKey, DataSource dataSource) {
+        this(dataSourceKey, dataSource, true);
+    }
 
+    public FlexDataSource(String dataSourceKey, DataSource dataSource, boolean needDecryptDataSource) {
+        if (needDecryptDataSource) {
             DataSourceManager.decryptDataSource(dataSource);
+        }
 
         this.defaultDataSourceKey = dataSourceKey;
         this.defaultDataSource = dataSource;
@@ -61,11 +66,19 @@ public class FlexDataSource extends AbstractDataSource {
     }
 
     public void addDataSource(String dataSourceKey, DataSource dataSource) {
+        addDataSource(dataSourceKey, dataSource, true);
+    }
+
+
+    public void addDataSource(String dataSourceKey, DataSource dataSource, boolean needDecryptDataSource) {
+        if (needDecryptDataSource) {
             DataSourceManager.decryptDataSource(dataSource);
+        }
         dataSourceMap.put(dataSourceKey, dataSource);
         dbTypeHashMap.put(dataSourceKey, DbTypeUtil.getDbType(dataSource));
     }
 
+
     public void removeDatasource(String dataSourceKey) {
         dataSourceMap.remove(dataSourceKey);
         dbTypeHashMap.remove(dataSourceKey);

mybatis-flex-spring-boot-starter/src/main/java/com/mybatisflex/spring/boot/MultiDataSourceAutoConfiguration.java

@@ -81,7 +81,10 @@ public class MultiDataSourceAutoConfiguration {
             DataSourceManager.setDecipher(dataSourceDecipher);
 
             for (Map.Entry<String, Map<String, String>> entry : dataSourceProperties.entrySet()) {
+
                 DataSource dataSource = new DataSourceBuilder(entry.getValue()).build();
+                DataSourceManager.decryptDataSource(dataSource);
+
                 if (seataConfig != null && seataConfig.isEnable()) {
                     if (seataConfig.getSeataMode() == SeataMode.XA) {
                         dataSource = new DataSourceProxyXA(dataSource);
@@ -89,10 +92,11 @@ public class MultiDataSourceAutoConfiguration {
                         dataSource = new DataSourceProxy(dataSource);
                     }
                 }
+
                 if (flexDataSource == null) {
-                    flexDataSource = new FlexDataSource(entry.getKey(), dataSource);
+                    flexDataSource = new FlexDataSource(entry.getKey(), dataSource, false);
                 } else {
-                    flexDataSource.addDataSource(entry.getKey(), dataSource);
+                    flexDataSource.addDataSource(entry.getKey(), dataSource, false);
                 }
             }
         }