diff --git a/hcframe-parent/hcframe-base/pom.xml b/hcframe-parent/hcframe-base/pom.xml
index d4a7b19..555fb3a 100644
--- a/hcframe-parent/hcframe-base/pom.xml
+++ b/hcframe-parent/hcframe-base/pom.xml
@@ -9,7 +9,7 @@
4.0.0
hcframe-base
- 1.2.3-SNAPSHOT
+ 1.2.4-SNAPSHOT
8
@@ -48,6 +48,13 @@
+
+
+
+ com.highgo
+ HgdbJdbc
+ 6.2.3
+
org.apache.logging.log4j
log4j-api
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 2d5b8e2..641827b 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
@@ -58,6 +58,9 @@ public class BaseMapperImpl implements BaseMapper {
if (dataType.contains("sqlite")) {
datasourceConfig.setCommonType(DataUnit.SQLITE);
}
+ if(dataType.contains("highgo")) {
+ datasourceConfig.setCommonType(DataUnit.HANGO);
+ }
}
JudgesNull(dataMap.getData(), "data can not be null!");
JudgesNull(dataMap.getTableName(), "tableName can not be null!");
@@ -65,7 +68,7 @@ public class BaseMapperImpl implements BaseMapper {
dataMap.setPkName("ID");
}
int i;
- if (DataUnit.ORACLE.equals(datasourceConfig.getCommonType()) || DataUnit.DAMENG.equals(datasourceConfig.getCommonType())) {
+ if (DataUnit.ORACLE.equals(datasourceConfig.getCommonType()) || DataUnit.DAMENG.equals(datasourceConfig.getCommonType()) || DataUnit.HANGO.equals(datasourceConfig.getCommonType())) {
if (org.springframework.util.StringUtils.isEmpty(dataMap.get(dataMap.getPkName()))) {
Object id = getSequence(dataMap.getTableName(), dataMap.getPkName());
dataMap.toBuilder().add(dataMap.getPkName(), id);
@@ -82,10 +85,14 @@ public class BaseMapperImpl implements BaseMapper {
return i;
}
+ private String formatTable(String tableName) {
+ return "`"+tableName+"`";
+ }
@Override
public int save(String tableName, String pkName, Map data) {
JudgesNull(tableName, "data can not be null!");
JudgesNull(data, "tableName can not be null!");
+ tableName = formatTable(tableName);
String key;
DatasourceConfig datasourceConfig = new DatasourceConfig();
try {
@@ -132,6 +139,7 @@ public class BaseMapperImpl implements BaseMapper {
private int updateByWhere(Condition condition, String tableName, Map data) {
Map params = condition.getParamMap();
+ tableName = formatTable(tableName);
params.put("tableName", tableName);
params.put("info", data);
params.put("sql", condition.getSql());
@@ -244,6 +252,7 @@ public class BaseMapperImpl implements BaseMapper {
private int deleteByWhere(Condition condition, String tableName) {
Map params = condition.getParamMap();
+ tableName = formatTable(tableName);
params.put("tableName", tableName);
params.put("sql", condition.getSql());
return sqlSessionTemplate.delete(TABLE_MAPPER_PACKAGE + "deleteByWhere", params);
@@ -330,6 +339,7 @@ public class BaseMapperImpl implements BaseMapper {
@Override
public List