CREATE TABLE `employee` (

`id` int(11) NOT NULL auto_increment,

`name` varchar(50) default NULL,

`age` int(11) default NULL,

`position` varchar(50) default NULL,

PRIMARY KEY  (`id`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

/**

* ClassName: Employee.java

* Author: qiujy

* CreateTime: 2008-8-20

* EMAIL: qjyong@gmail.com

* Copyright 2008 ++YONG All rights reserved.

*/

package org.qiujy.domain;

/** 员工实体类 */

public class Employee {

private int id;

private String name;

private int age;

private String position;

public Employee() {

}

public Employee(int age, String name, String position) {

super();

this.age = age;

this.name = name;

this.position = position;

}

//以下省略所有属性的getter和setter

……

@Override

public String toString() {

return "[id=" + this.id + ",name=" + this.name + ",age=" + age

+ ",position=" + this.position + "]";

}

}

/**

* ClassName: EmployeeDao.java

* Author: qiujy

* CreateTime: 2008-8-20

* EMAIL: qjyong@gmail.com

* Copyright 2008 ++YONG All rights reserved.

*/

package org.qiujy.dao;

import java.sql.Connection;

import java.sql.SQLException;

import java.util.List;

import org.apache.commons.dbutils.DbUtils;

import org.apache.commons.dbutils.QueryRunner;

import org.apache.commons.dbutils.handlers.BeanHandler;

import org.apache.commons.dbutils.handlers.BeanListHandler;

import org.qiujy.common.MyDbUtils;

import org.qiujy.domain.Employee;

/** 员工dao */

public class EmployeeDao {

/**

* 新增一个员工实例

* @param empl

* @param conn

* @throws DAOException

*/

public void insertEmployee(Connection conn, Employee empl) throws DAOException {

String sql = "INSERT INTO employee(name,age,position) VALUES(?,?,?)";

try {

QueryRunner qr = new QueryRunner();

Object[] params = {empl.getName(), empl.getAge(),empl.getPosition()};

qr.update(conn, sql, params);

} catch (SQLException e) {

throw new DAOException(e);

}

}

/**

* 根据ID删除一个员工实例

* @param conn

* @param id

* @throws DAOException

*/

public void deleteEmloyeeById(Connection conn, int id) throws DAOException {

String sql = "DELETE FROM employee WHERE id=?";

try {

QueryRunner qr = new QueryRunner();

qr.update(conn, sql, id);

} catch (SQLException e) {

throw new DAOException(e);

}

}

/**

* 更新员工的信息

* @param conn

* @param empl

* @throws DAOException

*/

public void updateEmployee(Connection conn, Employee empl) throws DAOException {

String sql = "UPDATE employee SET name=?,age=?,position=? WHERE id=?";

try {

                            QueryRunner qr = new QueryRunner();

                            Object[] params = { empl.getName(), empl.getAge(),

                                               empl.getPosition(), empl.getId() };

                            qr.update(conn, sql, params);

} catch (SQLException e) {

throw new DAOException(e);

}

}

/**

* 根据ID获取该员工实例

* @param conn

* @param id

* @return

* @throws DAOException

*/

public Employee getEmployeeById(Connection conn, int id) throws DAOException {

Employee empl = null;

String sql = "SELECT id,name,age,position FROM employee WHERE id=?";

try {

QueryRunner qr = new QueryRunner();

                            empl = (Employee) qr.query(conn, sql, id,

                                                                 new BeanHandler(Employee.class));

} catch (SQLException e) {

throw new DAOException(e);

}

return empl;

}

/**

* 获取所有的员工列表

* @param conn

* @return　员工实例列表

* @throws DAOException

*/

@SuppressWarnings("unchecked")

public List<Employee> getEmployeeList(Connection conn) throws DAOException {

List<Employee> list = null;

String sql = "SELECT id,name,age,position FROM employee";

try {

QueryRunner qr = new QueryRunner();

         list = (List<Employee>) qr.query(conn, sql,

                                                                 new BeanListHandler(Employee.class));

} catch (SQLException e) {

throw new DAOException(e);

}

return list;

}

public static void main(String[] args) throws SQLException {

Connection conn = MyDbUtils.getConnection();

List<Employee> list = new EmployeeDao().getEmployeeList(conn);

for(Employee empl : list){

System.out.println(empl);

}

DbUtils.close(conn);

}

}