MySQL_JDBC

一、JDBC常用的接口和类

1.1 数据库连接 Connection

1.2 Statement 对象

二、JDBC的使用

总结

【Java 的数据库编程】

JDBC 即 Java Database Connectivity (Java数据库连接)，是一种用于执行 SQL 语句的 Java API。这个 API 由 java.sql.*,javax.sql.* 包中的一些类和接口组成，它为 Java 开发人员操作数据库提供了一个标准的API，可以为多种关系数据库提供统一访问。

一、JDBC常用的接口和类

1.1 数据库连接 Connection

Connection 接口实现类由数据库提供，获取 Connection 对象通常有两种方式：

1、通过 DriverManager (驱动管理类) 的静态方法获取：

// 加载JDBC驱动程序

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

// 创建数据库连接

Connection connection = DriverManager.getConnection(url);

2、通过 DataSource (数据源) 对象获取。(实际应用中使用数据源)

【MySQL 数据连接的URL参数格式】

jdbc:mysql://服务器地址:端口/数据库名?参数名=参数值

//创建数据源

DataSource dataSource = new MysqlDataSource();

((MysqlDataSource)dataSource).setUrl("URL"); //路径

((MysqlDataSource)dataSource).setUser("root"); //用户名

((MysqlDataSource)dataSource).setPassword("123456"); //密码

【二者区别】

1、DriverManager 类来获取的 Connection 连接，是无法重复利用的，每次使用完以后释放资源时，通过 connection.close() 都是关闭物理连接。

2、DataSource 提供连接池的支持。连接池在初始化时将创建一定数量的数据库连接，这些连接是可以复用的，每次使用完数据库连接，释放资源调用 connection.close() 都是将 Conncetion 连接对象回收。

1.2 Statement 对象

Statement 对象主要是将 SQL 语句发送到数据库服务器中。

JDBC API 中主要提供了三种 Statement 对象：

1、Statement：用于执行不带参数的简单 SQL 语句。

2、PreparedStatement：

① 用于执行不带参数的简单 SQL 语句。

② 在客户端中提前解析好 SQL 语句再发给服务器，可以大幅降低服务器解析的开销。

③ 占位符 "?" 不能使用多值。

④ 占位符 "?" 下标从 1 开始。

⑤ 阻止常见 SQL 注入攻击。

⑥ 执行速度快于 Statement 对象。

3、CallableStatement：用于执行数据库存储过程的调用。

【执行 SQL 的方法】

1、executeQuery() 方法：通常用于查询操作，该方法执行后返回单个结果集；

2、executeUpdate() 方法：通常用于增删改操作，其返回值为整型，代表这个 sql 操作影响到了表中的几行数据。

二、JDBC的使用

【前置操作】

1、创建项目，引入 mysql 的 JDBC 驱动包。

2、将 jar 包导入项目中。

在项目中创建一个目录，将 jar 包拷贝进去，右键新目录并 add as library。

【正式操作】

（1）创建数据源。(数据源描述了数据库的位置)

    //创建数据源 (向上转型)DataSource dataSource = new MysqlDataSource();//路径((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&useSSL=false");//用户名((MysqlDataSource)dataSource).setUser("root");//密码((MysqlDataSource)dataSource).setPassword("123456");

注：数据库是服务器，有可能在本主机上，也可能在其他主机上。

（2）和数据库服务器建立连接。

建立连接时，Connection 接口需是 java.sql 包下的，否则会报错。

    //创建数据库连接Connection connection = dataSource.getConnection();

（3）构造一个 sql 语句，并将其转换成语句对象。

    //3、构造一个 sqlString sql = "insert into student values(1,'moon')";//需要把 sql 转换成语句对象PreparedStatement statement = connection.prepareStatement(sql);

（4）把构造好的 sql 发送给服务器去执行。

    //4、把构造好的 sql 发送给服务器去执行int n = statement.executeUpdate();System.out.println("n = " + n);

（5）释放资源。

当我们用到的资源不会自动释放，此时我们就需要手动释放，否则该资源无法被再次利用。而释放资源顺序与创建顺序相反。

    //5、释放资源statement.close();connection.close();

【JDBC 插入操作案例】

import com.mysql.cj.jdbc.MysqlDataSource;import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;public class JdbcInsert {public static void main(String[] args) throws SQLException {Scanner sc = new Scanner(System.in);System.out.println("请输入id：");int id = sc.nextInt();System.out.println("请输入name：");String name = sc.next();//1、创建数据源//通过 ip + 端口号 + 数据库名 来定位数据库DataSource dataSource = new MysqlDataSource();((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&useSSL=false");((MysqlDataSource)dataSource).setUser("root");((MysqlDataSource)dataSource).setPassword("wyy.2003");//2、和数据库服务器建立连接Connection connection = dataSource.getConnection();//3、构造一个 sqlString sql = "insert into student values(?,?)"; // ? 是占位符//需要把 sql 转换成语句对象PreparedStatement statement = connection.prepareStatement(sql);statement.setInt(1, id);statement.setString(2, name);//4、把构造好的 sql 发送给服务器去执行int n = statement.executeUpdate();System.out.println("n = " + n);//5、释放资源statement.close();connection.close();}
}

注：修改、删除操作与插入操作类似。

【JDBC 查询操作案例】

import com.mysql.cj.jdbc.MysqlDataSource;import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;public class JdbcSelect {public static void main(String[] args) throws SQLException {//1、创建数据源DataSource dataSource = new MysqlDataSource();((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf8&useSSL=false");((MysqlDataSource)dataSource).setUser("root");((MysqlDataSource)dataSource).setPassword("wyy.2003");//2、建立连接Connection connection = dataSource.getConnection();//3、构造 sqlString sql = "select * from student";PreparedStatement statement = connection.prepareStatement(sql);//4、执行 sql//ResultSet 即结果集合ResultSet resultSet = statement.executeQuery();//遍历 resultSet 每行数据while (resultSet.next()) {//获取 id 列的数据int id = resultSet.getInt("id");//获取 name 列的数据String name = resultSet.getString("name");System.out.println("id: " + id);System.out.println("name: " + name);}//5、释放资源resultSet.close();statement.close();connection.close();}
}

【关键点总结】