diff --git a/magic-api-spring-boot-starter/src/main/java/org/ssssssss/magicapi/spring/boot/starter/MagicAPIAutoConfiguration.java b/magic-api-spring-boot-starter/src/main/java/org/ssssssss/magicapi/spring/boot/starter/MagicAPIAutoConfiguration.java index dafdfff4cc7a31cc10f8f310e71997945efa71ef..0e0627ceee4747702dd9c4c135ab1759c920c93d 100644 --- a/magic-api-spring-boot-starter/src/main/java/org/ssssssss/magicapi/spring/boot/starter/MagicAPIAutoConfiguration.java +++ b/magic-api-spring-boot-starter/src/main/java/org/ssssssss/magicapi/spring/boot/starter/MagicAPIAutoConfiguration.java @@ -491,8 +491,10 @@ public class MagicAPIAutoConfiguration implements WebMvcConfigurer, WebSocketCon MagicResourceLoader.addModule(module.getModuleName(), module); }); MagicResourceLoader.addModule(sqlModule.getModuleName(), new DynamicModuleImport(SQLModule.class, context -> { + String dataSourceKey = context.getString(Options.DEFAULT_DATA_SOURCE.getValue()); + if(StringUtils.isEmpty(dataSourceKey)) return new SQLModule(dynamicDataSource); SQLModule newSqlModule = sqlModule.cloneSQLModule(); - newSqlModule.setDataSourceNode(dynamicDataSource.getDataSource(context.getString(Options.DEFAULT_DATA_SOURCE.getValue()))); + newSqlModule.setDataSourceNode(dynamicDataSource.getDataSource(dataSourceKey)); return newSqlModule; })); MagicResourceLoader.getModuleNames().stream().filter(importModules::contains).forEach(moduleName -> {