From 5daf13eefe430cdf13b3a04ac2b4931840fcf048 Mon Sep 17 00:00:00 2001
From: taixingyiji <taixingyiji@126.com>
Date: Wed, 9 Apr 2025 09:33:20 +0800
Subject: [PATCH] fix: fix datasource error

---
 .../base/module/data/module/BaseMapperImpl.java     | 13 ++++++++++---
 1 file changed, 10 insertions(+), 3 deletions(-)

diff --git a/hcframe-parent/hcframe-base/src/main/java/com/taixingyiji/base/module/data/module/BaseMapperImpl.java b/hcframe-parent/hcframe-base/src/main/java/com/taixingyiji/base/module/data/module/BaseMapperImpl.java
index f18d1f9..5909bee 100644
--- a/hcframe-parent/hcframe-base/src/main/java/com/taixingyiji/base/module/data/module/BaseMapperImpl.java
+++ b/hcframe-parent/hcframe-base/src/main/java/com/taixingyiji/base/module/data/module/BaseMapperImpl.java
@@ -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')");
             }