package com.dao; import com.bean.Repair_addBean; import com.db.DBHelper; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.List; public class RepairDao { //获取列表 public List GetList(String strwhere, String strorder){ String sql="select * from repair "; if(!(isInvalid(strwhere))) { sql+=" where "+strwhere; } if(!(isInvalid(strorder))) { sql+=" order by "+strorder; } Statement stat = null; ResultSet rs = null; Connection conn = new DBHelper().getConn(); List list=new ArrayList(); try{ stat = conn.createStatement(); rs = stat.executeQuery(sql); while(rs.next()){ Repair_addBean cnbean=new Repair_addBean(); // cnbean.setRepair_time((rs.getInt("Repair_time"))); cnbean.setRepair_id(rs.getInt("repair_id")); cnbean.setRepair_info(rs.getString("repair_info")); cnbean.setRepair_address(rs.getString("repair_address")); //cnbean.setRepair_info(rs.getString("repair_info;")); // cnbean.setRepair_cost(rs.getString("repair_cost")); cnbean.setRepair_tel(rs.getString("repair_tel")); cnbean.setRepair_status(rs.getString("repair_status")); list.add(cnbean); } } catch (SQLException e) { e.printStackTrace(); } finally { try { if (conn != null) conn.close(); if (stat != null) stat.close(); if (rs != null) rs.close(); } catch (SQLException e) { e.printStackTrace(); } } return list; } //获取指定ID的实体Bean public Repair_addBean GetBean(int id){ String sql="select * from repair where repair_id="+id; Statement stat = null; ResultSet rs = null; Connection conn = new DBHelper().getConn(); Repair_addBean cnbean=new Repair_addBean(); try{ stat = conn.createStatement(); rs = stat.executeQuery(sql); while(rs.next()){ cnbean.setRepair_id(rs.getInt("repair_id")); // cnbean.setRepair_info(rs.getString("repair_info")); // cnbean.setRepair_address(rs.getString("repair_address")); // cnbean.setRepair_tel(rs.getString("repair_tel")); cnbean.setRepair_status(rs.getString("repair_status")); // cnbean.setTeacher_Tel(rs.getString("Teacher_Tel")); } } catch (SQLException e) { e.printStackTrace(); } finally { try { if (conn != null) conn.close(); if (stat != null) stat.close(); if (rs != null) rs.close(); } catch (SQLException e) { e.printStackTrace(); } } return cnbean; } //添加 public void Add(Repair_addBean cnbean){ Statement stat = null; ResultSet rs = null; String sql="insert into repair ("; sql+="repair_id,repair_info,repair_address,repair_tel"; sql+=") values("; sql+="'"+cnbean.getRepair_id()+"','"+cnbean.getRepair_info()+"','"+cnbean.getRepair_address()+"','"+cnbean.getRepair_tel()+"'"; sql+=")"; Connection conn = new DBHelper().getConn(); try{ stat = conn.createStatement(); stat.executeUpdate(sql); } catch (SQLException e) { e.printStackTrace(); } finally { try { if (conn != null) conn.close(); if (stat != null) stat.close(); if (rs != null) rs.close(); } catch (SQLException e) { e.printStackTrace(); } } } //修改 public void Update(Repair_addBean cnbean){ String sql="update repair set "; // sql+="repair_id='"+cnbean.getRepair_id()+"',"; // sql+="repair_info='"+cnbean.getRepair_info()+"',"; //sql+="repair_address='"+cnbean.getRepair_address()+"',"; // sql+="repair_tel='"+cnbean.getRepair_tel()+"',"; sql+="repair_status='"+cnbean.getRepair_status()+"'"; sql+=" where repair_id='"+cnbean.getRepair_id()+"'"; Statement stat = null; ResultSet rs = null; Connection conn = new DBHelper().getConn(); try{ stat = conn.createStatement(); stat.executeUpdate(sql); System.out.println(sql); System.out.println("修改状态成功"); } catch (SQLException e) { e.printStackTrace(); } finally { try { if (conn != null) conn.close(); if (stat != null) stat.close(); if (rs != null) rs.close(); } catch (SQLException e) { e.printStackTrace(); } } } //删除 public void Delete(String strwhere){ String sql="delete repair where "; sql+=strwhere; Statement stat = null; ResultSet rs = null; Connection conn = new DBHelper().getConn(); try{ stat = conn.createStatement(); stat.executeUpdate(sql); } catch (SQLException e) { e.printStackTrace(); } finally { try { if (conn != null) conn.close(); if (stat != null) stat.close(); if (rs != null) rs.close(); } catch (SQLException e) { e.printStackTrace(); } } } //判断是否空值 private boolean isInvalid(String value) { return (value == null || value.length() == 0); } //测试 public static void main(String[] args) { System.out.println(""); } }