信创改造

functional-modules/renkang-starter-batch/src/main/java/com/renkang/batch/configure/BatchAutoConfiguration.java

@@ -25,6 +25,7 @@ import org.springframework.core.task.TaskExecutor;
 import org.springframework.jdbc.support.JdbcTransactionManager;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.transaction.PlatformTransactionManager;
+import org.springframework.util.StringUtils;
 
 import javax.sql.DataSource;
 import java.util.List;
@@ -125,8 +126,21 @@ public class BatchAutoConfiguration {
             @BatchDataSource ObjectProvider<DataSource> batchDataSource,
             BatchProperties properties
     ) {
-        return new BatchDataSourceScriptDatabaseInitializer(batchDataSource.getIfAvailable(() -> dataSource),
-                properties.getJdbc());
+        DataSource dataSourceToUse = batchDataSource.getIfAvailable(() -> dataSource);
+        BatchProperties.Jdbc jdbc = properties.getJdbc();
+        // 达梦数据库兼容处理：设置platform绕过构造器中的自动类型检测
+        if (!StringUtils.hasText(jdbc.getPlatform())) {
+            jdbc.setPlatform("dm");
+        }
+        // 重写afterPropertiesSet()跳过SQL脚本初始化：
+        // 父类会先断言SQL文件存在再检查initializeSchema mode，导致找不到schema-dm.sql时报错
+        // Batch元数据表已通过数据迁移创建，无需自动建表
+        return new BatchDataSourceScriptDatabaseInitializer(dataSourceToUse, jdbc) {
+            @Override
+            public void afterPropertiesSet() {
+                // 跳过Batch元数据表的自动建表，防止找不到schema-dm.sql文件报错
+            }
+        };
     }
 
 }

functional-modules/renkang-starter-batch/src/main/java/com/renkang/batch/configure/CustomBatchConfigurer.java

@@ -34,6 +34,13 @@ public class CustomBatchConfigurer extends BasicBatchConfigurer {
         this.taskExecutor = taskExecutor;
     }
 
+    @Override
+    public void initialize() {
+        // 达梦数据库兼容处理：跳过Spring Batch数据库类型自动检测
+        // BasicBatchConfigurer.initialize()中DatabaseType.fromProductName()无法识别"DM DBMS"产品名
+        // 保持父类默认隔离级别ISOLATION_SERIALIZABLE，DM8与此兼容
+    }
+
     @Override
     protected JobLauncher createJobLauncher() throws Exception {
         SimpleJobLauncher jobLauncher = new SimpleJobLauncher();