pyexr2f4a/dao文件/RepairDao.java

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<Repair_addBean> 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<Repair_addBean> list=new ArrayList<Repair_addBean>();
       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("");
    }




    }