package org.vo; 
import java.util.*; 
public class Emp{ 
  private int empno; 
  private String ename; 
  private String job; 
  private Date hireDate; 
  private float sal; 
  public Emp(){ 
  } 
  public int getEmpno(){ 
    return empno; 
  } 
  public void setEmpno(int empno){ 
    this.empno = empno; 
  } 
  public String getEname(){ 
    return ename; 
  } 
  public void setEname(String ename){ 
    this.ename = ename; 
  } 
  public Date getHireDate(){ 
    return hireDate; 
  } 
  public void setHireDate(Date hireDate){ 
    this.hireDate = hireDate; 
  } 
  public float getSal(){ 
    return sal; 
  } 
  public void setSal(float sal){ 
    this.sal = sal; 
  } 
  public String getJob(){ 
    return job; 
  } 
  public void setJob(String job){ 
    this.job = job; 
  } 
} 

package org.dbc; 
import java.sql.*; 
public class DatabaseConnection{ 
  private Connection con = null; 
  private static final String DRIVER = "com.mysql.jdbc.Driver"; 
  private static final String USER = "root"; 
  private static final String URL = "jdbc:mysql://localhost:3306/mldn"; 
  private static final String PASS = "12345"; 
  public DatabaseConnection()throws Exception{ 
    Class.forName(DRIVER); 
    con = DriverManager.getConnection(URL,USER,PASS); 
  } 
  public Connection getConnection()throws Exception{ 
    return con; 
  } 
  public void close()throws Exception{ 
    if(con!=null){ 
      con.close(); 
    } 
  } 
} 

package org.dao; 
import java.util.List; 
import org.vo.*; 
public interface IEmpDAO{ 
  public boolean doCreate(Emp emp)throws Exception; 
  public List<Emp> findAll()throws Exception; 
  public Emp findById(int empno)throws Exception; 
} 

package org.dao.impl; 
import org.dao.*; 
import java.sql.*; 
import org.vo.*; 
import java.util.*; 
public class EmpDAOImpl implements IEmpDAO{ 
  private Connection con; 
  private PreparedStatement stat = null; 
  public EmpDAOImpl(Connection con){ 
    this.con = con; 
  } 
  public boolean doCreate(Emp emp)throws Exception{ 
    String sql = "INSERT INTO emp(empno,ename,job,hiredate,sal) VALUES(?,?,?,?,?)"; 
    stat = con.prepareStatement(sql); 
    stat.setInt(1,emp.getEmpno()); 
    stat.setString(2,emp.getEname()); 
    stat.setString(3,emp.getJob()); 
    stat.setDate(4,new java.sql.Date(emp.getHireDate().getTime())); 
    stat.setFloat(5,emp.getSal()); 
    int update = stat.executeUpdate(); 
    if(update>0){ 
      return true; 
    } 
    else{ 
      return false; 
    } 
  } 
  public List<Emp> findAll()throws Exception{ 
    String sql = "SELECT empno,ename,job,hiredate,sal FROM emp"; 
    stat = con.prepareStatement(sql); 
    ResultSet rs = stat.executeQuery(); 
    Emp emp = null; 
    List<Emp> list = new ArrayList<Emp>(); 
    while(rs.next()){ 
      int empno = rs.getInt(1); 
      String ename = rs.getString(2); 
      String job = rs.getString(3); 
      float sal = rs.getFloat(5); 
      emp = new Emp(); 
      emp.setEmpno(empno); 
      emp.setEname(ename); 
      emp.setJob(job); 
      emp.setHireDate(rs.getDate(4)); 
      emp.setSal(sal); 
      list.add(emp); 
    } 
    return list; 
  } 
  public Emp findById(int empno)throws Exception{ 
    String sql = "SELECT empno,ename,job,hiredate,sal FROM emp WHERE empno=?"; 
    stat = con.prepareStatement(sql); 
    stat.setInt(1,empno); 
    ResultSet rs = stat.executeQuery(); 
    Emp emp = null; 
    if(rs.next()){ 
      String ename = rs.getString(2); 
      String job = rs.getString(3); 
      float sal = rs.getFloat(5); 
      emp = new Emp(); 
      emp.setEmpno(empno); 
      emp.setEname(ename); 
      emp.setJob(job); 
      emp.setHireDate(rs.getDate(4)); 
      emp.setSal(sal); 
    } 
    return emp; 
  } 
} 

package org.dao.impl; 
import org.dao.*; 
import java.sql.*; 
import org.vo.*; 
import java.util.*; 
import org.dbc.*; 
public class EmpDAOProxy implements IEmpDAO{ 
  private DatabaseConnection dbc; 
  private IEmpDAO dao = null; 
  public EmpDAOProxy()throws Exception{ 
    dbc = new DatabaseConnection(); 
    dao = new EmpDAOImpl(dbc.getConnection()); 
  } 
  public boolean doCreate(Emp emp)throws Exception{ 
    boolean flag = false; 
    if(dao.findById(emp.getEmpno())==null){ 
      flag = dao.doCreate(emp); 
    } 
    dbc.close(); 
    return flag; 
  } 
  public List<Emp> findAll()throws Exception{ 
    List<Emp>list = dao.findAll(); 
    dbc.close(); 
    return list; 
  } 
  public Emp findById(int empno)throws Exception{ 
    Emp emp = dao.findById(empno); 
    dbc.close(); 
    return emp; 
  } 
} 

package org.dao.factory; 
import org.dao.*; 
import java.sql.*; 
import org.vo.*; 
import java.util.*; 
import org.dbc.*; 
import org.dao.impl.*; 
public class DAOFactory{ 
  public static IEmpDAO getInstance(){ 
    IEmpDAO dao = null; 
    try{ 
      dao = new EmpDAOProxy();   
    } 
    catch(Exception e){ 
      e.printStackTrace(); 
    } 
    return dao; 
  } 
} 

package org.dao.test; 
import org.dao.factory.*; 
import org.vo.*; 
import org.dao.*; 
public class TestDAO{ 
  public static void main(String args[])throws Exception{ 
    Emp emp = null; 
    for(int i=0;i<5;i++){ 
      emp = new Emp(); 
      emp.setEmpno(i); 
      emp.setEname("xiazdong-"+i); 
      emp.setJob("stu-"+i); 
      emp.setHireDate(new java.util.Date()); 
      emp.setSal(500*i); 
      DAOFactory.getInstance().doCreate(emp); 
    } 
  } 
} 

//对应
String sql = "INSERT INTO emp_table(ename,job,sal,hiredate) VALUES(?,?,?,?)"; 
    stat = (PreparedStatement) con.prepareStatement(sql); 
    stat.setString(1,emp.getEname()); 
    stat.setString(2,emp.getJob()); 
    stat.setFloat(3,emp.getSal());