目录
- 一、什么是BaseDao?
- BaseDao的优点:
- BaseDao用来做什么操作?
- 二、BaseDao封装增删改查 案例演示:
- 1、java与数据库进行连接
- 2、连接后可对其进行操作(增、删、改)返回影响行数
- 3、查询 查询一个字段(返回一条记录且只有一个条件,常用场景:单个条件查询)
- 4、有连接自然就有有关闭 使用完关闭数据库连接
- 三、演示BaseDao增删改查方法:
一、什么是BaseDao?
BaseDao是一个基于数据访问对象(Data Access Object,简称 DAO)设计模式的通用数据库操作类,它封装了对数据库的基本操作,如增加、删除、修改和查询等。使用 BaseDAO 可以简化数据库操作的代码编写,提高开发效率。
BaseDao的优点:
- 代码复用性:BaseDao封装了通用的数据库操作方法,这些方法可以被不同的业务逻辑类重复调用,这样可以减少重复编写相同数据库操作代码的工作,提高了代码的复用性。
- 业务逻辑与数据库访问解耦:BaseDao不直接与具体的数据库表对应,而是通过数据映射层(如DTO、VO等)来实现业务逻辑与数据库表的映射。这样的设计使得开发者在编写业务逻辑时,无需关心具体的数据库表结构,只需专注于业务逻辑的实现,从而降低了业务逻辑与数据库访问之间的耦合度。
- 灵活的数据操作方法:BaseDao提供了多种灵活的数据操作方法,如分页查询、条件查询等,这些方法可以满足业务逻辑的各种需求,使得数据处理更加灵活和高效。
- 模块化DAO(Data Access Object)的设计原则是为了实现功能的模块化,这有利于代码的维护和升级。在实际开发中,DAO层主要负责数据的持久化,而不包含任何业务相关的信息,这有助于保持代码的清晰和易于管理。
BaseDao的使用可以简化数据库操作,提高开发效率和代码质量。
BaseDao用来做什么操作?
- 提供通用的数据库操作:BaseDao提供了一些通用的方法,
如插入数据、更新数据、删除数据和查询数据等,这些方法可以在不同的数据访问对象中重复使用。 - 减少冗余代码
- 提高开发效率
- 降低出错概率
二、BaseDao封装增删改查 案例演示:
1、java与数据库进行连接
//数据库连接
public class BaseDao {private String driver = "com.mysql.jdbc.Driver";// 数据库驱动字符串private String url = "jdbc:mysql://localhost:3306/数据库名";// 连接URL字符串private String user = "root"; // 数据库用户名private String password = "20040417"; // 用户密码Connection conn=null; // 数据连接对象/*** 获取数据库连接对象*/public Connection getConnection() {Connection conn=null; // 数据连接对象// 获取连接并捕获异常try {Class.forName(driver);conn = DriverManager.getConnection(url, user, password);} catch (Exception e) {e.printStackTrace(); // 异常处理}return conn; // 返回连接对象}
2、连接后可对其进行操作(增、删、改)返回影响行数
/*** 增、删、改的操作* @param sql 预编译的 SQL 语句* @param param 参数的字符串数组* @return 影响的行数*/public int exceuteUpdate (String sql, Object[] param) {PreparedStatement ps = null;int row = 0;conn = getConnection();try {ps = conn.prepareStatement(sql);if (param != null) {for (int i = 0; i < param.length; i++) {//为预编译sql设置参数ps.setObject(i + 1, param[i]);}}row = ps.executeUpdate();} catch (SQLException e) {e.printStackTrace();} finally{closeAll(conn,ps,null);}return row;}
3、查询 查询一个字段(返回一条记录且只有一个条件,常用场景:单个条件查询)
/*** 查询方法* @param sql* @param objs* @return*/public List<Names> executeQuery(String sql, Object[] objs) {List<Names> resultList = new ArrayList<>();Connection con = getConnection();try {PreparedStatement ps = con.prepareStatement(sql);// 设置参数for (int i = 0; i < objs.length; i++) {ps.setObject(i + 1, objs[i]);}ResultSet rs = ps.executeQuery();while (rs.next()) {Names a = new Names();// 根据实际表结构设置属性值a.setId(rs.getInt("id"));a.setName(rs.getString("name"));a.setPwd(rs.getString("pwd"));resultList.add(a);System.out.println(a.getId()+a.getName()+a.getPwd());}closeAll(con, rs, ps);} catch (Exception e) {e.printStackTrace();}return resultList;}
4、有连接自然就有有关闭 使用完关闭数据库连接
/*** 关闭数据库连接* @param conn 数据库连接* @param stmt Statement对象* @param rs 结果集*/public void closeAll(Connection conn, Statement stmt, ResultSet rs) {// 若结果集对象不为空,则关闭if (rs != null) {try {rs.close();} catch (Exception e) {e.printStackTrace();}}// 若Statement对象不为空,则关闭if (stmt != null) {try {stmt.close();} catch (Exception e) {e.printStackTrace();}}// 若数据库连接对象不为空,则关闭if (conn != null) {try {conn.close();} catch (Exception e) {e.printStackTrace();}}}
三、演示BaseDao增删改查方法:
public class Test {public static void main(String[] args) throws SQLException {BaseDao1 dao=new BaseDao1();//新增功能String sqlAdd="insert into names(name,age) values(?,?)";Object []objAdd={"老九",11};int r1=dao.executeUpdate(sqlAdd,objAdd);if(r1>0){System.out.println("新增成功");}//删除功能String sqlDel="delete from names where id=?";Object []objDel={2};int r2= dao.executeUpdate(sqlDel,objDel);if(r2>0){System.out.println("删除成功");}//修改功能String sqlUpdate="update names set name=? where id=?";Object []objUpdate={"小尹",1};int r3= dao.executeUpdate(sqlUpdate,objUpdate);if(r3>0){System.out.println("修改成功");}//查询功能String sqlShow = "select * from names where id=?";Object[] objShow = {1};//返回结果集dao.executeQuery(sqlShow,objShow);}}
总结:以上就是BaseDao的使用入门了 如有错误望指点 谢谢!