|
|
@@ -34,9 +34,16 @@ public class DataCenterService extends AbstractService {
|
|
|
dataCenter.setOuterUrl(dataCenter.getOuterUrl() + "/");
|
|
|
}
|
|
|
}
|
|
|
- jdbcTemplate.update("update DataCenter set url=?,username=?,password=?,driverClassName=?,outerUrl=?",
|
|
|
- dataCenter.getUrl(), dataCenter.getUsername(), dataCenter.getPassword(), dataCenter.getDriverClassName(), dataCenter.getOuterUrl());
|
|
|
- dynamicDataSourceRegister.unregister(dataCenter);
|
|
|
+ DataCenter oldOne = find();
|
|
|
+ if (null == oldOne) {
|
|
|
+ jdbcTemplate.update("insert into DataCenter(id,driverClassName,url,username,password,outerUrl) values (1,?,?,?,?,?)",
|
|
|
+ dataCenter.getDriverClassName(), dataCenter.getUrl(), dataCenter.getUsername(), dataCenter.getPassword(), dataCenter.getOuterUrl());
|
|
|
+ dataCenter = find();
|
|
|
+ } else {
|
|
|
+ jdbcTemplate.update("update DataCenter set url=?,username=?,password=?,driverClassName=?,outerUrl=?",
|
|
|
+ dataCenter.getUrl(), dataCenter.getUsername(), dataCenter.getPassword(), dataCenter.getDriverClassName(), dataCenter.getOuterUrl());
|
|
|
+ dynamicDataSourceRegister.unregister(dataCenter);
|
|
|
+ }
|
|
|
if (null != dataCenter.getUsername() && null != dataCenter.getPassword() && null != dataCenter.getUrl()) {
|
|
|
dynamicDataSourceRegister.register(dataCenter);
|
|
|
ContextHolder.getApplicationContext().publishEvent(new DataCenterEvent(this, dataCenter));
|