增查改刪
阿新 • • 發佈:2019-01-10
package com.emms.comp.BDS; import java.util.ArrayList; import java.util.List; import com.emms.comp.entity.bds.T_T_BDS_DATAMININGSHOWPOINT; import com.emms.util.StringUtils; import com.haiyisoft.common.exception.ServiceExceptionUtil; import com.haiyisoft.persist.exception.DBException; import com.haiyisoft.persist.jdbc.DBTool; public class DATAMININGSHOWPOINTCom { public List<T_T_BDS_DATAMININGSHOWPOINT> query(T_T_BDS_DATAMININGSHOWPOINT t) { List<Object> params = new ArrayList<Object>(); DBTool tool = new DBTool(); List<T_T_BDS_DATAMININGSHOWPOINT> data = null; try { StringBuffer sql = new StringBuffer( "SELECT * FROM T_BDS_DATAMININGSHOWPOINT WHERE 1 = 1"); if (StringUtils.isNotEmpty(t.getDataminingpointflowid())) { sql.append(" AND DATAMININGPOINTFLOWID = ?"); params.add(t.getDataminingpointflowid()); } if (StringUtils.isNotEmpty(t.getDataminingpointid())) { sql.append(" AND DATAMININGPOINTID = ?"); params.add(t.getDataminingpointid()); } if (StringUtils.isNotEmpty(t.getDataminingpointtype())) { sql.append(" AND DATAMININGPOINTTYPE = ?"); params.add(t.getDataminingpointtype()); } if (StringUtils.isNotEmpty(t.getDataminingpointname())) { sql.append(" AND DATAMININGPOINTNAME = ?"); params.add(t.getDataminingpointname()); } data = tool.executeQuery(sql.toString(), params, T_T_BDS_DATAMININGSHOWPOINT.class); } catch (Exception e) { throw ServiceExceptionUtil.generateSOAServiceException(e, "查詢選單異常"); } return data; } public void add(List<T_T_BDS_DATAMININGSHOWPOINT> insertList) { DBTool dbtool = new DBTool(); StringBuffer sql = new StringBuffer( "SELECT * FROM T_BDS_DATAMININGSHOWPOINT WHERE 1 = 1"); for (T_T_BDS_DATAMININGSHOWPOINT t : insertList) { StringBuffer newsql = sql; List<Object> params = new ArrayList<Object>(); if (StringUtils.isNotEmpty(t.getDataminingpointid())) { newsql.append(" AND DATAMININGPOINTID = ?"); params.add(t.getDataminingpointid()); } List<T_T_BDS_DATAMININGSHOWPOINT> data = dbtool.executeQuery( newsql.toString(), params, T_T_BDS_DATAMININGSHOWPOINT.class); if (data == null || data.size() == 0) { List<T_T_BDS_DATAMININGSHOWPOINT> insertList2 = new ArrayList<T_T_BDS_DATAMININGSHOWPOINT>(); insertList2.add(t); try { dbtool.batchInsertEntity(insertList2); } catch (Exception e) { throw ServiceExceptionUtil.generateSOAServiceException(e, "插入資料異常"); } } else { List<T_T_BDS_DATAMININGSHOWPOINT> insertList2 = new ArrayList<T_T_BDS_DATAMININGSHOWPOINT>(); insertList2.add(t); try { dbtool.batchUpdateEntity(insertList2); } catch (Exception e) { throw ServiceExceptionUtil.generateSOAServiceException(e, "更新資料異常"); } } } } public void save(List<T_T_BDS_DATAMININGSHOWPOINT> insertList) { DBTool dbtool = new DBTool(); StringBuffer sql = new StringBuffer( "SELECT * FROM T_BDS_DATAMININGSHOWPOINT WHERE 1 = 1"); for (T_T_BDS_DATAMININGSHOWPOINT t : insertList) { StringBuffer newsql = sql; List<Object> params = new ArrayList<Object>(); if (StringUtils.isNotEmpty(t.getDataminingpointflowid())) { newsql.append(" AND DATAMININGPOINTFLOWID = ?"); params.add(t.getDataminingpointflowid()); } List<T_T_BDS_DATAMININGSHOWPOINT> data = dbtool.executeQuery( newsql.toString(), params, T_T_BDS_DATAMININGSHOWPOINT.class); if (data == null || data.size() == 0) { List<T_T_BDS_DATAMININGSHOWPOINT> insertList2 = new ArrayList<T_T_BDS_DATAMININGSHOWPOINT>(); insertList2.add(t); try { dbtool.batchInsertEntity(insertList2); } catch (Exception e) { throw ServiceExceptionUtil.generateSOAServiceException(e, "插入資料異常"); } } else { List<T_T_BDS_DATAMININGSHOWPOINT> insertList2 = new ArrayList<T_T_BDS_DATAMININGSHOWPOINT>(); insertList2.add(t); try { dbtool.batchUpdateEntity(insertList2); } catch (Exception e) { throw ServiceExceptionUtil.generateSOAServiceException(e, "更新資料異常"); } } } } public void delete(List<T_T_BDS_DATAMININGSHOWPOINT> deleteList) { DBTool tool = new DBTool(); try { tool.batchDeleteEntity(deleteList); } catch (DBException e) { throw ServiceExceptionUtil.generateSOAServiceException("服務資料刪除異常"); } } public void delete(List<T_DSJWJ_SFRW> deleteList) { DBTool tool = new DBTool(); try { // tool.batchDeleteEntity(deleteList); for (int i = 0; i < deleteList.size(); i++) { String slid = deleteList.get(i).getRwbh(); tool.executeUpdate("DELETE FROM DSJWJ_SFRW WHERE RWBH ='" + slid + "'", null); } } catch (DBException e) { throw ServiceExceptionUtil.generateSOAServiceException("服務資料刪除異常"); } } }