可二次开发一个非常简单的mysqljava项目的增删查项目.zip

package com.sam.bean; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.Statement; import java.util.ArrayList; import java.util.List; public class Plan { private int planid;//编号 private String applydate;//创建时间 private int status;//话费字段 private String Saileail;//年龄字段 public Plan(int planid, String applydate, int status, String saileail) { super(); this.planid = planid; this.applydate = applydate; this.status = status; Saileail = saileail; } public Plan() { super(); } /** * 查询的方法 * @param conn * @return * @throws Exception */ public static List<Plan> find(Connection conn,String id,String saileail1,String saileail2,String status1,String status2)throws Exception { List<Plan> listmeal=new ArrayList<Plan>();//创建一个新的集合 String strSql="select * from plan where 1=1 "; if(id.length()>0 && !id.equals("0")){ strSql=strSql+"and PlanID='"+id+"' "; } if(saileail1.length()>0){ strSql=strSql+"and Saileail>='"+saileail1+"' "; } if(saileail2.length()>0){ strSql=strSql+"and Saileail<='"+saileail2+"' "; } if(status1.length()>0){ strSql=strSql+"and status>='"+status1+"' "; } if(status2.length()>0){ strSql=strSql+"and status<='"+status2+"' "; } Statement stmt =DB.createStmt(conn); ResultSet rs = null; rs = DB.executeQuery(stmt, strSql);//执行这个sql语句;增删改用executeUpdate，查询用executeQuery try { while(rs.next()){//遍历 Plan ns=new Plan(); ns.setPlanid(Integer.parseInt(rs.getString("planid"))); ns.setApplydate(rs.getString("applydate")); ns.setStatus(Integer.parseInt(rs.getString("status"))); ns.setSaileail(rs.getString("saileail")); listmeal.add(ns);//将这个对象添加到集合中 } } finally{ DB.close(rs); DB.close(stmt); } return listmeal;//返回这个集合 } /** * 修改的方法 * @param conn * @param m * @throws Exception */ public static void update(Connection conn,Plan n)throws Exception { PreparedStatement stmt = null; String strSql = "update plan set status='"+n.getStatus()+"',Saileail='"+n.getSaileail()+"',applydate='"+n.getApplydate()+"' where PlanID='"+n.getPlanid()+"'";//将传来的id丢进去 stmt = conn.prepareStatement(strSql); try { stmt.executeUpdate();//执行这个sql语句;增删改用executeUpdate，查询用executeQuery } catch (Exception e) {} } /** * 删除的方法 * @param conn * @param m * @throws Exception */ public static void del(Connection conn,int id)throws Exception { PreparedStatement stmt = null; String strSql = "delete from plan where PlanID = '"+id+"'";//将传来的id丢进去 stmt = conn.prepareStatement(strSql); try { stmt.executeUpdate();//执行这个sql语句;增删改用executeUpdate，查询用executeQuery } catch (Exception e) {} } /** * 添加的方法 * @param conn * @param m * @throws Exception */ public static void add(Connection conn,Plan m)throws Exception { PreparedStatement stmt = null; String strSql = "insert into plan(status,Saileail,applydate) values('"+m.getStatus()+"','"+m.getSaileail()+"','"+m.getApplydate()+"')";//取对象里面的值丢进去 stmt = conn.prepareStatement(strSql); try { stmt.executeUpdate();//执行添加语句，和查询的不一样；增删改用executeUpdate，查询用executeQuery } catch (Exception e) {} } public int getPlanid() { return planid; } public void setPlanid(int planid) { this.planid = planid; } public String getApplydate() { return applydate; } public void setApplydate(String applydate) { this.applydate = applydate; } public int getStatus() { return status; } public void setStatus(int status) { this.status = status; } public String getSaileail() { return Saileail; } public void setSaileail(String saileail) { Saileail = saileail; } }