基于JDBC的MySQL数据库编程
Posted bit荣
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了基于JDBC的MySQL数据库编程相关的知识,希望对你有一定的参考价值。
✨博客主页: 荣 ✨系列专栏: mysql
✨一句短话: 难在坚持,贵在坚持,成在坚持!
文章目录
一. JDBC概述
JDBC: JDBC(Java DataBase Connectivity Java数据库连接)就是使用java语言操作关系型数据库的一套API.
实际开发中, sql很少是手动去的输入的, 绝大多数的sql都是通过代码自动执行的, 这就需要我们使用其他编程语言来操作数据库服务器.
各种数据库本身就都提供了一系列的API, 通过这些API就可以操作对应的数据库, 完成各种增删改查的操作; 同时也可以让我们比较方便的来实现客户端.
而每种数据库所提供的API都是一套单独的API, 是不相同的, 如果没有一个统一的标准, 要使用不同的数据库进行数据库编程, 就需要去学习好几套API, 这样就极大的提高了学习成本.
而这里所介绍的JDBC, 是Java标准库为为我们所提供一套标准API, JDBC中约定了应该有哪些API, 应该怎么用, 各种数据库厂商都提供了能够活应JDBC相关的"驱动包(相当于API的具体实现)".
JDBC屏蔽了不同数据库原生API之间的差异, 使用同一套API接口来规范了所有数据库的编程操作, 此时只要掌握了这套API, 无论操作哪个数据库, 操作的代码都是基本相同的.
二. JDBC前置工作
1. 准备好MySQL驱动包
MySQL的jdbc驱动包我们可以去官网下载, 我们也可以maven中央仓库下载, maven中央仓库类似于一个 “应用商店”,里面有许多的API以及依赖包.
这个驱动包可以从Oracle官网下载, 但是可能不太好找, 所以更建议去maven中央仓库下载jdbc驱动包.
网址:maven中央仓库
第一步, 点进网址进入maven中央仓库.
第二步, 搜索MySQL, 选择MySQL Connector java.
第三步, 点击进入, 找到对应大版本的jdbc驱动包, 比如我的MySQL是5版本的, 那驱动包也选择5版本的.
第四步, 第进去, 点击jar, 下载驱动包, 驱动包中有很多字节码文件(.class).
下载完成我们的驱动包就准备好了.
2. 创建项目
使用IDEA编译器创建一个项目, 项目创建好后, 按照下面的步骤操作:
第一步, 创建一个目录, 名字随便起, 这里就叫lib目录.
第二步, 将下载好的驱动包拷贝到该目录.
第三步, 设置选项, 右键刚才创建并已经将驱动包拷贝的目录, 找到Add as Library…
此时, 驱动包就导进项目中了, idea就可以解析出jar包里面的内容, 然后就是写相关代码了.
三. JDBC的使用步骤
写jdbc的代码时, 看起来挺复杂, 其实都有固定的格式, 套用即可.
1. 创建数据源DataSourece
第一步, 创建DataSource
对象, 用来来描述数据库在哪.
DataSource dataSource = new MysqlDataSource();
其中DataSource
为标准库中java.sql
里面的一个jdbc接口, MysqlDataSource
是来源于我们所下载驱动包中的一个实现DataSource
接口的类.
第二步, 设置数据库的 “位置” (URL), 登录数据库的用户名和密码.
//设置数据库所在地址
((MysqlDataSource)dataSource).setUrl
("jdbc:mysql://127.0.0.1:3306/java_rong?characterEncoding=utf8&useSSL=false");
//设置登录数据库的用户名
((MysqlDataSource)dataSource).setUser("root");
//设置登录数据库的密码
((MysqlDataSource)dataSource).setPassword("111111");
jdbc:mysql://127.0.0.1:3306/java_rong?characterEncoding=utf8&useSSL=false
是一个URL, 也叫唯一资源地址符.
具体含义对照: URL类型声明://数据库的地址/数据库名?字符集编码&是否加密
.
上面的向上/向下转型是jdbc中比较常用的写法, 让后续的代码继续使用DataSoure类型的实例, 避免MysqlDataSource扩散到代码中的各个地方, 以此方便未来更换数据库, 更换时只需要修改一处代码即可.
User是用户名, root为数据库的默认用户名.
Password是登录数据库的密码, 即安装数据时, 我们自己所设的密码.
此时我们数据源创建的操作, 只是去描述了下服务器在那里, 访问哪个数据库, 编码方式是什么, 登陆账号密码是什么等等, 但还没有真正进行连接访问, 下面进行的连接操作, 是真正开始通过网络进行通信.
2. 连接数据库
第三步, 和数据库服务器建立连接, 创建好数据源DataSource
对象后, 调用该对象的getConnection()
方法, 获取java.sql.Connection
对象, 此时就可以与数据库建立连接了.
Connection是网络通信中的核心概念, 叫做"连接".
Connection connection = dataSource.getConnection();
还可以通过Connection实例去调用事务方法
//开启事务
connection.setAutoCommit(boolean autoCommit);//是否自动提交事务,true是,false否
//提交事务
connection.commit();
//回滚事务
connection.rollback();
3. 构造并执行sql语句
第四步, 构造sql
语句字符串, 并将该语句包装成PreparedStatement
对象, 即调用Connection
对象的prepareStatement
方法, 参数是sql
字符串, 会返回一个PreparedStatement
对象, 然后我们再调用PreparedStatement
对象中的executeUpdate
方法或executeQuery
方法执行sql
语句(执行其实就是在给服务器发送网络请求).
先在mysql客户端中创建一个学生表, 有id和name两个字段
mysql> create table student(
-> id int,
-> name varchar(20)
-> );
Query OK, 0 rows affected (0.03 sec)
这里的代码先以插入操作为例.
//构造的sql语句不需要带上;
String sql = "insert into student values(1, '张三')";
//将sql字符串包装成一个语句对象,表示待执行的sql的对象
PreparedStatement statement = connection.prepareStatement(sql);
//执行sql
int ret = statement.executeUpdate();//返回值为受影响的行数
要注意如果待执行的sql语句操作是insert
, update
, delete
, 使用executeUpdate
方法执行即可,返回值为影响数据的行数;
而如果待执行的sql语句操作是select
, 则使用executeQuery
方法执行,返回值是一个ResultSet
结果表对象, 其中储存了查询到的的结果, 我们可以通过遍历该结果表来获取查询到的数据.
4. 释放资源
第五步, 释放资源, 我们执行完毕sql语句后需要及时地将资源释放, 在JDBC编程中, 最常见需要释放的类或接口有三个, 分别是Connection
, PreparedStatement
, ResultSet
, 要注意的是释放资源的顺序和开启资源的的顺序是相反的, 也就是先开启的要后释放.
//此时sql语句已经执行完毕了,需要释放资源
statement.close();
connection.close();
下面是jdbc完成插入操作的完整代码:
import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class JDBCInsertDemo
public static void main(String[] args) throws SQLException
//1. 创建数据源
DataSource dataSource = new MysqlDataSource();
//设置数据库所在地址
((MysqlDataSource)dataSource).setUrl
("jdbc:mysql://127.0.0.1:3306/java_rong?characterEncoding=utf8&useSSL=false");
//设置登录数据库的用户名
((MysqlDataSource)dataSource).setUser("root");
//设置登录数据库的密码
((MysqlDataSource)dataSource).setPassword("111111");
//2. 和数据库建立连接
Connection connection = dataSource.getConnection();//会报异常,需要处理
//3. 构造sql语句
//要注意sql字符串中不需要带上;
String sql = "insert into student values(1, '张三')";
//将sql字符串包装成一个语句对象,表示待执行的sql的对象
PreparedStatement statement = connection.prepareStatement(sql);
//4. 执行sql
int ret = statement.executeUpdate();
System.out.println(ret);
//5. 释放资源
//此时sql语句已经执行完毕了,需要释放资源
statement.close();
connection.close();
执行结果:
显示1行受到了影响
此时再来观察数据库中的student, 插入是成功了的.
mysql> show tables;
+---------------------+
| Tables_in_java_rong |
+---------------------+
| account |
| student |
+---------------------+
2 rows in set (0.00 sec)
mysql> select * from student;
+------+--------+
| id | name |
+------+--------+
| 1 | 张三 |
+------+--------+
1 row in set (0.00 sec)
5. sql语句不要写死(以插入为例)
观察上面的插入操作代码, 其中构造的sql语句是完全写死的, 造成了这个程序只能执行一次, 无法多次动态执行, 其实改善这一点很简单, 我们可以使用Scanner类通过控制台来让用户进行字段信息输入的操作, 然后将输入的信息整合到到sql字符串中.
那么如何整合呢, 最容易想到的就是字符串拼接, 也很容易实现, 代码如下:
System.out.println("请输入学号: ");
int id = scanner.nextInt();
System.out.println("请输入姓名: ");
String name = scanner.next();
// 3. 构造 SQL 语句
String sql = "insert into student values("+ id +", '" + name + "')";
执行结果:
此时程序也可以完成操作, 但是这么做是有缺陷的, 首先这个字符串就很容易写错, 特别是单双引号比较多的情况, 还有这种写法是很不安全的是, 黑客可以使用sql注入的方式来修改数据库.
所以不建议使用上面的方法, 更好的方法就是把sql字符串中待输入的信息使用?
来进行替换(占位), 然后通过PreparedStatement
中的setXXX
系列方法来逐个设置每个?
的内容;
这个系列的方法, 第一个参数表示sql待执行对象中第多少个?
,第二个参数表示将这个?
设置的内容, 需要注意?
占位符的编号是从1开始的, 而不是从0开始的.
此时使用这种方式完成插入操作, 代码如下:
import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;
public class JdbcInsertDemo
public static void main(String[] args) throws SQLException
//1. 创建数据源
DataSource dataSource = new MysqlDataSource();
((MysqlDataSource)dataSource).setUrl
("jdbc:mysql://127.0.0.1:3306/java_rong?characterEncoding=utf8&useSSL=false");
((MysqlDataSource)dataSource).setUser("root");
((MysqlDataSource)dataSource).setPassword("111111");
//2. 和数据库建立连接
Connection connection = dataSource.getConnection();
Scanner scanner = new Scanner(System.in);
System.out.println("请输入学号:");
int id = scanner.nextInt();
System.out.println("请输入姓名");
String name = scanner.next();
//3. 构造sql语句
String sql = "insert into student values (?, ?)";
PreparedStatement statement = connection.prepareStatement(sql);
statement.setInt(1, id);
statement.setString(2, name);
System.out.println("sql: "+statement);
//4. 执行sql
int ret = statement.executeUpdate();
System.out.println("ret= " + ret);
//5. 断开连接,释放资源
statement.close();
connection.close();
执行结果:
6. JDBC修改操作
jdbc的修改代码和插入操作是一样的, 只需要修改sql语句即可.
import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;
public class JdbcUpdateDemo
public static void main(String[] args) throws SQLException
//1. 创建数据源
DataSource dataSource = new MysqlDataSource();
((MysqlDataSource)dataSource).setUrl
("jdbc:mysql://127.0.0.1:3306/java_rong?characterEncoding=utf8&useSSL=false");
((MysqlDataSource)dataSource).setUser("root");
((MysqlDataSource)dataSource).setPassword("111111");
//2. 和数据库建立连接
Connection connection = dataSource.getConnection();
Scanner scanner = new Scanner(System.in);
System.out.println("请输入要修改学生的学号:");
int oldId = scanner.nextInt();
System.out.println("请输入修改值(学号):");
int newId = scanner.nextInt();
System.out.println("请输入修改值(姓名):");
String newName = scanner.next();
//3. 构造sql语句
String sql = "update student set id = ?, name = ? where id = ?";
PreparedStatement statement = connection.prepareStatement(sql);
statement.setInt(3, oldId);
statement.setInt(1, newId);
statement.setString(2, newName);
System.out.println("sql: "+statement);
//4. 执行sql
int ret = statement.executeUpdate();
System.out.println("ret= "+ret);
//5. 断开连接,关闭资源
statement.close();
connection.close();
执行结果:
7. JDBC删除操作
同样的, jdbc的删除代码和插入操作也是一样的, 只需要修改sql语句即可.
import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;
public class JdbcDeleteDemo
public static void main(String[] args) throws SQLException
//1. 创建数据源
DataSource dataSource = new MysqlDataSource();
((MysqlDataSource)dataSource).setUrl
("jdbc:mysql://127.0.0.1:3306/java_rong?characterEncoding=utf8&useSSL=false");
((MysqlDataSource)dataSource).setUser("root");
((MysqlDataSource)dataSource).setPassword("111111");
//2. 和数据库建立连接
Connection connection = dataSource.getConnection();
Scanner scanner = new Scanner(System.in);
System.out.println("请输入要删除记录的姓名:");
String name = scanner.next();
//3. 构造sql语句
String sql = "delete from student where name = ?";
PreparedStatement statement = connection.prepareStatement(sql);
statement.setString(1, name);
System.out.println("sql: "+statement);
//4. 执行sql
int ret = statement.executeUpdate();
System.out.println("ret= "+ret);
//5. 断开连接,关闭资源
statement.close();
connection.close();
执行结果:
8. JDBC查询操作
jdbc的查询操作与插入删除修改操作代码稍有不同, 执行查询sql语句的时候是调用executeQuery
方法来执行语句的, 并且会返回查询到的结果集(ResultSet对象
), 我们可以通过类似于迭代器的操作来获取查询到的数据, 最后ResultSet对象
使用完后需要进行资源释放.
import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class JdbcSelectDemo
public static void main(String[] args) throws SQLException
//1. 创建数据源
DataSource dataSource = new MysqlDataSource();
((MysqlDataSource)dataSource).setUrl
("jdbc:mysql://127.0.0.1:3306/java_rong?characterEncoding=utf8&useSSL=false");
((MysqlDataSource)dataSource).setUser("root");
((MysqlDataSource)dataSource).setPassword("111111");
//2. 和数据库建立连接
Connection connection = dataSource.getConnection();
//3. 构造sql
String sql = "select * from student";
PreparedStatement statement = connection.prepareStatement(sql);
//4. 执行获取结果集合
ResultSet resultSet = statement.executeQuery();
while (resultSet.next())
int id = resultSet.getInt("id");
String name = resultSet.getString("name");
System.out.println("id: "+id+" name: "+name);
//5. 断开连接,释放资源
resultSet.close();
statement.close();
connection.close();
执行结果:
四. 总结
1. 数据库连接Connection
Connection接口实现类由数据库提供,获取Connection对象通常有两种方式:
- 一种是通过
DriverManager
(驱动管理类) 的静态方法获取:
// 加载JDBC驱动程序
Class.forName("com.mysql.jdbc.Driver");
// 创建数据库连接
Connection connection = DriverManager.getConnection(url);
- 一种是通过
DataSource
(数据源) 对象获取, 即上面篇幅锁介绍的, 实际应用中会使用DataSource对象.
以上两种方式的区别是:
DriverManager
类来获取的Connection连接, 是无法重复利用的, 每次使用完以后释放资源时, 通过connection.close()都是关闭物理连接。DataSource
提供连接池的支持, 连接池在初始化时将创建一定数量的数据库连接, 这些连接是可以复用的, 每次使用完数据库连接, 释放资源调用connection.close()都是将Conncetion连接对象回收.
2. Statement对象
Statement
对象主要是将SQL语句发送到数据库中, JDBC API中主要提供了三种Statement对象.
实际开发中最常用的是PreparedStatement
对象
主要掌握两种执行SQL的方法:
executeQuery()
方法执行后返回单个结果集的,通常用于select
语句executeUpdate()
方法返回值是一个整数,指示受影响的行数,通常用于update
、insert
、delete
语句
3. ResultSet对象
ResultSet
对象它被称为结果集, 它代表符合SQL语句条件的所有行, 并且它通过一套getXXX
方法提供了对这些行中数据的访问.
ResultSet
里的数据一行一行排列, 每行有多个字段, 并且有一个记录指针, 指针所指的数据行叫做当前数据行, 我们只能来操作当前的数据行; 我们如果想要取得某一条记录, 就要使用ResultSet
的next()
方法, 如果我们想要得到ResultSet
里的所有记录, 就应该使用while
循环.
以上是关于基于JDBC的MySQL数据库编程的主要内容,如果未能解决你的问题,请参考以下文章
MySQL 数据库JDBC 编程之 Java 连接 MySQL