在员工管理系统中,已知"员工表"的信息为:表名:Worker字段分别为:wid; varchar; 员工编号:wname; varchar; 员工名称,wage;int; 员工年龄,wphone;varchar;员工电话 已知Dao模式中的DataBase.java如下所示: public class DataBase { public DataBase(){//构造函数,实现连接及创建Statement} public ResultSet executeSql(String sql){//执行查询,获取结果集} public int executeDML(String sql){ //执行增 删 改}} 请构建员工信息表Dao模式中的其他三部分(即实体类、Dao接口、Dao接口实现类)java代码,所需要的业务方法有:1.根据员工编号查询员工信息的方法,2.添加员工信息的方法。程序命名、变量命名、方法名要符合规范。
时间: 2024-03-11 09:51:43 浏览: 14
实体类Worker.java:
```
public class Worker {
private String wid; //员工编号
private String wname; //员工名称
private int wage; //员工年龄
private String wphone; //员工电话
//构造方法
public Worker(String wid, String wname, int wage, String wphone) {
this.wid = wid;
this.wname = wname;
this.wage = wage;
this.wphone = wphone;
}
//getter和setter方法
public String getWid() {
return wid;
}
public void setWid(String wid) {
this.wid = wid;
}
public String getWname() {
return wname;
}
public void setWname(String wname) {
this.wname = wname;
}
public int getWage() {
return wage;
}
public void setWage(int wage) {
this.wage = wage;
}
public String getWphone() {
return wphone;
}
public void setWphone(String wphone) {
this.wphone = wphone;
}
}
```
Dao接口WorkerDao.java:
```
public interface WorkerDao {
//根据员工编号查询员工信息
public Worker queryWorkerById(String wid);
//添加员工信息
public int addWorker(Worker worker);
}
```
Dao接口实现类WorkerDaoImpl.java:
```
public class WorkerDaoImpl implements WorkerDao {
private DataBase db;
private PreparedStatement pstmt;
private ResultSet rs;
//构造方法,实例化数据库连接对象
public WorkerDaoImpl() {
db = new DataBase();
}
//根据员工编号查询员工信息
public Worker queryWorkerById(String wid) {
Worker worker = null;
String sql = "select * from Worker where wid=?";
try {
pstmt = db.getConnection().prepareStatement(sql);
pstmt.setString(1, wid);
rs = pstmt.executeQuery();
if(rs.next()) {
worker = new Worker(rs.getString("wid"), rs.getString("wname"), rs.getInt("wage"), rs.getString("wphone"));
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
db.closeAll(rs, pstmt);
}
return worker;
}
//添加员工信息
public int addWorker(Worker worker) {
int result = 0;
String sql = "insert into Worker(wid,wname,wage,wphone) values(?,?,?,?)";
try {
pstmt = db.getConnection().prepareStatement(sql);
pstmt.setString(1, worker.getWid());
pstmt.setString(2, worker.getWname());
pstmt.setInt(3, worker.getWage());
pstmt.setString(4, worker.getWphone());
result = pstmt.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} finally {
db.closeAll(null, pstmt);
}
return result;
}
}
```