common-frame/hcframe
17
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

fix: fix datasource error

Browse Source
This commit is contained in:
taixingyiji
2025-04-09 09:33:20 +08:00
parent 622e4cbbe5
commit 5daf13eefe
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
hcframe-parent/hcframe-base/src/main/java/com/taixingyiji/base/module/data/module/BaseMapperImpl.java
View File

@@ -44,7 +44,7 @@ public class BaseMapperImpl implements BaseMapper {
}
@Override
public String getDataConfig() {
public String getDataConfig(){
String key;
DatasourceConfig datasourceConfig = new DatasourceConfig();
try {
@@ -70,6 +70,7 @@ public class BaseMapperImpl implements BaseMapper {
if (dbType.contains("PostgreSQL")) {
datasourceConfig.setCommonType(DataUnit.HANGO);
}
connection.close();
} catch (Exception e1) {
if (dataType.contains("oracle")) {
datasourceConfig.setCommonType(DataUnit.ORACLE);
@@ -745,8 +746,14 @@ public class BaseMapperImpl implements BaseMapper {
pkName = "ID";
}
int i;
if (dataTypeConfig.equals(DataUnit.ORACLE) || dataTypeConfig.equals(DataUnit.DAMENG) || dataTypeConfig.equals(DataUnit.HANGO)) {
Object id = getSequence(tableName, pkName);
if (dataTypeConfig.equals(DataUnit.ORACLE) || dataTypeConfig.equals(DataUnit.DAMENG)){
for (Map<String, Object> map : list) {
Object id = getSequence(tableName, pkName);
map.put(pkName, id);
}
i = tableMapper.insertBatch(list,tableName);
}else if(dataTypeConfig.equals(DataUnit.HANGO)) {
getSequence(tableName, pkName);
for (Map<String, Object> map : list) {
map.put(pkName, "nextval('"+tableName.toLowerCase()+"_seq')");
}