高效掌握JDBC技术(二)| 掌握ORM思想 | 定义连接数据库的工具类(上)

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: 高效掌握JDBC技术(二)| 掌握ORM思想 | 定义连接数据库的工具类

一、ORM思想及实践

ORM框架思想:


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


在对象模型和关系型模型之间实现映射

image.png

两者的区别:数据格式不同、操作数据的方式不同

两者的映射:

一张表的设计 – 一个类

表中的一个字段 – 类中的一个属性

表中的一行数据 – 一个对象

一条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;
    }
}

2、DAO模式

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

image.png

实现:


一张表对应一个接口,接口中存放着对该表的所有操作的行为方法

接口名应与表名相关:t_user-->UserDao

包:com.xxx.dao

实现类:

一个实现类实现一个接口

实现类的命名:UserDao-->UserDaoImpl

包: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;
}

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;
    }
}

测试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("添加失败");
        }
    }
}
相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
7天前
|
安全 Java 数据库连接
gbase8a JDBC常用特性-Kerberos认证方式连接
JDBC常用特性-Kerberos认证方式连接
|
8天前
|
Java 数据库连接 网络安全
JDBC常用特性-SSH隧道连接
JDBC常用特性-SSH隧道连接
|
1月前
|
关系型数据库 MySQL 数据库连接
python脚本:连接数据库,检查直播流是否可用
【10月更文挑战第13天】本脚本使用 `mysql-connector-python` 连接MySQL数据库,检查 `live_streams` 表中每个直播流URL的可用性。通过 `requests` 库发送HTTP请求,输出每个URL的检查结果。需安装 `mysql-connector-python` 和 `requests` 库,并配置数据库连接参数。
128 68
|
21天前
|
数据库 C# 开发者
ADO.NET连接到南大通用GBase 8s数据库
ADO.NET连接到南大通用GBase 8s数据库
|
19天前
|
数据库连接 Linux Shell
Linux下ODBC与 南大通用GBase 8s数据库的无缝连接配置指南
本文详细介绍在Linux系统下配置GBase 8s数据库ODBC的过程,涵盖环境变量设置、ODBC配置文件编辑及连接测试等步骤。首先配置数据库环境变量如GBASEDBTDIR、PATH等,接着修改odbcinst.ini和odbc.ini文件,指定驱动路径、数据库名称等信息,最后通过catalog.c工具或isql命令验证ODBC连接是否成功。
|
19天前
|
JSON JavaScript 关系型数据库
node.js连接GBase 8a 数据库 并进行查询代码示例
node.js连接GBase 8a 数据库 并进行查询代码示例
|
1月前
|
SQL Java 数据库连接
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,有效减少连接开销,提升访问效率
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,有效减少连接开销,提升访问效率。本文介绍了连接池的工作原理、优势及实现方法,并提供了HikariCP的示例代码。
50 3
|
19天前
|
数据库连接 数据库 C#
Windows下C# 通过ADO.NET方式连接南大通用GBase 8s数据库(上)
Windows下C# 通过ADO.NET方式连接南大通用GBase 8s数据库(上)
|
19天前
|
数据库连接 数据库 C#
Windows下C# 通过ADO.NET方式连接南大通用GBase 8s数据库(下)
本文接续前文,深入讲解了在Windows环境下使用C#和ADO.NET操作南大通用GBase 8s数据库的方法。通过Visual Studio 2022创建项目,添加GBase 8s的DLL引用,并提供了详细的C#代码示例,涵盖数据库连接、表的创建与修改、数据的增删查改等操作,旨在帮助开发者提高数据库管理效率。
|
2月前
|
关系型数据库 MySQL 数据库连接
DBeaver如何连接一个数据库
【10月更文挑战第27天】DBeaver 是一款功能强大的通用数据库管理工具,支持多种主流数据库。本文介绍了使用 DBeaver 连接数据库的基本步骤,包括下载安装、创建新连接、选择数据库类型、配置连接参数、测试连接以及最终连接到数据库。详细的操作指南帮助用户轻松管理和操作数据库。
318 9