首页>代码>jsp+servlet+mysql员工管理系统源代码下载>/Emp/src/dao/jdbc/EmployeeDAOJdbcImpl.java
package dao.jdbc;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import util.DBConnection;
import dao.EmployeeDAO;
import entity.Employee;

public class EmployeeDAOJdbcImpl implements EmployeeDAO {

	public List<Employee> findALL() throws Exception {
		ArrayList<Employee> list = new ArrayList<Employee>();
		Connection conn = DBConnection.getConnection();
		PreparedStatement ps = conn.prepareStatement("select * from t_emp");
		ResultSet rs = ps.executeQuery();
		
		while(rs.next()) {
			Employee e = new Employee();
			e.setId(rs.getInt("id"));
			e.setName(rs.getString("name"));
			e.setAge(rs.getInt("age"));
			e.setSalary(rs.getDouble("salary"));
			list.add(e);
		}
		DBConnection.close(rs, ps, conn);
		return list;
	}
	
	public void insertEmp(Employee e) throws Exception {
		Connection conn = DBConnection.getConnection();
		PreparedStatement ps = conn.prepareStatement("insert into t_emp(name,age,salary) values(?,?,?)");
		ps.setString(1, e.getName());
		ps.setInt(2,e.getAge());
		ps.setDouble(3, e.getSalary());
		ps.executeUpdate();
		System.out.println("插入成功");
		DBConnection.close(ps, conn);
		
	}
	
	public void deleteEmpById(int id) throws Exception {
		Connection conn = DBConnection.getConnection();
		PreparedStatement ps = conn.prepareStatement("delete from t_emp where id=?");
		ps.setInt(1,id);
		ps.executeUpdate();
		
		DBConnection.close(ps, conn);
	}
	
	public void updateEmp(Employee e) throws Exception {
		Connection conn = DBConnection.getConnection();
		PreparedStatement ps = conn.prepareStatement("update t_emp set name=?,age=?,salary=? where id=?");
		ps.setString(1, e.getName());
		ps.setInt(2,e.getAge());
		ps.setDouble(3, e.getSalary());
		ps.setInt(4, e.getId());
		ps.executeUpdate();
		
		DBConnection.close(ps, conn);
	}
	
	public Employee findEmpById(int id) throws Exception {
		Employee e = null;
		Connection conn = DBConnection.getConnection();
		PreparedStatement ps = conn.prepareStatement("select * from t_emp where id=?");
		ps.setInt(1, id);
		ResultSet rs = ps.executeQuery();
		
		while(rs.next()) {
			e = new Employee();
			e.setId(rs.getInt("id"));
			e.setName(rs.getString("name"));
			e.setAge(rs.getInt("age"));
			e.setSalary(rs.getDouble("salary"));
		}
		DBConnection.close(rs, ps, conn);
		return e;
		
	}


	
}
最近下载更多
dgibvhjn LV24月18日
星星星星
陌路过客 LV24月16日
星星星星
帮帮小农 LV14月15日
星星
快快好 LV14月14日
星星
liyitong123 LV44月13日
月亮
lm666666666 LV14月13日
星星
2606131460 LV14月9日
星星
1468364881 LV34月8日
星星星星星星
飞猪奔跑记1 LV14月8日
星星
张氏一小生 LV24月7日
星星星星
最近浏览更多
凡先生 LV14昨天
月亮月亮月亮星星星星
nnnnnnnhau LV2昨天
星星星星
暂无贡献等级
louis888前天
暂无贡献等级
Mopp1234 LV2前天
星星星星
dgibvhjn LV24月18日
星星星星
13385512289l4月18日
暂无贡献等级
陌路过客 LV24月16日
星星星星
cqgcxy LV34月16日
星星星星星星
雾123456 LV24月16日
星星星星
顶部客服微信二维码底部
>扫描二维码关注最代码为好友扫描二维码关注最代码为好友