From 1f75b59680589aa2c5831ddfbe8255e0eab84fe8 Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期二, 03 一月 2023 15:38:39 +0800
Subject: [PATCH] #中间表对接
---
src/main/java/com/zy/ints/erp/ErpSqlServer.java | 71 +++++++++++++++++------------------
1 files changed, 35 insertions(+), 36 deletions(-)
diff --git a/src/main/java/com/zy/ints/erp/ErpSqlServer.java b/src/main/java/com/zy/ints/erp/ErpSqlServer.java
index 78b7ed8..fc8b96b 100644
--- a/src/main/java/com/zy/ints/erp/ErpSqlServer.java
+++ b/src/main/java/com/zy/ints/erp/ErpSqlServer.java
@@ -26,7 +26,7 @@
@Slf4j
@Service
public class ErpSqlServer {
-
+
// 鏁版嵁搴撹繛鎺�
// private Connection conn;
// 鍒涘缓棰勭紪璇戣鍙ュ璞★紝涓�鑸兘鏄敤杩欎釜鑰屼笉鐢⊿tatement
@@ -54,17 +54,18 @@
}
return list;
}
-
-
+
+
/**
* 鎵弿鎵�鏈夊疄鍔涚被灞炴�ч噷鐨凾ableField娉ㄨВ,骞跺皢閲岄潰鐨勫�间綔涓篶olumn
+ *
* @param cls
* @param <T>
* @return
*/
- public <T> String selectFrontPart(Class<T> cls){
+ public <T> String selectFrontPart(Class<T> cls) {
String tableName = cls.getDeclaredAnnotation(TableName.class).value();
- List<HashMap<String,String>> columnAndField = new ArrayList<>();
+ List<HashMap<String, String>> columnAndField = new ArrayList<>();
String sql = "SELECT ";
if (Cools.isEmpty(tableName)) {
return null;
@@ -73,7 +74,7 @@
for (Field f : allFields) {
if (Modifier.isFinal(f.getModifiers())
|| Modifier.isStatic(f.getModifiers())
- || Modifier.isTransient(f.getModifiers())){
+ || Modifier.isTransient(f.getModifiers())) {
continue;
}
String column = null;
@@ -85,16 +86,16 @@
}
String name = f.getName();
HashMap<String, String> container = new HashMap<>();
- container.put(column,name);
+ container.put(column, name);
columnAndField.add(container);
}
for (int i = 0; i < columnAndField.size(); i++) {
HashMap<String, String> stringStringHashMap = columnAndField.get(i);
- if (i == columnAndField.size() - 1){
+ if (i == columnAndField.size() - 1) {
for (String s : stringStringHashMap.keySet()) {
sql = sql + s + " AS " + stringStringHashMap.get(s);
}
- }else {
+ } else {
for (String s : stringStringHashMap.keySet()) {
sql = sql + s + " AS " + stringStringHashMap.get(s) + ", ";
}
@@ -103,40 +104,41 @@
sql = sql + " FROM " + tableName;
return sql;
}
-
- public String addWhere(String sql, Map<String,String> condition){
+
+ public String addWhere(String sql, Map<String, String> condition) {
int conditionSize = 1;
sql = sql + " WHERE ";
for (String s : condition.keySet()) {
- if (conditionSize == condition.keySet().size()){
+ if (conditionSize == condition.keySet().size()) {
sql = sql + s + " = " + condition.get(s);
- }else {
+ } else {
sql = sql + s + " = " + condition.get(s) + " and ";
}
conditionSize = conditionSize + 1;
}
return sql;
}
-
+
/**
* map鐨勯敭鏄垪鍚�, 鍊肩瓑鍚屼簬鍊�
* key: id, value: 1 绛夊悓浜� WHERE id = 1
* 濡傛灉瑕佹煡璇㈠瓧绗︿覆闇�瑕佽嚜琛屽姞涓�''
* key:name, value: 'zhs'绛夊悓浜� WHERE name = 'zhs'
+ *
* @param cls
* @param condition
* @param <T>
* @return
*/
- public <T> List<T> selectList(Class<T> cls, Map<String,String> condition){
+ public <T> List<T> selectList(Class<T> cls, Map<String, String> condition) {
String sql = selectFrontPart(cls);
String finalSQL = addWhere(sql, condition);
- return select(finalSQL,cls);
- }
-
- public <T> List<T> selectAll(Class<T> cls){
+ return select(finalSQL, cls);
+ }
+
+ public <T> List<T> selectAll(Class<T> cls) {
String sql = selectFrontPart(cls);
- return select(sql,cls);
+ return select(sql, cls);
}
public List<Map<String, Object>> select(String sql) {
@@ -150,7 +152,7 @@
return executeUpdate(sql);
}
- public <T> int delete(Class<T> cls, Map<String,String> condition) {
+ public <T> int delete(Class<T> cls, Map<String, String> condition) {
String tableName = cls.getDeclaredAnnotation(TableName.class).value();
if (Cools.isEmpty(tableName)) {
return 0;
@@ -159,8 +161,8 @@
String finalSQL = addWhere(sql, condition);
return executeUpdate(finalSQL);
}
-
- public <T> int insert(Class<T> cls, Map<String,Object> condition){
+
+ public <T> int insert(Class<T> cls, Map<String, Object> condition) {
String tableName = cls.getDeclaredAnnotation(TableName.class).value();
if (Cools.isEmpty(tableName)) {
return 0;
@@ -168,9 +170,9 @@
String sql = "INSERT INTO " + tableName + " (";
int conditionSize = 1;
for (String s : condition.keySet()) {
- if (conditionSize == condition.keySet().size()){
- sql = sql +s+")";
- }else {
+ if (conditionSize == condition.keySet().size()) {
+ sql = sql + s + ")";
+ } else {
sql = sql + s + ",";
}
conditionSize = conditionSize + 1;
@@ -178,25 +180,23 @@
sql = sql + " VALUES(";
int valuesSize = 1;
for (String s : condition.keySet()) {
- if (valuesSize == condition.keySet().size()){
-
- sql = sql + condition.get(s)+")";
- }else {
+ if (valuesSize == condition.keySet().size()) {
+
+ sql = sql + condition.get(s) + ")";
+ } else {
sql = sql + condition.get(s) + ",";
}
valuesSize = valuesSize + 1;
}
-
+
return executeUpdate(sql);
}
-
-
+
/*****************************************************************************/
/********************************* 鏍稿績灞� *********************************/
/*****************************************************************************/
-
private List<Map<String, Object>> executeQuery(String sql) {
Connection conn = null;
@@ -254,8 +254,7 @@
Connection conn = null;
try {
conn = getConn();
- if(null != conn)
- {
+ if (null != conn) {
pstm = conn.prepareStatement(sql);
} else {
log.error("鏇存柊ERP涓棿琛ㄥけ璐�===>>鏁版嵁搴撹繛鎺onn涓虹┖");
--
Gitblit v1.9.1