From cbc1f9db3d796683d88d6d30df3659984dfbeda3 Mon Sep 17 00:00:00 2001
From: webapp <webapp@home-server.attdns.com>
Date: 星期一, 30 九月 2019 22:56:12 +0800
Subject: [PATCH] 取消java110-common jar包，提升为CommonService服务,将之前的Java110-common内容变更为Java110-utils包
---
java110-service/src/main/java/com/java110/service/dao/impl/QueryServiceDAOImpl.java | 160 ++++++++++++++++++++++++++++++++++++++++++++---------
1 files changed, 133 insertions(+), 27 deletions(-)
diff --git a/java110-service/src/main/java/com/java110/service/dao/impl/QueryServiceDAOImpl.java b/java110-service/src/main/java/com/java110/service/dao/impl/QueryServiceDAOImpl.java
index cbf97c3..f2d4b70 100644
--- a/java110-service/src/main/java/com/java110/service/dao/impl/QueryServiceDAOImpl.java
+++ b/java110-service/src/main/java/com/java110/service/dao/impl/QueryServiceDAOImpl.java
@@ -1,15 +1,25 @@
package com.java110.service.dao.impl;
-import com.java110.common.util.StringUtil;
+import com.java110.utils.util.StringUtil;
import com.java110.core.base.dao.BaseServiceDao;
+import com.java110.entity.order.ServiceBusiness;
import com.java110.entity.service.ServiceSql;
import com.java110.service.dao.IQueryServiceDAO;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.ResultSetMetaData;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.HashMap;
import java.util.List;
import java.util.Map;
-import java.util.TreeMap;
+
/**
* Created by wuxw on 2018/4/20.
@@ -17,66 +27,162 @@
@Service("queryServiceDAOImpl")
@Transactional
public class QueryServiceDAOImpl extends BaseServiceDao implements IQueryServiceDAO {
+
+ private final static Logger logger = LoggerFactory.getLogger(QueryServiceDAOImpl.class);
+
+ /**
+ * 闃叉sql娉ㄥ叆 鏀归�犳垚鐩存帴鐢╬repareStatement 棰勫鐞唖ql
+ *
+ * @param sql
+ * @param params
+ * @return
+ */
@Override
- public List<Map> executeSql(String sql) {
- logger.debug("----銆恞ueryServiceDAOImpl.executeSql銆戝叆鍙� : "+sql);
- return sqlSessionTemplate.selectList("queryServiceDAOImpl.executeSql",sql);
+ public List<Map<String, Object>> executeSql(String sql, Object[] params) {
+ logger.debug("----銆恞ueryServiceDAOImpl.executeSql銆戝叆鍙� : " + sql + " params= " + params);
+ Connection conn = null;
+ ResultSet rs = null;
+ PreparedStatement ps = null;
+ List<Map<String, Object>> mapList = new ArrayList<Map<String, Object>>();
+ try {
+ conn = sqlSessionTemplate.getConnection();
+ ps = conn.prepareStatement(sql);
+ if (params != null) {
+ for (int i = 0; i < params.length; i++) {
+ ps.setObject(i + 1, params[i]);
+ }
+ }
+ rs = ps.executeQuery();
+ //绮鹃珦鐨勫湴鏂瑰氨鍦ㄨ繖閲岋紝绫籖esultSet鏈塯etMetaData()浼氳繑鍥炴暟鎹殑鍒楀拰瀵瑰簲鐨勫�肩殑淇℃伅锛岀劧鍚庢垜浠皢鍒楀悕鍜屽搴旂殑鍊间綔涓簃ap鐨勯敭鍊煎瓨鍏ap瀵硅薄涔嬩腑...
+ ResultSetMetaData rsmd = rs.getMetaData();
+ while (rs.next()) {
+ Map<String, Object> map = new HashMap<String, Object>();
+ for (int i = 0; i < rsmd.getColumnCount(); i++) {
+ String col_name = rsmd.getColumnLabel(i + 1);
+ Object col_value = rs.getObject(col_name);
+ if (col_value == null) {
+ col_value = "";
+ }
+ map.put(col_name, col_value);
+ }
+ mapList.add(map);
+ }
+ return mapList;
+ } catch (SQLException e) {
+ logger.error("鎵цsql寮傚父锛�" + sql + params, e);
+ return null;
+ } finally {
+ try {
+ //conn.close();
+ if (ps != null) {
+ ps.close();
+ }
+ if (rs != null) {
+ rs.close();
+ }
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ }
+ //return sqlSessionTemplate.selectList("queryServiceDAOImpl.executeSql",sql);
}
- public int updateSql(String sql){
- return sqlSessionTemplate.update("queryServiceDAOImpl.updateSql",sql);
+ /**
+ * 闃叉sql娉ㄥ叆 鏀归�犳垚鐩存帴鐢╬repareStatement 棰勫鐞唖ql
+ *
+ * @param sql
+ * @param params
+ * @return
+ */
+ public int updateSql(String sql, Object[] params) {
+ logger.debug("----銆恞ueryServiceDAOImpl.updateSql銆戝叆鍙� : " + sql + " params= " + params);
+ Connection conn = null;
+ PreparedStatement ps = null;
+ try {
+ conn = sqlSessionTemplate.getConnection();
+ ps = conn.prepareStatement(sql);
+ if (params != null) {
+ for (int i = 0; i < params.length; i++) {
+ ps.setObject(i + 1, params[i]);
+ }
+ }
+ return ps.executeUpdate();
+ //绮鹃珦鐨勫湴鏂瑰氨鍦ㄨ繖閲岋紝绫籖esultSet鏈塯etMetaData()浼氳繑鍥炴暟鎹殑鍒楀拰瀵瑰簲鐨勫�肩殑淇℃伅锛岀劧鍚庢垜浠皢鍒楀悕鍜屽搴旂殑鍊间綔涓簃ap鐨勯敭鍊煎瓨鍏ap瀵硅薄涔嬩腑...
+ } catch (SQLException e) {
+ logger.error("鎵цsql寮傚父锛�" + sql + params, e);
+ return 0;
+ } finally {
+ try {
+ //conn.close();
+ ps.close();
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ }
+ //return sqlSessionTemplate.update("queryServiceDAOImpl.updateSql",sql);
}
@Override
- public String executeProc(Map<String,Object> paramsInfo) {
+ public String executeProc(Map<String, Object> paramsInfo) {
String paramsInfoStr = "";
- for (String key : paramsInfo.keySet()){
- if("procName".equals(key)){
+ for (String key : paramsInfo.keySet()) {
+ if ("procName".equals(key)) {
paramsInfoStr += (paramsInfo.get("procName") + "(");
- }else{
- if(StringUtil.isNullOrNone(paramsInfo.get(key))){
+ } else {
+ if (StringUtil.isNullOrNone(paramsInfo.get(key))) {
paramsInfoStr += "'',";
- }else{
- paramsInfoStr += "'"+paramsInfo.get(key)+"',";
+ } else {
+ paramsInfoStr += "'" + paramsInfo.get(key) + "',";
}
}
}
- paramsInfo.put("paramsInfo",paramsInfoStr);
+ paramsInfo.put("paramsInfo", paramsInfoStr);
- sqlSessionTemplate.selectOne("queryServiceDAOImpl.executeProc",paramsInfo);
+ sqlSessionTemplate.selectOne("queryServiceDAOImpl.executeProc", paramsInfo);
- return paramsInfo.get("resMsg") ==null ?"" :paramsInfo.get("resMsg").toString();
+ return paramsInfo.get("resMsg") == null ? "" : paramsInfo.get("resMsg").toString();
}
@Override
- public String updateProc(Map<String,Object> paramsInfo) {
+ public String updateProc(Map<String, Object> paramsInfo) {
String paramsInfoStr = "";
- for (String key : paramsInfo.keySet()){
- if("procName".equals(key)){
+ for (String key : paramsInfo.keySet()) {
+ if ("procName".equals(key)) {
paramsInfoStr += (paramsInfo.get("procName") + "(");
- }else{
- if(StringUtil.isNullOrNone(paramsInfo.get(key))){
+ } else {
+ if (StringUtil.isNullOrNone(paramsInfo.get(key))) {
paramsInfoStr += "'',";
- }else{
- paramsInfoStr += "'"+paramsInfo.get(key)+"',";
+ } else {
+ paramsInfoStr += "'" + paramsInfo.get(key) + "',";
}
}
}
- paramsInfo.put("paramsInfo",paramsInfoStr);
+ paramsInfo.put("paramsInfo", paramsInfoStr);
- sqlSessionTemplate.update("queryServiceDAOImpl.updateProc",paramsInfo);
+ sqlSessionTemplate.update("queryServiceDAOImpl.updateProc", paramsInfo);
- return paramsInfo.get("resMsg") ==null ?"" :paramsInfo.get("resMsg").toString();
+ return paramsInfo.get("resMsg") == null ? "" : paramsInfo.get("resMsg").toString();
}
/**
* 鏌ヨ ServiceSql
+ *
* @return
*/
@Override
public List<ServiceSql> qureyServiceSqlAll() {
return sqlSessionTemplate.selectList("queryServiceDAOImpl.qureyServiceSqlAll");
}
+
+
+ /**
+ * 鏌ヨ鏈嶅姟涓氬姟淇℃伅
+ *
+ * @return
+ */
+ public List<ServiceBusiness> qureyServiceBusiness() {
+ return sqlSessionTemplate.selectList("queryServiceDAOImpl.queryServiceBusiness");
+ }
}
--
Gitblit v1.8.0