lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

src

Browse Source
This commit is contained in:
redkale
2024-01-24 15:18:09 +08:00
parent 97d517abd9
commit 99a217cef6
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/org/redkale/source/spi/SourceModuleEngine.java
View File

@@ -417,6 +417,7 @@ public class SourceModuleEngine extends ModuleEngine implements SourceManager {
public DataSource loadDataSource(final String sourceName, boolean autoMemory) { public DataSource loadDataSource(final String sourceName, boolean autoMemory) {
dataSourceLock.lock(); dataSourceLock.lock();
try { try {
long st = System.currentTimeMillis();
DataSource old = resourceFactory.find(sourceName, DataSource.class); DataSource old = resourceFactory.find(sourceName, DataSource.class);
if (old != null) { if (old != null) {
return old; return old;
@@ -433,7 +434,7 @@ public class SourceModuleEngine extends ModuleEngine implements SourceManager {
} }
dataSources.add(source); dataSources.add(source);
resourceFactory.register(sourceName, DataSource.class, source); resourceFactory.register(sourceName, DataSource.class, source);
logger.info("Load DataSource resourceName = '" + sourceName + "', source = " + source); logger.info("Load DataSource resourceName = '" + sourceName + "', source = " + source + " in " + (System.currentTimeMillis() - st) + " ms");
return source; return source;
} }
if (!sourceConf.getValue(DataSources.DATA_SOURCE_RESOURCE, "").isEmpty()) { if (!sourceConf.getValue(DataSources.DATA_SOURCE_RESOURCE, "").isEmpty()) {
@@ -473,7 +474,7 @@ public class SourceModuleEngine extends ModuleEngine implements SourceManager {
resourceFactory.register(sourceName, DataJdbcSource.class, source); resourceFactory.register(sourceName, DataJdbcSource.class, source);
} }
} }
logger.info("Load DataSource resourceName = '" + sourceName + "', source = " + source); logger.info("Load DataSource resourceName = '" + sourceName + "', source = " + source + " in " + (System.currentTimeMillis() - st) + " ms");
return source; return source;
} catch (RuntimeException ex) { } catch (RuntimeException ex) {
throw ex; throw ex;