1. repository do not catch db exception

王彬
1 parent d6a3508b
Showing 1 changed file with 34 additions and 111 deletions Show diff stats
src/main/java/com/taover/repository/CustomJdbcTemplate.java
@@ -250,13 +250,7 @@ public class CustomJdbcTemplate&lt;T, ID extends Serializable&gt; {
 			sql.append(" FOR UPDATE");
 			pql.append(" FOR UPDATE");
 		}
-		T result = null;
-		try {
-			result = (T) (fromWriteDB ? jdbcTemplateWrite : jdbcTemplateRead).queryForObject(sql.toString(), this.customJdbcTemplateRowMapper, id);
-		}catch(Exception e) {
-			UtilsLog.errorForException(e, this.getClass());
-		}
-		return result;
+		return (T) (fromWriteDB ? jdbcTemplateWrite : jdbcTemplateRead).queryForObject(sql.toString(), this.customJdbcTemplateRowMapper, id);
 	}
 	/**
@@ -315,14 +309,7 @@ public class CustomJdbcTemplate&lt;T, ID extends Serializable&gt; {
 		   sql.append(" " + sortCondition + " ");
 		   pql.append(" " + sortCondition + " ");
 		}
-		List<T> resultList = null;
-		try {
-			resultList = (fromWriteDB ? jdbcTemplateWrite : jdbcTemplateRead).query(sql.toString(), this.customJdbcTemplateRowMapper, list.toArray());
-			return resultList;
-		} catch (Exception e) {
-			UtilsLog.errorForException(e, this.getClass());
-		}
-		return null;
+		return (List<T>)(fromWriteDB ? jdbcTemplateWrite : jdbcTemplateRead).query(sql.toString(), this.customJdbcTemplateRowMapper, list.toArray());
 	}
 	/**
@@ -339,14 +326,7 @@ public class CustomJdbcTemplate&lt;T, ID extends Serializable&gt; {
 	 */
 	public List<T> findListBySql(String sqlCondition, boolean fromWriteDB) {
 		StringBuffer sql = new StringBuffer("SELECT "+this.tableFieldNameListGapWithComma+" FROM "+this.getTableSql()+" WHERE " + sqlCondition);
-		List<T> resultList = null;
-		try {
-			resultList = (fromWriteDB ? jdbcTemplateWrite : jdbcTemplateRead).query(sql.toString(), this.customJdbcTemplateRowMapper);
-			return resultList;
-		} catch (Exception e) {
-			UtilsLog.errorForException(e, this.getClass());
-		}
-		return null;
+		return (List<T>)(fromWriteDB ? jdbcTemplateWrite : jdbcTemplateRead).query(sql.toString(), this.customJdbcTemplateRowMapper);
 	}
 	/**
@@ -386,21 +366,16 @@ public class CustomJdbcTemplate&lt;T, ID extends Serializable&gt; {
 		}
 	  	String pageSql = sql.toString() + " limit ?, ?";
-			
+				
+		Map<String, Object> totalRowsMap = (fromWriteDB ? jdbcTemplateWrite : jdbcTemplateRead).queryForMap(sqlCount.toString(), count_list.toArray()) ;
+		
+		Map<String, Object> resultMap = new HashMap<String, Object>();
+		resultMap.put("page", page);
+		resultMap.put("total", totalRowsMap.get("rowCount"));
 		List<T> resultList = null;
-		try {
-			Map<String, Object> totalRowsMap = (fromWriteDB ? jdbcTemplateWrite : jdbcTemplateRead).queryForMap(sqlCount.toString(), count_list.toArray()) ;
-			
-			Map<String, Object> resultMap = new HashMap<String, Object>();
-			resultMap.put("page", page);
-			resultMap.put("total", totalRowsMap.get("rowCount"));
-			resultList = (fromWriteDB ? jdbcTemplateWrite : jdbcTemplateRead).query(pageSql.toString(), this.customJdbcTemplateRowMapper, page_list.toArray());
-			resultMap.put("rows", resultList);
-			return resultMap;
-		} catch (Exception e) {
-			UtilsLog.errorForException(e, this.getClass());
-		}
-		return null;
+		resultList = (fromWriteDB ? jdbcTemplateWrite : jdbcTemplateRead).query(pageSql.toString(), this.customJdbcTemplateRowMapper, page_list.toArray());
+		resultMap.put("rows", resultList);
+		return resultMap;
 	}
 	/**
@@ -422,22 +397,15 @@ public class CustomJdbcTemplate&lt;T, ID extends Serializable&gt; {
 		page_list.add((page - 1) * pageSize);
 		page_list.add(page * pageSize);
+		Map<String, Object> totalRowsMap = (fromWriteDB ? jdbcTemplateWrite : jdbcTemplateRead).queryForMap(sqlCount.toString());
+		Map<String, Object> resultMap = new HashMap<String, Object>();
+		resultMap.put("page", page);
+		resultMap.put("total", totalRowsMap.get("rowCount"));
 		List<T> resultList = null;
-		try {
-			
-			Map<String, Object> totalRowsMap = (fromWriteDB ? jdbcTemplateWrite : jdbcTemplateRead).queryForMap(sqlCount.toString());
-			
-			Map<String, Object> resultMap = new HashMap<String, Object>();
-			resultMap.put("page", page);
-			resultMap.put("total", totalRowsMap.get("rowCount"));
-			resultList = (fromWriteDB ? jdbcTemplateWrite : jdbcTemplateRead).query(pageSql.toString(), this.customJdbcTemplateRowMapper, page_list.toArray());
-			resultMap.put("rows", resultList);
-			return resultMap;
-		} catch (Exception e) {
-			UtilsLog.errorForException(e, this.getClass());
-		}
-		return null;
+		resultList = (fromWriteDB ? jdbcTemplateWrite : jdbcTemplateRead).query(pageSql.toString(), this.customJdbcTemplateRowMapper, page_list.toArray());
+		resultMap.put("rows", resultList);
+		return resultMap;
 	}
 	/**
@@ -482,14 +450,9 @@ public class CustomJdbcTemplate&lt;T, ID extends Serializable&gt; {
 		//执行SQL
 		String exeSql = sqlInsertPart.substring(0, sqlInsertPart.length()-1)+sqlColumnPart.substring(0, sqlColumnPart.length()-1)+")";
-		try {
-			jdbcTemplateWrite.update(exeSql, paramList.toArray());
-			Map<String, Object> lastInsertIdMap =  jdbcTemplateWrite.queryForMap("SELECT LAST_INSERT_ID() lastInsertId");
-			return (BigInteger)lastInsertIdMap.get("lastInsertId");
-		} catch (Exception e) {
-			UtilsLog.errorForException(e, this.getClass());
-		}
-		return null;
+		jdbcTemplateWrite.update(exeSql, paramList.toArray());
+		Map<String, Object> lastInsertIdMap =  jdbcTemplateWrite.queryForMap("SELECT LAST_INSERT_ID() lastInsertId");
+		return (BigInteger)lastInsertIdMap.get("lastInsertId");
 	}
 	/**
@@ -511,7 +474,6 @@ public class CustomJdbcTemplate&lt;T, ID extends Serializable&gt; {
 		StringBuffer pql = new StringBuffer(sql.toString());
 		pql.append(" "+this.idTableFieldName+" = " + id);
 		sql.append(" "+this.idTableFieldName+" = ?");
-		//UtilsLog.infoForMessage(pql.toString(), this.getClass());
 		return jdbcTemplateWrite.update(sql.toString(), id);
 	}
 	/**
@@ -528,12 +490,7 @@ public class CustomJdbcTemplate&lt;T, ID extends Serializable&gt; {
 		StringBuffer sql = new StringBuffer("DELETE FROM "+this.getTableSql()+"");
 		StringBuffer pql = new StringBuffer(sql.toString());
 		this.appendWhereCondition(sql, pql, list, condition);
-		try {
-			return jdbcTemplateWrite.update( sql.toString(), list.toArray());
-		} catch (Exception e) {
-			UtilsLog.errorForException(e, this.getClass());
-		}
-		return 0;
+		return jdbcTemplateWrite.update( sql.toString(), list.toArray());
 	}
 	/**
@@ -544,14 +501,8 @@ public class CustomJdbcTemplate&lt;T, ID extends Serializable&gt; {
 	public int deleteEntityBySql(String sqlCondition) throws Exception{
 		if("".equals(sqlCondition)) {
 			throw new Exception("没有传入条件，请至少传入一个筛选条件");
-		}		
-		StringBuffer sql = new StringBuffer("DELETE FROM "+this.getTableSql()+" WHERE ");
-		try {
-			return jdbcTemplateWrite.update( sql.toString() + sqlCondition);
-		} catch (Exception e) {
-			UtilsLog.errorForException(e, this.getClass());
 		}
-		return 0;
+		return jdbcTemplateWrite.update( "DELETE FROM "+this.getTableSql()+" WHERE " + sqlCondition);
 	}
 	/**
@@ -606,19 +557,10 @@ public class CustomJdbcTemplate&lt;T, ID extends Serializable&gt; {
 			}
 		}
-		//记录SQL
-		String pwhere = " WHERE "+this.idTableFieldName+"=\"" + id + "\"";
-		//UtilsLog.infoForMessage(pql.toString()+pwhere, this.getClass());
-		
-		try {
-			String where = " WHERE "+this.idTableFieldName+"=?";
-			String updateSql = sql.substring(0, sql.length()-1)+where;
-			list.add(id);			
-			return jdbcTemplateWrite.update(updateSql, list.toArray());
-		} catch (Exception e) {
-			UtilsLog.errorForException(e, this.getClass());
-		}
-		return 0;
+		String where = " WHERE "+this.idTableFieldName+"=?";
+		String updateSql = sql.substring(0, sql.length()-1)+where;
+		list.add(id);			
+		return jdbcTemplateWrite.update(updateSql, list.toArray());
 	}
 	/**
@@ -642,15 +584,8 @@ public class CustomJdbcTemplate&lt;T, ID extends Serializable&gt; {
 		StringBuffer pwhere = new StringBuffer("");
 		this.appendWhereCondition(where, pwhere, list, condition);
-		//UtilsLog.infoForMessage(pql.toString()+pwhere.toString(), this.getClass());
-		
 		String updateSql = sql.substring(0, sql.length()-1)+where.toString();
-		try {			
-			return jdbcTemplateWrite.update(updateSql, list.toArray());
-		} catch (Exception e) {
-			UtilsLog.errorForException(e, this.getClass());
-		}
-		return 0;
+		return jdbcTemplateWrite.update(updateSql, list.toArray());
 	}
 	/**
@@ -670,13 +605,8 @@ public class CustomJdbcTemplate&lt;T, ID extends Serializable&gt; {
 		List<Object> list = new ArrayList<Object>();
 		this.appendSql(sql, pql, list, updateObj);
-		try {
-			String updateSql = sql.toString().substring(0, sql.length()-1) + " WHERE "+sqlCondition;
-			return jdbcTemplateWrite.update(updateSql, list.toArray());
-		} catch (Exception e) {
-			UtilsLog.errorForException(e, this.getClass());
-		}
-		return 0;
+		String updateSql = sql.toString().substring(0, sql.length()-1) + " WHERE "+sqlCondition;
+		return jdbcTemplateWrite.update(updateSql, list.toArray());
 	}
 	public Map<String, Object> getPageData(String coreSql, String orderByPartSql, Integer page, Integer pageSize){
@@ -688,16 +618,9 @@ public class CustomJdbcTemplate&lt;T, ID extends Serializable&gt; {
 		//执行查询
 		List<Map<String, Object>> queryData = new ArrayList<Map<String, Object>>();
-		Map<String, Object> countData = new HashMap<String, Object>();
-		try{
-			queryData = this.jdbcTemplateRead.queryForList(querySql);
-			countData = this.jdbcTemplateRead.queryForMap(countSql);
-		}catch(Exception e){
-			countData.put("rows", "0");
-			
-			UtilsLog.errorForException(e, this.getClass());
-		}
-		
+		Map<String, Object> countData = new HashMap<String, Object>();	
+		queryData = this.jdbcTemplateRead.queryForList(querySql);
+		countData = this.jdbcTemplateRead.queryForMap(countSql);		
 		return UtilsSql.createPage(page, Integer.valueOf(countData.get("rows").toString()), queryData);
 	}
 }