person_app.zip

package lujy.dao.impl; import java.util.Collection; import java.util.Set; import java.util.HashSet; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import lujy.util.ConnectionFactory; import lujy.util.DBUtil; import lujy.entity.Person; import lujy.dao.PersonDao; public class PersonDaoImpl implements PersonDao { public void add(Person p) throws Exception { Connection con = null; PreparedStatement ps = null; ResultSet rs = null; StringBuffer sql = new StringBuffer(); //sql.append("insert into person(id, name, sex, age, phone, address)"); //sql.append("values(?, ?, ?, ?, ?, ?)"); sql.append("insert into person(name, sex, age, phone, address)"); sql.append("values(?, ?, ?, ?, ?)"); try { con = ConnectionFactory.getConnection(); /* 用于Oracle DB生成Person的ID ps = con.prepareStatement("select person_seq.nextval from dual"); rs = ps.executeQuery(); rs.next(); long id = rs.getLong(1); */ // p.setId(id); /*DBUtil.close(rs, ps, null); */ ps = con.prepareStatement(sql.toString()); int index = 1; //ps.setLong(index++, p.getId()); //这里利用用MySQL的auto_increment自动递增保存ID值。 ps.setString(index++, p.getName()); ps.setInt(index++, p.getSex()); ps.setInt(index++, p.getAge()); ps.setString(index++, p.getPhone()); ps.setString(index++, p.getAddress()); ps.executeUpdate(); }catch(Exception e) { e.printStackTrace(); throw e; }finally { DBUtil.close(null, ps, con); } } public void modify(Person p) throws Exception { Connection con = null; PreparedStatement ps = null; StringBuffer sql = new StringBuffer(); sql.append("update person set name = ?, sex = ?, age = ?, phone = ?, address = ? ") ; sql.append("where id = ?"); try { con = ConnectionFactory.getConnection(); ps = con.prepareStatement(sql.toString()); int index = 1; ps.setString(index++, p.getName()); ps.setInt(index++, p.getSex()); ps.setInt(index++, p.getAge()); ps.setString(index++, p.getPhone()); ps.setString(index++, p.getAddress()); ps.setLong(index++, p.getId()); ps.executeUpdate(); }catch(Exception e) { e.printStackTrace(); throw e; }finally { DBUtil.close(null, ps, con); } } public void remove(long personId) throws Exception { Connection con = null; PreparedStatement ps = null; String sql = "delete from person where id = ?"; try { con = ConnectionFactory.getConnection(); ps = con.prepareStatement(sql); ps.setLong(1, personId); ps.executeUpdate(); }catch(Exception e) { e.printStackTrace(); throw e; }finally { DBUtil.close(null, ps, con); } } public Person findPersonById(long personId) throws Exception { Person p = null; Connection con = null; PreparedStatement ps = null; ResultSet rs = null; String sql = "select * from person where id = ? "; try { con = ConnectionFactory.getConnection(); ps = con.prepareStatement(sql); ps.setLong(1, personId); rs = ps.executeQuery(); if(rs.next()) { p = new Person(); p.setId(rs.getLong("id")); p.setName(rs.getString("name")); p.setSex(rs.getInt("sex")); p.setAge(rs.getInt("age")); p.setPhone(rs.getString("phone")); p.setAddress(rs.getString("address")); } }catch(Exception e) { e.printStackTrace(); throw e; }finally { DBUtil.close(rs, ps, con); } return p; } public Collection findAllPerson() throws Exception { Set persons = new HashSet(); Connection con = null; PreparedStatement ps = null; ResultSet rs = null; String sql = "select * from person"; try { con = ConnectionFactory.getConnection(); ps = con.prepareStatement(sql); System.out.println(con) ; rs = ps.executeQuery(); while(rs.next()) { Person p = new Person(); p.setId(rs.getLong("id")); p.setName(rs.getString("name")); p.setSex(rs.getInt("sex")); p.setAge(rs.getInt("age")); p.setPhone(rs.getString("phone")); p.setAddress(rs.getString("address")); persons.add(p); } }catch(Exception e) { e.printStackTrace(); throw e; }finally { DBUtil.close(rs, ps, con); } return persons; } }