S2理财产品信息管理系统（参考答案）

package com.thunder.dao.impl; import com.thunder.dao.BaseDao; import com.thunder.dao.FinancingProductDao; import com.thunder.entity.FinancingProduct; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; /** * @author Think */ public class FinancingDaoImpl extends BaseDao implements FinancingProductDao { @Override public List<FinancingProduct> getAll(String id, Integer risk) throws SQLException { connection=super.getConnection(); String sql="select * from financingproduct"; StringBuffer sb=new StringBuffer(sql); List<FinancingProduct> list=new ArrayList<FinancingProduct>(); if ("".equals(id)&&risk!=null) { sb.append(" where risk=? and id like ? "); preparedStatement = connection.prepareStatement(sb.toString()); preparedStatement.setInt(1, risk); preparedStatement.setString(2, id+"%"); resultSet = preparedStatement.executeQuery(); selectGetAll(list); }else if ("".equals(id)||id!=null){ //按照品种查询 sb.append(" where id like ? "); preparedStatement=connection.prepareStatement(sb.toString()); preparedStatement.setString(1,id+"%"); resultSet=preparedStatement.executeQuery(); selectGetAll(list); }else if (risk!=null){ sb.append(" where risk=? "); preparedStatement=connection.prepareStatement(sb.toString()); preparedStatement.setInt(1,risk); resultSet=preparedStatement.executeQuery(); selectGetAll(list); }else{ //不是按照品种查询 String sql1="select * from financingproduct order by saleStarting desc "; preparedStatement=connection.prepareStatement(sql1); resultSet=preparedStatement.executeQuery(); selectGetAll(list); } //关闭文档流 super.closeAll(connection, preparedStatement, resultSet); return list; } private void selectGetAll(List<FinancingProduct> list) throws SQLException { FinancingProduct financingProduct; while (resultSet.next()) { financingProduct=new FinancingProduct(); financingProduct.setId(resultSet.getString("id")); financingProduct.setRisk(resultSet.getInt("risk")); financingProduct.setIncome(resultSet.getString("income")); financingProduct.setSaleStarting(resultSet.getDate("saleStarting")); financingProduct.setSaleEnd(resultSet.getDate("saleEnd")); financingProduct.setEnd(resultSet.getDate("end")); list.add(financingProduct); } } @Override public FinancingProduct getOne(String id) throws SQLException { connection=super.getConnection(); String sql="select * from financingproduct where id=?"; preparedStatement=connection.prepareStatement(sql); preparedStatement.setString(1,id); resultSet=preparedStatement.executeQuery(); FinancingProduct financingProduct=null; while(resultSet.next()){ financingProduct=new FinancingProduct(); financingProduct.setId(resultSet.getString("id")); } return financingProduct; } @Override public Integer add(FinancingProduct financingProduct) { String sql="insert into financingproduct (id,risk,income,saleStarting,saleEnd,end)value(?,?,?,?,?,?)"; int result=this.executeUpdate(sql,financingProduct.getId(),financingProduct.getRisk(), financingProduct.getIncome(), financingProduct.getSaleStarting(), financingProduct.getSaleEnd(),financingProduct.getEnd()); return result; } }