IT类课程习题-FinancingProduct-master.zip

package com.Finacing.service; import com.Finacing.dao.BaseDao; import com.Finacing.dao.FinancingproductDao; import com.Finacing.entity.Financingproduct; import java.lang.reflect.Field; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; public class FinancingproductService extends BaseDao implements FinancingproductDao { @Override public List<Financingproduct> getAll() { String sql = "select * from financingproduct order by salestarting"; List<Financingproduct> pros = new ArrayList<>(); ResultSet rs = super.executeQuery(sql); try { while (rs.next()){ Financingproduct pro = new Financingproduct(); Field[] fs = pro.getClass().getDeclaredFields(); for (int i = 0; i < fs.length; i++) { fs[i].setAccessible(true); fs[i].set(pro,rs.getObject(i+1)); } pros.add(pro); } } catch (SQLException e) { e.printStackTrace(); } catch (IllegalAccessException e) { e.printStackTrace(); } finally { try { super.closeConn(rs,rs.getStatement(),rs.getStatement().getConnection()); } catch (SQLException e) { e.printStackTrace(); } } return pros; } public List<Financingproduct> search(String id,int risk) { String sql = "select * from financingproduct where 1=1 "; List<Object> objs = new ArrayList<>(); if (id!=null&&id.length()!=0){ sql+=" and id like CONCAT('%',?,'%') "; objs.add(id); } if (risk>0){ sql+= " and risk = ? "; objs.add(risk); } ResultSet rs = null; sql+= " order by salestarting"; if (!objs.isEmpty()){ rs = super.executeQuery(sql,objs.toArray()); }else{ rs = super.executeQuery(sql); } List<Financingproduct> pros = new ArrayList<>(); System.out.println(sql); try { while (rs.next()){ Financingproduct pro = new Financingproduct(); Field[] fs = pro.getClass().getDeclaredFields(); for (int i = 0; i < fs.length; i++) { fs[i].setAccessible(true); fs[i].set(pro,rs.getObject(i+1)); } pros.add(pro); } } catch (SQLException e) { e.printStackTrace(); } catch (IllegalAccessException e) { e.printStackTrace(); } finally { try { super.closeConn(rs,rs.getStatement(),rs.getStatement().getConnection()); } catch (SQLException e) { e.printStackTrace(); } } return pros; } @Override public Financingproduct getProduct(String id) { String sql = "select * from financingproduct where id=?"; Financingproduct pro = null; ResultSet rs = super.executeQuery(sql,id); try { while (rs.next()){ pro = new Financingproduct(); Field[] fs = pro.getClass().getDeclaredFields(); for (int i = 0; i < fs.length; i++) { fs[i].setAccessible(true); fs[i].set(pro,rs.getObject(i+1)); } } } catch (SQLException e) { e.printStackTrace(); } catch (IllegalAccessException e) { e.printStackTrace(); } finally { try { super.closeConn(rs,rs.getStatement(),rs.getStatement().getConnection()); } catch (SQLException e) { e.printStackTrace(); } } return pro; } @Override public boolean addProduct(Financingproduct financingproduct) { String sql = "insert financingproduct values("; Field[] fs = financingproduct.getClass().getDeclaredFields(); Object[] os = new Object[fs.length] ; for (int i = 0; i < fs.length; i++) { if (i==fs.length-1){ sql+="?)"; }else{ sql+="?,"; } fs[i].setAccessible(true); try { os[i] = fs[i].get(financingproduct); } catch (IllegalAccessException e) { e.printStackTrace(); } } return super.executeUpdate(sql,os); } }