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

Browse Source
This commit is contained in:
Redkale
2018-04-02 14:48:23 +08:00
parent 9e90ae5285
commit 84f6ce58a0
1 changed files with 16 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/org/redkale/source/DataJdbcSource.java
View File

@@ -59,6 +59,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, DataC
public DataJdbcSource(String unitName, Properties readprop, Properties writeprop) { public DataJdbcSource(String unitName, Properties readprop, Properties writeprop) {
this.preConstruct(unitName, readprop, writeprop); this.preConstruct(unitName, readprop, writeprop);
this.initByProperties(unitName, readprop, writeprop); this.initByProperties(unitName, readprop, writeprop);
} }
public DataJdbcSource() { public DataJdbcSource() {
@@ -86,7 +87,22 @@ public class DataJdbcSource extends AbstractService implements DataSource, DataC
if (pn == null || pv == null) continue; if (pn == null || pv == null) continue;
readprop.put(pn, pv); readprop.put(pn, pv);
} }
if (writeprop.isEmpty()) writeprop = readprop;
this.initByProperties(unitName, readprop, writeprop);
}
@Override
protected ExecutorService getExecutor() {
return executor;
}
@Override
public void destroy(AnyValue config) {
if (this.executor != null) this.executor.shutdownNow();
}
//构造前调用
protected void preConstruct(String unitName, Properties readprop, Properties writeprop) {
final AtomicInteger counter = new AtomicInteger(); final AtomicInteger counter = new AtomicInteger();
this.threads = Integer.decode(readprop.getProperty(JDBC_CONNECTIONSMAX, "" + Runtime.getRuntime().availableProcessors() * 16)); this.threads = Integer.decode(readprop.getProperty(JDBC_CONNECTIONSMAX, "" + Runtime.getRuntime().availableProcessors() * 16));
final Thread.UncaughtExceptionHandler ueh = (t, e) -> { final Thread.UncaughtExceptionHandler ueh = (t, e) -> {
@@ -105,22 +121,6 @@ public class DataJdbcSource extends AbstractService implements DataSource, DataC
t.setUncaughtExceptionHandler(ueh); t.setUncaughtExceptionHandler(ueh);
return t; return t;
}); });
if (writeprop.isEmpty()) writeprop = readprop;
this.initByProperties(unitName, readprop, writeprop);
}
@Override
protected ExecutorService getExecutor() {
return executor;
}
@Override
public void destroy(AnyValue config) {
if (this.executor != null) this.executor.shutdownNow();
}
//构造前调用
protected void preConstruct(String unitName, Properties readprop, Properties writeprop) {
} }
protected void initByProperties(String unitName, Properties readprop, Properties writeprop) { protected void initByProperties(String unitName, Properties readprop, Properties writeprop) {