MySQL_JDBC

news2024/9/23 6:26:59

一、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、构造一个 sql
    String 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、构造一个 sql
        String 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、构造 sql
        String 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();
    }
}

【关键点总结】