基于jsp+servlet+javabean 程序集分页

package com.dao; import com.bean.TakeOrganize; import java.sql.*; import java.util.ArrayList; import java.util.List; public class TakeOrganizeDao extends DBConnection { /** * 添加 insert() * @param objTakeOrg com.bean.TakeOrganize */ public void insert(TakeOrganize objTakeOrg) throws Exception{ Connection con = null; PreparedStatement ps = null; String sql ="insert into T_TakeOrganize_BASE values(?,?,?,?,?,?,?,?,?,?,?)"; con = DBConnection.getcon(); //获得连接 ps = con.prepareStatement(sql); //设置参数 ps.setString(1, objTakeOrg.getAP_Num()); ps.setInt(2, objTakeOrg.getOT_Num()); ps.setInt(3, objTakeOrg.getTA_ParentNum()); ps.setString(4, objTakeOrg.getTA_Name()); ps.setString(5, objTakeOrg.getTA_Fax()); ps.setString(6, objTakeOrg.getTA_Address()); ps.setString(7, objTakeOrg.getTA_Linkman()); ps.setString(8, objTakeOrg.getTA_Phone()); ps.setString(9, objTakeOrg.getTA_Post()); ps.setString(10, objTakeOrg.getTA_Email()); ps.setInt(11, objTakeOrg.getTA_Status()); ps.executeUpdate(); //执行添加方法 this.closeAll(null,ps,con);//关闭连接 } /** * 按单位类型或单位状态 查询 * @param objTakeOrg com.bean.TakeOrganize * return List<TakeOrganize> */ public List select(TakeOrganize objTakeOrgC) throws Exception{ Connection con = null; PreparedStatement ps = null; ResultSet rs = null; List list = new ArrayList(); String sql = "select * from T_TakeOrganize_BASE where 1=1 "; con = DBConnection.getcon(); //获得连接 if(objTakeOrgC!=null){ // 按单位类型 查询 if(objTakeOrgC.getOT_Num()!=-1){ sql+=" and OT_Num ="+objTakeOrgC.getOT_Num()+" "; } // 按单位状态 查询 if(objTakeOrgC.getTA_Status()!=-1){ sql+=" and TA_Status ="+objTakeOrgC.getTA_Status(); } } ps = con.prepareStatement(sql); rs = ps.executeQuery();//执行查询方法 while (rs.next()) { TakeOrganize objTakeOrg = new TakeOrganize(); // 实例化对象 objTakeOrg objTakeOrg.setTA_Num(rs.getInt(1)); objTakeOrg.setAP_Num(rs.getString(2)); objTakeOrg.setOT_Num(rs.getInt(3)); objTakeOrg.setTA_ParentNum(rs.getInt(4)); objTakeOrg.setTA_Name(rs.getString(5)); objTakeOrg.setTA_Fax(rs.getString(6)); objTakeOrg.setTA_Address(rs.getString(7)); objTakeOrg.setTA_Linkman(rs.getString(8)); objTakeOrg.setTA_Phone(rs.getString(9)); objTakeOrg.setTA_Post(rs.getString(10)); objTakeOrg.setTA_Email(rs.getString(11)); objTakeOrg.setTA_Status(rs.getInt(12)); list.add(objTakeOrg); } this.closeAll(rs,ps,con);//关闭连接 return list; } /** * 按单位编号查询 查询 * @param objTakeOrg com.bean.TakeOrganize * return List<TakeOrganize> */ public TakeOrganize selectOne(int TA_Num) throws Exception{ Connection con = null; PreparedStatement ps = null; ResultSet rs = null; List list = new ArrayList(); String sql = "select * from T_TakeOrganize_BASE_view where TA_Num="+TA_Num; con = DBConnection.getcon(); //获得连接 ps = con.prepareStatement(sql); rs = ps.executeQuery();//执行查询方法 TakeOrganize objTakeOrg = null; while (rs.next()) { objTakeOrg = new TakeOrganize(); // 实例化对象 objTakeOrg objTakeOrg.setTA_Num(rs.getInt(1)); objTakeOrg.setAP_Num(rs.getString(2)); objTakeOrg.setOT_Num(rs.getInt(3)); objTakeOrg.setTA_ParentNum(rs.getInt(4)); objTakeOrg.setTA_Name(rs.getString(5)); objTakeOrg.setTA_Fax(rs.getString(6)); objTakeOrg.setTA_Address(rs.getString(7)); objTakeOrg.setTA_Linkman(rs.getString(8)); objTakeOrg.setTA_Phone(rs.getString(9)); objTakeOrg.setTA_Post(rs.getString(10)); objTakeOrg.setTA_Email(rs.getString(11)); objTakeOrg.setTA_Status(rs.getInt(12)); } this.closeAll(rs,ps,con);//关闭连接 return objTakeOrg; } /** * 修改 * @param TA_Num 单位编号 * @return * @throws Exception */ public int update(int TA_Num,int TA_Status) throws Exception{ int i=-1; Connection con = null; PreparedStatement ps = null; String sql = "update T_TakeOrganize_BASE set TA_Status =? where TA_Num =? "; con = DBConnection.getcon();//获得连接 ps = con.prepareStatement(sql); //设置参数 ps.setInt(1, TA_Status); ps.setInt(2, TA_Num); i = ps.executeUpdate(); //执行修改方法 this.closeAll(null,ps,con);//关闭连接 return i; } /** * 删除 * @param objTakeOrg * @return * @throws Exception */ public int delete(int TA_Num) throws Exception{ int i=-1; Connection con = null; PreparedStatement ps = null; String sql = "delete T_TakeOrganize_BASE where TA_Num=? "; con = DBConnection.getcon();//获得连接 ps = con.prepareStatement(sql); //设置参数 ps.setInt(1, TA_Num); i = ps.executeUpdate(); //执行删除方法 this.closeAll(null,ps,con);//关闭连接 return i; } // public static void main(String []args){ // TakeOrganizeDao takeOrgDao = new TakeOrganizeDao(); // // try { // takeOrgDao.update(8,2); // } catch (Exception e) { // e.printStackTrace(); // } // // } // }