当前位置：首页 > news >正文

BaseDao指南

news 来源：原创 2025/5/24 9:51:49

1. BaseDao类

import java.sql.*;/*** 通用的工具类 ,负责连接数据， 执行增删改查的通用方法*/
public class BaseDao {private Connection connection;private PreparedStatement pstm;private ResultSet rs;/*** 建立数据库连接** @return*/public Boolean getConnection(){try {Class.forName("com.mysql.jdbc.Driver");connection =DriverManager.getConnection("jdbc:mysql://主机:端口/连接的数据库名称","根用户名","密码");return true;} catch (ClassNotFoundException e) {e.printStackTrace();return false;} catch (SQLException e) {e.printStackTrace();return false;}}/*** @param sql    insert into xx values (?,?,?)* @param params 参数个数和占位符个数一致*               new params[]{"a","b","c"}* @return*/public int update(String sql, Object[] params){try {if (this.getConnection()){pstm = connection.prepareStatement(sql);if (params!=null && params.length>0){for (int i=0; i < params.length; i++) {pstm.setObject(i+1,params[i]);}}int num = pstm.executeUpdate();return num;}} catch (SQLException e) {e.printStackTrace();}return 0;}/*** 查询** @param sql    select * from xxx where xx =? and xx=?* @param params new []{"xxx","xxx"}* @return*/public ResultSet query(String sql, Object[] params){try {if (this.getConnection()){pstm = connection.prepareStatement(sql);if (params!=null && params.length>0){for (int i=0; i < params.length; i++) {pstm.setObject(i+1,params[i]);}}rs = pstm.executeQuery();}} catch (SQLException e) {e.printStackTrace();}return rs;}/*** 关闭数据库连接*/public void close(){try {if (rs!=null){rs.close();}if (pstm!=null){pstm.close();}if (connection!=null){connection.close();}} catch (SQLException e) {e.printStackTrace();}}
}

主机，端口，根用户名，密码：

自选你需要连接的数据库名：

填写相应的数据，BaseDao就初始化完成了。

2. 指南

！食用指南前请先看文章Dao模式，更便于理解！

DAO模式-CSDN博客

接下来我将举例来说明如何具体使用：

需求：根据雇员id添加/更新/删除雇员信息。根据部门id获取部门名称

我们需要连接到dept1来完成工作：

connection=DriverManager.getConnection("jdbc:mysql://localhost:3306/dept1","root","ok");

表信息：

employees表：

departments表：

首先我们先创建两个实体类：

entity：

Employees

public class Employees {private Integer empId;private String empName;private Integer departmentId;private Double salary;private String empPasswd;public Employees() {}public Employees(Integer empId, String empName, Integer departmentId, Double salary, String empPasswd) {this.empId = empId;this.empName = empName;this.departmentId = departmentId;this.salary = salary;this.empPasswd = empPasswd;}public Integer getEmpId() {return empId;}public void setEmpId(Integer empId) {this.empId = empId;}public String getEmpName() {return empName;}public void setEmpName(String empName) {this.empName = empName;}public Integer getDepartmentId() {return departmentId;}public void setDepartmentId(Integer departmentId) {this.departmentId = departmentId;}public Double getSalary() {return salary;}public void setSalary(Double salary) {this.salary = salary;}public String getEmpPasswd() {return empPasswd;}public void setEmpPasswd(String empPasswd) {this.empPasswd = empPasswd;}@Overridepublic String toString() {return "Employees{" +"empId=" + empId +", empName='" + empName + '\'' +", departmentId=" + departmentId +", salary=" + salary +", empPasswd='" + empPasswd + '\'' +'}';}
}

Departments

public class Departments {private Integer deptId;private String deptName;public Departments() {}public Departments(Integer deptId, String deptName) {this.deptId=deptId;this.deptName=deptName;}public Integer getDeptId() {return deptId;}public void setDeptId(Integer deptId) {this.deptId = deptId;}public String getDeptName() {return deptName;}public void setDeptName(String deptName) {this.deptName = deptName;}@Overridepublic String toString() {return "Departments{" +"deptId=" + deptId +", deptName='" + deptName + '\'' +'}';}
}

接着我们来创建两个接口：

！注意：创建接口时可以根据需求一个一个方法的创建并实现。比如要做增删改查四个功能，可以先在接口里写（增加）的方法，在implement里实现以后再继续添加后续方法！

！注意：也可以分类别添加方法，比如增删改查是一类方法，可以add update delete list都写进接口里，在impl里挨个实现，然后再添加减薪资之类的复杂方法！

接口：

EmployeesDao接口

import com.zb.entity.Employees;import java.util.List;public interface EmployeesDao {int addEmployees(Employees employees);int updateEmp(Employees employees);int deleteEmp(Integer id);List<Employees> listEmpByDept(Integer deptId);Double avgSalaryByDept(Integer dept);}

DepartmentsDao接口

import com.zb.entity.Departments;public interface DepartmentsDao {Departments findDeptById(Integer id);}

接下来在接口实现类里对接口的方法进行实现：

！注意：接口实现类继承BaseDao并实现对应接口！

接口实现类

EmployeesDaoImpl

import com.zb.dao.BaseDao;
import com.zb.dao.EmployeesDao;
import com.zb.entity.Employees;import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;public class EmployeesDaoImpl extends BaseDao implements EmployeesDao {@Overridepublic int addEmployees(Employees employees) {String sql = "insert into employees values (?,?,?,?,?)";Object[] param = {employees.getEmpId(),employees.getEmpName(),employees.getDepartmentId(),employees.getSalary(),employees.getEmpPasswd()};int num = super.update(sql,param);close();return num;}@Overridepublic int updateEmp(Employees employees) {String sql = "update employees set emp_name=? , department_id=? ,salary =? ,emp_passwd =? where emp_id=?";Object[] param = {employees.getEmpName(),employees.getDepartmentId(),employees.getSalary(),employees.getEmpPasswd(),employees.getEmpId()};int num = super.update(sql,param);close();return num;}@Overridepublic int deleteEmp(Integer id) {String sql = "delete from employees  where emp_id=?";Object[] param = {id};int num = super.update(sql,param);close();return num;}@Overridepublic List<Employees> listEmpByDept(Integer deptId) {List<Employees> list = new ArrayList<>();String sql = "SELECT * FROM employees WHERE department_id=?";Object[] param = {deptId};ResultSet rs = super.query(sql,param);try {while(rs.next()){Employees employee = new Employees();employee.setEmpId(rs.getInt(1));employee.setEmpName(rs.getString(2));employee.setDepartmentId(rs.getInt(3));employee.setSalary(rs.getDouble(4));employee.setEmpPasswd(rs.getString(5));list.add(employee);}} catch (SQLException e) {e.printStackTrace();} finally {close();}return list;}@Overridepublic Double avgSalaryByDept(Integer dept) {String sql = "SELECT AVG(salary) FROM employees WHERE department_id = ?";Object[] param = {dept};ResultSet rs = super.query(sql,param);try {while (rs.next()){Double avgSalary = rs.getDouble(1);return avgSalary;}} catch (SQLException e) {e.printStackTrace();}finally {close();}return null;}}

DepartmentDaoImpl

import com.zb.dao.BaseDao;
import com.zb.dao.DepartmentsDao;
import com.zb.entity.Departments;import java.sql.ResultSet;
import java.sql.SQLException;public class DepartmentDaoImpl extends BaseDao implements DepartmentsDao {@Overridepublic Departments findDeptById(Integer id) {Departments departments = null;String sql = "SELECT * FROM  departments WHERE dept_id =?";Object[] param = {id};ResultSet rs = super.query(sql, param);try {while (rs.next()) {departments = new Departments();departments.setDeptId(rs.getInt(1));departments.setDeptName(rs.getString(2));}} catch (SQLException e) {e.printStackTrace();} finally {super.close();}return departments;}
}

接着我们进行测试：

Test

public class test {public static void main(String[] args) {//初始化一个新员工Employees employees=new Employees();employees.setEmpId(8);employees.setEmpName("关羽");employees.setDepartmentId(2);employees.setSalary(3000.0D);employees.setEmpPasswd("123");EmployeesDao employeesDao=new EmployeesDaoImpl();//添加新员工employeesDao.addEmployees(employees);//删除该员工employeesDao.deleteEmp(8);//更新该员工数据employeesDao.updateEmp(employees);//查看部门编号为1的员工的姓名和薪资List<Employees> emp=employeesDao.listEmpByDept(1);for (Employees employees1 : emp) {System.out.println(employees1.getEmpName() + "\t" + employees1.getSalary());}//查看部门编号为1的名称DepartmentsDao dept=new DepartmentDaoImpl();System.out.println(dept.findDeptById(1).getDeptName());}
}

附加：

进阶需求：查找每个部门的平均薪资，如果大于5000，则每个雇员-500元薪资

添加service文件夹，在service里对dao包里获取的数据进行处理

接口：

EmployeesService接口

public interface EmployeesService {boolean changeSalaryByDept(Integer dept,Double changeMoney);
}

DepartmentsService接口

import java.util.Map;public interface DepartmentsService {Map<String, Object> searchEmpFromDept(Integer dept);}

接口实现类：

EmpolyeesServiceImpl

import com.zb.dao.EmployeesDao;
import com.zb.dao.impl.EmployeesDaoImpl;
import com.zb.entity.Employees;
import com.zb.service.EmployeesService;import java.util.List;public class EmployeesServiceImpl implements EmployeesService {private EmployeesDao employeesDao = new EmployeesDaoImpl();@Overridepublic boolean changeSalaryByDept(Integer dept, Double reduceMoney) {double avgSalary = employeesDao.avgSalaryByDept(dept);if (avgSalary>5000){List<Employees> employees = employeesDao.listEmpByDept(dept);for (Employees employee : employees) {employee.setSalary(employee.getSalary()+reduceMoney);employeesDao.updateEmp(employee);}return true;}return false;}}

DepartmentsImpl

import com.zb.dao.DepartmentsDao;
import com.zb.dao.EmployeesDao;
import com.zb.dao.impl.DepartmentDaoImpl;
import com.zb.dao.impl.EmployeesDaoImpl;
import com.zb.entity.Employees;
import com.zb.service.DepartmentsService;import java.util.HashMap;
import java.util.List;
import java.util.Map;public class DepartmentsServiceImpl implements DepartmentsService {private DepartmentsDao departmentsDao = new DepartmentDaoImpl();private EmployeesDao employeesDao = new EmployeesDaoImpl();@Overridepublic Map<String, Object> searchEmpFromDept(Integer dept) {Map<String, Object> deptModel = new HashMap<>();List<Employees> employees = employeesDao.listEmpByDept(dept);deptModel.put("emp",employees);deptModel.put("dept",departmentsDao.findDeptById(dept));return deptModel;}}

Test

import com.zb.dao.DepartmentsDao;
import com.zb.dao.EmployeesDao;
import com.zb.dao.impl.DepartmentDaoImpl;
import com.zb.dao.impl.EmployeesDaoImpl;
import com.zb.entity.Departments;
import com.zb.entity.Employees;
import com.zb.service.DepartmentsService;
import com.zb.service.EmployeesService;
import com.zb.service.impl.DepartmentsServiceImpl;
import com.zb.service.impl.EmployeesServiceImpl;import java.util.List;
import java.util.Map;public class test {public static void main(String[] args) {EmployeesDao employeesDao=new EmployeesDaoImpl();double avgSalary=employeesDao.avgSalaryByDept(1);EmployeesService employeesService=new EmployeesServiceImpl();boolean flag=employeesService.changeSalaryByDept(1, -500.0);System.out.println(avgSalary + "\t" + flag);}}