From 02727f5389622a22d023bfd2d3baaf6b02fea098 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期一, 13 五月 2019 18:01:57 +0800
Subject: [PATCH] 加入分片功能呢
---
java110-service/src/main/java/com/java110/service/dao/impl/QueryServiceDAOImpl.java | 120 +++++++++++++++++++++++++++++++++++++----------------------
1 files changed, 75 insertions(+), 45 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 2900eb6..65ace0a 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
@@ -2,13 +2,24 @@
import com.java110.common.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.*;
-import java.util.*;
+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;
+
/**
* Created by wuxw on 2018/4/20.
@@ -17,36 +28,39 @@
@Transactional
public class QueryServiceDAOImpl extends BaseServiceDao implements IQueryServiceDAO {
+ private final static Logger logger = LoggerFactory.getLogger(QueryServiceDAOImpl.class);
+
/**
- * 闃叉sql娉ㄥ叆 鏀归�犳垚鐩存帴鐢╬repareStatement 棰勫鐞唖ql
+ * 闃叉sql娉ㄥ叆 鏀归�犳垚鐩存帴鐢╬repareStatement 棰勫鐞唖ql
+ *
* @param sql
* @param params
* @return
*/
@Override
- public List<Map<String,Object>> executeSql(String sql,Object[] params) {
- logger.debug("----銆恞ueryServiceDAOImpl.executeSql銆戝叆鍙� : "+sql+" params= "+params);
+ 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>>();
+ 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]);
+ 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.getColumnName(i+1);
+ 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){
+ if (col_value == null) {
col_value = "";
}
map.put(col_name, col_value);
@@ -55,13 +69,17 @@
}
return mapList;
} catch (SQLException e) {
- logger.error("鎵цsql寮傚父锛�" + sql +params,e);
+ logger.error("鎵цsql寮傚父锛�" + sql + params, e);
return null;
- }finally{
+ } finally {
try {
//conn.close();
- ps.close();
- rs.close();
+ if (ps != null) {
+ ps.close();
+ }
+ if (rs != null) {
+ rs.close();
+ }
} catch (SQLException e) {
e.printStackTrace();
}
@@ -71,28 +89,29 @@
/**
* 闃叉sql娉ㄥ叆 鏀归�犳垚鐩存帴鐢╬repareStatement 棰勫鐞唖ql
+ *
* @param sql
* @param params
* @return
*/
- public int updateSql(String sql,Object[] params){
- logger.debug("----銆恞ueryServiceDAOImpl.updateSql銆戝叆鍙� : "+sql+" params= "+params);
+ 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]);
+ 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);
+ logger.error("鎵цsql寮傚父锛�" + sql + params, e);
return 0;
- }finally{
+ } finally {
try {
//conn.close();
ps.close();
@@ -104,55 +123,66 @@
}
@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