AI 助理
备案控制台
开发者社区 数据库 文章 正文

一文搞懂JDBC

2024-10-17 26
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
RDS MySQL Serverless 高可用系列，价值2615元额度，1个月
简介： 一文搞懂JDBC

JDBC
一、JDBC快速入门
1.准备数据库并查看其版本 SELECT VERSION();
2.下载对应版本驱动jar包

3.创建数据库
create table t_emp
(
emp_id int auto_increment comment '员工编号' primary key,
emp_name varchar(100) not null comment '员工姓名',
emp_salary double(10, 5) not null comment '员工薪资',
emp_age int not null comment '员工年龄'
);

insert into t_emp (emp_name,emp_salary,emp_age)
values ('andy', 777.77, 32),
('大风哥', 666.66, 41),
('康师傅',111, 23),
('Gavin',123, 26),
('小鱼儿', 123, 28);
1
2
3
4
5
6
7
8
9
10
11
12
13
14
4.java代码
public class JDBCQuickStart {
public static void main(String[] args) throws Exception {
// 1.加载驱动
Class.forName("com.mysql.cj.jdbc.Driver");
// 2.建立连接
String url = "jdbc:mysql://localhost:3306/mybatis";
String user = "root";
String password = "root";
Connection connection = DriverManager.getConnection(url, user, password);
// 3.创建Statement
Statement statement = connection.createStatement();
// 4.执行SQL
String sql = "select * from t_emp";
ResultSet resultSet = statement.executeQuery(sql);
//5.处理结果
while (resultSet.next()) {
int empId = resultSet.getInt("emp_id");
String empName = resultSet.getString("emp_name");
String empSalary = resultSet.getString("emp_salary");
int empAge = resultSet.getInt("emp_age");
System.out.println(empId + "\t" + empName + "\t" + empSalary + "\t" + empAge);
}

    //6.释放资源(先开后关原则)
    resultSet.close();
    statement.close();
    connection.close();
}

}

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
5.核心api理解
注册驱动
Class.forName("com.mysql.cj.jdbc.Driver");
1
在 Java 中，当使用 JDBC（Java Database Connectivity）连接数据库时，需要加载数据库特定的驱动程序，以便与数据库进行通信。加载驱动程序的目的是为了注册驱动程序，使得 JDBC API 能够识别并与特定的数据库进行交互。

从JDK6开始，不再需要显式地调用 Class.forName() 来加载 JDBC 驱动程序，只要在类路径中集成了对应的jar文件，会自动在初始化时注册驱动程序。

Connection
Connection接口是JDBC API的重要接口，用于建立与数据库的通信通道。换而言之，Connection对象不为空，则代表一次数据库连接。
在建立连接时，需要指定数据库URL、用户名、密码参数。
URL：jdbc:mysql://localhost:3306/atguigu
jdbc:mysql://IP地址:端口号/数据库名称?参数键值对1&参数键值对2
Connection 接口还负责管理事务，Connection 接口提供了 commit 和 rollback 方法，用于提交事务和回滚事务。
可以创建 Statement 对象，用于执行 SQL 语句并与数据库进行交互。
在使用JDBC技术时，必须要先获取Connection对象，在使用完毕后，要释放资源，避免资源占用浪费及泄漏。
Statement
Statement 接口用于执行 SQL 语句并与数据库进行交互。它是 JDBC API 中的一个重要接口。通过 Statement 对象，可以向数据库发送 SQL 语句并获取执行结果。

结果可以是一个或多个结果。

增删改：受影响行数单个结果。
查询：单行单列、多行多列、单行多列等结果。
但是Statement 接口在执行SQL语句时，会产生SQL注入攻击问题:

当使用 Statement 执行动态构建的 SQL 查询时，往往需要将查询条件与 SQL 语句拼接在一起，直接将参数和SQL语句一并生成，让SQL的查询条件始终为true得到结果。statement 默认会在参数两边加上双引号’’

"select id, name, money, birthday from user where name='"+name+"'"

参数 = zhangsan' or 1='1 具有sql注入风险
1
2
3
PreparedStatement
PreparedStatement是 Statement 接口的子接口，用于执行预编译的 SQL 查询，作用如下：
预编译SQL语句：在创建PreparedStatement时，就会预编译SQL语句，也就是SQL语句已经固定。
防止SQL注入：PreparedStatement 支持参数化查询，将数据作为参数传递到SQL语句中，采用?占位符的方式，将传入的参数用一对单引号包裹起来’'，无论传递什么都作为值。有效防止传入关键字或值导致SQL注入问题。
性能提升：PreparedStatement是预编译SQL语句，同一SQL语句多次执行的情况下，可以复用，不必每次重新编译和解析。
ResultSet
ResultSet是 JDBC API 中的一个接口，用于表示从数据库中执行查询语句所返回的结果集。它提供了一种用于遍历和访问查询结果的方式。
遍历结果：ResultSet可以使用 next() 方法将游标移动到结果集的下一行，逐行遍历数据库查询的结果，返回值为boolean类型，true代表有下一行结果，false则代表没有。
获取单列结果：可以通过getXxx的方法获取单列的数据，该方法为重载方法，支持索引和列名进行获取。
二、基于PreparedStatement实现CRUD
查询单行单列
/**

 * 查询单行单列
 *
 * @throws SQLException
 */
@Test
public void querySingleRowAndColumn() throws SQLException {
    //1.注册驱动

// Class.forName("com.mysql.cj.jdbc.Driver");

    //2.获取数据库连接
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/mybatis", "root", "root");

    //3.创建PreparedStatement对象，并预编译SQL语句
    PreparedStatement preparedStatement = connection.prepareStatement("select count(*) as count from t_emp");

    //4.执行SQL语句，获取结果
    ResultSet resultSet = preparedStatement.executeQuery();

    //5.处理结果
    while (resultSet.next()) {
        int count = resultSet.getInt("count");
        System.out.println("count = " + count);
    }

    //6.释放资源(先开后关原则)
    resultSet.close();
    preparedStatement.close();
    connection.close();
}

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
查询单行多列
/**

 * 单行多列
 *
 * @throws SQLException
 */
@Test
public void querySingleRow() throws SQLException {
    //1.注册驱动

// Class.forName("com.mysql.cj.jdbc.Driver");

    //2.获取数据库连接
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/mybatis", "root", "root");

    //3.创建PreparedStatement对象，并预编译SQL语句，使用?占位符
    PreparedStatement preparedStatement = connection.prepareStatement("select emp_id,emp_name,emp_salary,emp_age from t_emp where emp_id = ?");

    //4.为占位符赋值，索引从1开始，执行SQL语句，获取结果
    preparedStatement.setInt(1, 1);
    ResultSet resultSet = preparedStatement.executeQuery();

    //5.处理结果
    while (resultSet.next()) {
        int empId = resultSet.getInt("emp_id");
        String empName = resultSet.getString("emp_name");
        String empSalary = resultSet.getString("emp_salary");
        int empAge = resultSet.getInt("emp_age");
        System.out.println(empId + "\t" + empName + "\t" + empSalary + "\t" + empAge);
    }

    //6.释放资源(先开后关原则)
    resultSet.close();
    preparedStatement.close();
    connection.close();

}

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
查询多行多列
/**

 * 多行多列
 *
 * @throws SQLException
 */
@Test
public void queryMoreRow() throws SQLException {
    //1.注册驱动

// Class.forName("com.mysql.cj.jdbc.Driver");

    //2.获取数据库连接
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/mybatis", "root", "root");

    //3.创建Statement对象
    PreparedStatement preparedStatement = connection.prepareStatement("select emp_id,emp_name,emp_salary,emp_age from t_emp");

    //4.编写SQL语句并执行，获取结果
    ResultSet resultSet = preparedStatement.executeQuery();


    //5.处理结果
    while (resultSet.next()) {
        int empId = resultSet.getInt("emp_id");
        String empName = resultSet.getString("emp_name");
        String empSalary = resultSet.getString("emp_salary");
        int empAge = resultSet.getInt("emp_age");
        System.out.println(empId + "\t" + empName + "\t" + empSalary + "\t" + empAge);
    }

    //6.释放资源(先开后关原则)
    resultSet.close();
    preparedStatement.close();
    connection.close();

}

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
新增
@Test
public void insert() throws SQLException {
//1.注册驱动
// Class.forName("com.mysql.cj.jdbc.Driver");

    //2.获取数据库连接
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/mybatis", "root", "root");

    //3.创建Statement对象
    PreparedStatement preparedStatement = connection.prepareStatement("insert into t_emp (emp_name,emp_salary,emp_age)values  (?, ?,?)");

    //4.为占位符赋值，索引从1开始，编写SQL语句并执行，获取结果
    preparedStatement.setString(1, "rose");
    preparedStatement.setDouble(2, 666.66);
    preparedStatement.setDouble(3, 28);
    int result = preparedStatement.executeUpdate();

    //5.处理结果
    if (result > 0) {
        System.out.println("添加成功");
    } else {
        System.out.println("添加失败");
    }

    //6.释放资源(先开后关原则)
    preparedStatement.close();
    connection.close();

}

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
修改
@Test
public void update() throws SQLException {
//1.注册驱动
// Class.forName("com.mysql.cj.jdbc.Driver");

    //2.获取数据库连接
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/mybatis", "root", "root");

    //3.创建Statement对象
    PreparedStatement preparedStatement = connection.prepareStatement("update t_emp set emp_salary = ? where emp_id = ?");

    //4.为占位符赋值，索引从1开始，编写SQL语句并执行，获取结果
    preparedStatement.setDouble(1, 888.88);
    preparedStatement.setDouble(2, 6);
    int result = preparedStatement.executeUpdate();

    //5.处理结果
    if (result > 0) {
        System.out.println("修改成功");
    } else {
        System.out.println("修改失败");
    }

    //6.释放资源(先开后关原则)
    preparedStatement.close();
    connection.close();

}

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
删除
@Test
public void delete() throws SQLException {
//1.注册驱动
// Class.forName("com.mysql.cj.jdbc.Driver");

    //2.获取数据库连接
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/mybatis", "root", "root");

    //3.创建Statement对象
    PreparedStatement preparedStatement = connection.prepareStatement("delete from t_emp where emp_id = ?");

    //4.为占位符赋值，索引从1开始，编写SQL语句并执行，获取结果
    preparedStatement.setInt(1, 6);
    int result = preparedStatement.executeUpdate();

    //5.处理结果
    if (result > 0) {
        System.out.println("删除成功");
    } else {
        System.out.println("删除失败");
    }

    //6.释放资源(先开后关原则)
    preparedStatement.close();
    connection.close();

}
文章标签：
云数据库 RDS MySQL 版
Java
SQL
数据库连接
数据库
API
相关实践学习
如何在云端创建MySQL数据库
开始实验后，系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
你都不懂
目录
相关文章
Z_sorrain
|
3月前
|
Java 数据库连接
JDBC连接复习
JDBC连接复习
Z_sorrain
38 1
xaubllxwtvaqiu
|
SQL Oracle Java
JDBC 的原理 | 学习笔记
快速学习 JDBC 的原理
xaubllxwtvaqiu
156 0
JDBC 的原理 | 学习笔记
Cyan_RA9
|
SQL druid Java
JDBC BasicDAO详解（通俗易懂）
JDBC 第七节 详解BasicDAO 通俗易懂！
Cyan_RA9
145 0
Cyan_RA9
|
监控 druid Java
JDBC 连接池 详解（通俗易懂）
JDBC 第五节 详解连接池 通俗易懂！
Cyan_RA9
522 0
十七ing
|
SQL Java 关系型数据库
JDBC 编程
JDBC 编程
十七ing
102 0
JDBC 编程
小蜗牛耶
|
SQL Java 数据库连接
搞懂JDBC这一篇就够了！！！（三）
搞懂JDBC这一篇就够了！！！（三）
小蜗牛耶
311 0
搞懂JDBC这一篇就够了！！！（三）
小蜗牛耶
|
SQL Java 关系型数据库
搞懂JDBC这一篇就够了！！！（一）
搞懂JDBC这一篇就够了！！！（一）
小蜗牛耶
251 0
搞懂JDBC这一篇就够了！！！（一）
小蜗牛耶
|
SQL druid Java
搞懂JDBC这一篇就够了！！！（二）
搞懂JDBC这一篇就够了！！！（二）
小蜗牛耶
168 0
搞懂JDBC这一篇就够了！！！（二）
阿Jie
|
XML SQL Oracle
学习JDBC这一篇就够了(一)
JDBC
阿Jie
238 0
学习JDBC这一篇就够了(一)
阿Jie
|
SQL 监控 Oracle
学习JDBC这一篇就够了(二)
JDBC
阿Jie
121 0
学习JDBC这一篇就够了(二)

热门文章

最新文章

  • 1
    常见浏览器User-Agent大全
  • 2
    未来已来！阿里小蜜AI技术揭秘
  • 3
    Flink: 实时规则引擎助力新零售发展
  • 4
    Apache Flink 进阶（三）：Checkpoint 原理解析与应用实践
  • 5
    weex-html5 组件进阶
  • 6
    群智能算法：灰狼优化算法（GWO）的详细解读
  • 7
    Amazon 的IoT之路
  • 8
    hp M1530一体机无法在OEM系统下安装驱动
  • 9
    NumPy Cookbook 带注释源码 十、Scikit 中的乐趣
  • 10
    潮流设计：15个创意的 3D 字体版式作品欣赏
  • 1
    springboot配置hosts文件
    24
  • 2
    maven项目的pom.xml文件常用标签使用介绍
    23
  • 3
    天气预报-腾讯天气-7天-地址查询版免费API接口
    24
  • 4
    第四届人文，智慧教育与服务管理国际学术会议（HWESM 2025） 2025 4th International Conference on Humanities, Wisdom Education and Service Management
    19
  • 5
    2025电气自动化与电机系统国际学术会议（EAMS 2025） 2025 International Conference on Electrical Automation and Motor System
    19
  • 6
    大厂面试高频：什么是自旋锁？Java 实现自旋锁的原理？
    18
  • 7
    C++ 之 perf+火焰图分析与调试
    16
  • 8
    面试高频：Synchronized 原理，建议收藏备用 ！
    13
  • 9
    SQL 中，通配符
    14
  • 10
    鸿蒙next版开发：相机开发-适配不同折叠状态的摄像头变更(ArkTS)
    20

    • 相关课程

    更多
  • JDBC数据库开发进阶
  • JDBC数据库开发入门

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    无影云桌面