• 高效掌握JDBC技术（二）| 掌握ORM思想 | 定义连接数据库的工具类

    ✅作者简介：C/C++领域新星创作者、CSDN内容合伙人，喜欢学习后端语言的大学生
    ✨精品专栏：C++面向对象核心
    🔥系列专栏：JDBC技术
    📃推荐一款模拟面试、刷题神器👉注册免费刷题

    🔥前言

    上文讲了JDBC连接数据库的六大步，成功完成了对数据库的修改的读取。那么今天就来学习一下ORM思想，理解面向对象语言与关系型数据库之间的映射关系，学习把连接数据库的方法定义到一个工具类中从而减少重复代码的书写。

    文章目录

    一、ORM思想及实践

    ORM框架思想：

    广义上，ORM指的是面向对象的对象模型和关系型数据库的数据结构之间的相互转换。 狭义上，ORM可以被认为是，基于关系型数据库的数据存储，实现一个虚拟的面向对象的数据访问接口。

    • 在对象模型和关系型模型之间实现映射
    模型数据格式操作数据的方式
    java： 面向对象的语言对象、属性、类通过方法操作对象
    mysql：关系型数据库行、字段、表的设计通过SQL语句操作表中数据
    • 两者的区别：数据格式不同、操作数据的方式不同
    • 两者的映射：
      • 一张表的设计 – 一个类
      • 表中的一个字段 – 类中的一个属性
      • 表中的一行数据 – 一个对象
      • 一条SQL – 一个方法

    实践部分：

    1、实体类

    • 作用：跟数据库中表的设计进行映射，解决了两者之间数据格式不同的问题
    java数据库
    类：对对象的设计表：对字段的设计
    属性字段：列
    对象行
    • 要求：
      1. 一张表对应一个实体类
      2. 类名必须与表名相关
      3. 类必须实现Serializable接口
      4. 一个字段对应一个属性
      5. 属性类型必须为引用类型
      6. 必须提供无参构造（建议全属性有参构造同步存在）
      7. 为了保证对象安全，正常对属性进行封装
    /**
 * 映射t_user表
 */
public class User implements Serializable {
    private Integer id;
    private String name;
    private String sex;
    private Integer age;
    public User() {
    }
    public User(Integer id, String name, String sex, Integer age) {
        this.id = id;
        this.name = name;
        this.sex = sex;
        this.age = age;
    }
    public Integer getId() {
        return id;
    }
    public void setId(Integer id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getSex() {
        return sex;
    }
    public void setSex(String sex) {
        this.sex = sex;
    }
    public Integer getAge() {
        return age;
    }
    public void setAge(Integer age) {
        this.age = age;
    }
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41

    2、DAO模式

    • 作用：用来解决两者之间数据操作方式不同的问题

      操作数据库java
      增insert into…int insertXxx(对象)
      删delete from…int deleteXxx(Xxx 条件参数)
      改update … set …int updateXxx(Xxx 条件参数)
      查询单个select … from … where …对象 selectXxxByXxx(Xxx 条件参数)
      查询多个select … from对象集合/对象数组 selectXxxs()

    • 实现：

      1. 一张表对应一个接口，接口中存放着对该表的所有操作的行为方法
      2. 接口名应与表名相关：t_user-->UserDao
      3. 包：com.xxx.dao
      • 实现类：
        1. 一个实现类实现一个接口
        2. 实现类的命名：UserDao-->UserDaoImpl
        3. 包：com.xxx.dao.impl

    • 优点：让方法声明与方法实现分离，可以促使接口成为一套行为规范，该规范可以拥有多种不同的实现方式，提高程序的可扩展性

    UserDao接口：

    package com.bz.dao;
import com.bz.entity.User;
/**
 * t_user的所有行为方法
 */
public interface UserDao {
    /**
     * 往表中添加一条信息
     * @param user  包含着所有属性值的对象
     * @return 受影响的行数
     */
    int insertUser(User user) throws  Exception;

    /**
     * 根据用户id查找指定用户信息
     * @param id  被查询的id
     * @return 对应的用户信息对象
     */
    User seleteUserById(Integer id) throws  Exception;
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20

    UserDaoImpl实现：

    package com.bz.dao.impl;
import com.bz.dao.UserDao;
import com.bz.entity.User;

/**
 * 分别在不同的方法中使用JDBC6大步实现不同的功能方法
 */
public class UserDaoImpl implements UserDao {

    @Override
    public int insertUser(User user) throws Exception{
        //1. 加载驱动
        Class.forName("com.mysql.cj.jdbc.Driver");
        //2. 获取连接
        //用户名
        String username = "root";
        //密码
        String pwd = "123456";
        //连接的url
        String url = "jdbc:mysql://localhost:3306/baizhi2109?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai";
        Connection conn = DriverManager.getConnection(url, username, pwd);
        //3. 获取发送SQL的工具
        String sql="insert into t_user (u_name,u_sex,u_age) VALUES(?,?,?)";
        PreparedStatement ps = conn.prepareStatement(sql);
        //4. 发送并执行SQL
        //给占位符赋值:用参数对象的值给表中字段赋值
        ps.setString(1,user.getName());
        ps.setString(2,user.getSex());
        ps.setInt(3,user.getAge());

        int n=ps.executeUpdate();
        //5. 处理结果集  略
        //6.关闭资源
        ps.close();
        conn.close();
        return  n;//把受影响行数返回
    }

    @Override
    public User seleteUserById(Integer id) throws  Exception {
        User user=null;//用来返回的User对象

        //1. 加载驱动
        Class.forName("com.mysql.cj.jdbc.Driver");
        //2. 获取连接
        //用户名
        String username = "root";
        //密码
        String pwd = "123456";
        //连接的url
        String url = "jdbc:mysql://localhost:3306/baizhi2109?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai";
        Connection conn = DriverManager.getConnection(url, username, pwd);
        //准备发送SQL
        String sql = "select * from t_user where u_id=?";
        PreparedStatement ps = conn.prepareStatement(sql);
        //发送SQL
        //给占位符赋值
        ps.setInt(1,id);
        ResultSet rs=ps.executeQuery();
        //处理结果集
        if (rs.next()){//判断结果集中是否存在内容
            Integer uid = rs.getInt("u_id");
            String uname = rs.getString("u_name");
            String usex = rs.getString("u_sex");
            Integer uage = rs.getInt("u_age");
            //根据字段值构建对应的User对象
            user= new User(uid, uname, usex, uage);
        }
        //关闭资源
        rs.close();
        ps.close();
        conn.close();
        return user;
    }
}


    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62
    • 63
    • 64
    • 65
    • 66
    • 67
    • 68
    • 69
    • 70
    • 71
    • 72
    • 73
    • 74
    • 75
    • 76

    测试UserDao的接口实现类：

    package com.bz.test;
import com.bz.dao.UserDao;
import com.bz.dao.impl.UserDaoImpl;
import com.bz.entity.User;

public class TestUser {
    public static void main(String[] args) throws Exception{
        //创建实现类对象
        UserDao ud=new UserDaoImpl();
		//测试查询方法
        User user= ud.seleteUserById(2);
        System.out.println(user);
        //创建用来添加的对象
        User user = new User("zhangsan", "男", 38);
        //调用添加方法，接收返回值
        int n = ud.insertUser(user);
        //判断返回值
        if (n>0){
            System.out.println("添加成功");
        }else{
            System.out.println("添加失败");
        }
    }
}


    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25

    二、实现数据库连接的工具类——JDBCUtils

    从上面书写Dao接口实现类的时候我们发现，每当我要对数据库进行操作就要建立一个连接，书写六大步骤，是不是过于繁琐呢？因此我们直接实现一个数据库连接的工具类来减少重复代码的书写。

    1、JDBCUtils的具体代码实现

    package com.bz.util;
import java.sql.*;

/**
 * 工具类：方便方法调用，所有方法都应为静态方法
 */
public class JDBCUtils {
    public static Connection getConnection(){
        Connection conn =null;
        try {
            //1. 加载驱动
            Class.forName("com.mysql.cj.jdbc.Driver");
            //2. 获取连接
            //用户名
            String username = "root";
            //密码
            String pwd = "123456";
            //连接的url
            String url = "jdbc:mysql://localhost:3306/baizhi2109?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai";
            conn = DriverManager.getConnection(url, username, pwd);
        }catch (ClassNotFoundException e){
            System.out.println("驱动路径不正确");
        }catch (SQLException e){
            System.out.println("获取连接失败");
        }catch (Exception e){
            System.out.println("未知异常");
            e.printStackTrace();
        }
       return conn;
    }

    /**
     * 关闭资源连接  非空判断：防止空指针
     * @param rs
     * @param ps
     * @param conn
     */
    public static void close(ResultSet rs, PreparedStatement ps,Connection conn){
        if (rs!=null){
            try {
                rs.close();
            } catch (SQLException e) {
                System.out.println("关闭rs失败");
            }
        }
        if (ps!=null){
            try {
                ps.close();
            } catch (SQLException e) {
                System.out.println("关闭ps失败");
            }
        }
        if (conn!=null){
            try {
                conn.close();
            } catch (SQLException e) {
                System.out.println("关闭conn失败");
            }
        }
    }
}


    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62

    2、调用工具类

    public class UserDaoImpl implements UserDao {

    @Override
    public int insertUser(User user) throws Exception{
        //调用工具类的方法获取连接
        Connection conn=JDBCUtils.getConnection();
        //3. 获取发送SQL的工具
        String sql="insert into t_user (u_name,u_sex,u_age) VALUES(?,?,?)";
        PreparedStatement ps = conn.prepareStatement(sql);
        //4. 发送并执行SQL
        //给占位符赋值:用参数对象的值给表中字段赋值
        ps.setString(1,user.getName());
        ps.setString(2,user.getSex());
        ps.setInt(3,user.getAge());

        int n=ps.executeUpdate();
        //5. 处理结果集  略
        //6.调用工具类方法关闭资源
        JDBCUtils.close(null,ps,conn);

        return  n;//把受影响行数返回
    }
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23

    希望大家可以在这篇文章中学到ORM思想，此外可以参加投票，我将会在后续文章中做出改进，感谢你的配合！

  • 相关阅读:
    Jwt
    LeetCode力扣020:有效的括号
    shell脚本介绍
    数据采集时使用HTTP代理IP效率不高怎么办？
    Matlab图像处理-灰度直方图
    飞书机器人获取云文档中表格中的内容
    【数据结构-栈 二】【单调栈】每日温度、接雨水
    SpringBoot ApplicationContext分析
    针对移动硬盘发生I/O请求失败无法访问的问题
    微服务学习|Nacos配置管理：统一配置管理、配置热更新、配置共享、搭建Nacos集群
  • 原文地址：https://blog.csdn.net/m0_58618795/article/details/126630412