MySQL数据库 --- Java的JDBC编程

     阅读:29

Java的JDBC编程

1. 数据库编程的必备条件

  • 编程语言: 如Java, C、 C++、 Python等
  • 数据库: 如Oracle, MySQL, SQL Server等
  • 数据库驱动包: 不同的数据库,对应不同的编程语言提供了不同的数据库驱动包,
    如: MySQL提供了Java的驱动包mysql-connector-java,需要基于Java操作MySQL即需要该驱动包。同样的,要基于Java操作Oracle数据库则需要Oracle的数据库驱动包ojdbc。

2. MySQL驱动包的安装

  1. 首先浏览器搜索 https://mvnrepository.com

  2. 在输入框搜索 mysql jdbc
    在这里插入图片描述

  3. 找到下面这个并点进去
    在这里插入图片描述

  4. 选择对应自己 mysql 版本的 驱动程序
    在这里插入图片描述

  5. 选择一个 点进去下载
    在这里插入图片描述

3. idea 中 驱动包的部署

  1. 首先 在idea 的工程中,创建一个目录 ,然后把jar 包拷贝进去
    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述

  2. 打开idea 在 左上角 File -> Project Structure…
    在这里插入图片描述

  3. 点击Librarires -> + -> Java
    在这里插入图片描述

  4. 然后在选择libs目录 然后一路ok就可以了
    在这里插入图片描述

4. Java的数据库编程: JDBC

因为数据库的种类有很多,不同的数据库提供的API(application programming interface) 都不太一样.在Java中为了解决这个问题,引入了JDBC.

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

通过不同的数据库驱动程序把不同种类的 API 转换成 JDBC 风格的统一 API

在 Java 中 这样的驱动程序是一个独立的 jar包

JDBC优势:

  1. Java语言访问数据库操作完全面向抽象接口编程
  2. 开发数据库应用不用限定在特定数据库厂商的API
  3. 程序的可移植性大大增强

5. JDBC API

在Java JDBC编程中对数据库的操作均使用JDK自带的API统一处理,通常与特定数据库的驱动类是完全解耦的。 所以掌握Java JDBC API ( 位于 java.sql 包下) 即可掌握Java数据库编程。

6. JDBC常用接口和类

6.1 数据库连接Connection

Connection接口实现类由数据库提供,获取Connection对象通常有两种方式:
一种是通过DriverManager(驱动管理类)的静态方法获取:

// 加载JDBC驱动程序
Class.forName("com.mysql.jdbc.Driver");
// 创建数据库连接
Connection connection = DriverManager.getConnection(url);

一种是通过DataSource(数据源)对象获取。 实际应用中会使DataSource对象。

DataSource ds = new MysqlDataSource();
((MysqlDataSource) ds).setUrl("jdbc:mysql://localhost:3306/test");
((MysqlDataSource) ds).setUser("root");
((MysqlDataSource) ds).setPassword("root");
Connection connection = ds.getConnection();

以上两种方式的区别是:

  1. DriverManager类来获取的Connection连接,是无法重复利用的,每次使用完以后释放资源时,通过connection.close()都是关闭物理连接。
  2. DataSource提供连接池的支持。连接池在初始化时将创建一定数量的数据库连接,这些连接是可以复用的,每次使用完数据库连接,释放资源调用connection.close()都是将Conncetion连接对象回收

6.2 Statement对象

Statement对象主要是将SQL语句发送到数据库中。 JDBC API中主要提供了三种Statement对象(Statement,PreparedStatement,CallableStatement)。
在这里插入图片描述
主要掌握两种执行SQL的方法:

  • executeQuery()方法执行后返回单个结果集的,通常用于select语句
  • executeUpdate()方法返回值是一个整数,指示受影响的行数,通常用于update、 insert、 delete语句

6.3 ResultSet对象

ResultSet对象它被称为结果集,它代表符合SQL语句条件的所有行,并且它通过一套getXXX方法提供了对这些行中数据的访问。

ResultSet里的数据一行一行排列,每行有多个字段,并且有一个记录指针,指针所指的数据行叫做当前数据行,我们只能来操作当前的数据行。 我们如果想要取得某一条记录,就要使用ResultSetnext()方法 ,如果我们想要得到ResultSet里的所有记录,就应该使用while循环。

7. JDBC使用的注意事项

  1. URL的使用
    在这里插入图片描述
  2. 占位符 ?
    在这里插入图片描述
  3. 和数据库建立连接的 Connection
    在这里插入图片描述
  4. 关闭释放资源的顺序
    在这里插入图片描述
  5. ResultSet 对象的 遍历
    在这里插入图片描述

8. JDBC使用的具体操作

8.1 插入对应的JDBC的使用

操作步骤:

  1. 创建 DateSource 对象 (配置三方面信息 URL User Password)
  2. 和数据库建立连接Connection (处理SQLException异常)
  3. 拼装 SQL 语句,用到 PrepareStatement 对象
  4. 拼装完成后,执行 SQL 语句
  5. 执行完毕后,关闭释放相关资源(后创建先释放)

代码示例:

import com.mysql.cj.jdbc.MysqlDataSource;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class InsertJDBC {
    public static void main(String[] args) throws SQLException {
        // 1. 创建 DataSource 对象
        DataSource dataSource = new MysqlDataSource();
        // 需要针对dataSource 进行一些配置,以便后面能够顺利的访问到数据库服务器
        // 主要配置三方面信息: URL,User,Password 需要进行向下转型
        ((MysqlDataSource) dataSource).setURL("jdbc:mysql://127.0.0.1:3306/java20220310?characterEncoding=utf-8&useSSL=true&serverTimezone=UTC");
        ((MysqlDataSource) dataSource).setUser("root");
        ((MysqlDataSource) dataSource).setPassword("0000");

        // 2. 和数据库建立连接
        // 建立连接是为了验证当前网络通信是否正常
        // 如果不正常就会抛出 SQLException 异常
        // connection 对象生命周期应该是较短的.每个请求创建一个新的 connection.
        Connection connection = dataSource.getConnection();

        // 3. 拼装 SQL 语句,用到 PrepareStatement 对象
        String sql = "insert into student values(1,'曹操')";
        PreparedStatement statement = connection.prepareStatement(sql);
        System.out.println(" statement : "+statement);

        // 4. 拼装完成之后,可以执行 SQL 了
        // insert delete update 都使用 executeUpdate 方法来执行
        // select 就使用 executeQuery 来执行
        // 返回值表示此次操作修改了多少行
        int ret = statement.executeUpdate();
        System.out.println(" ret : "+ret);

        // 5. 执行完毕后,关闭释放相关资源
        // 一定是后创建的先释放
        statement.close();
        connection.close();
    }
}

8.2 删除对应的JDBC的使用

操作步骤:

  1. 创建 DataSource 对象(同样配置三方面信息)
  2. 创建数据库连接Connection
  3. 拼装 SQL 语句,用到 PrepareStatement 对象
  4. 拼装完成后,执行 SQL 语句
  5. 执行完毕后,关闭释放相关资源(后创建先释放)

代码实现:


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 DeleteJDBC {
    public static void main(String[] args) throws SQLException {
    	// 1. 创建 DataSource 对象
        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource) dataSource).setURL("jdbc:mysql://127.0.0.1:3306/java20220310?characterEncoding=utf-8&useSSL=true&serverTimezone=UTC");
        ((MysqlDataSource) dataSource).setUser("root");
        ((MysqlDataSource) dataSource).setPassword("0000");
		// 2. 创建数据库连接Connection
        Connection connection = dataSource.getConnection();
		// 3. 拼装 SQL 语句,用到 PrepareStatement 对象
        String sql = "delete from student where name = ?";
        System.out.println("请输入要删除的学生姓名: ");
        Scanner sc = new Scanner(System.in);
        String name = sc.nextLine();
		// 4. 拼装完成后,执行 SQL 语句
        PreparedStatement statement = connection.prepareStatement(sql);
        statement.setString(1,name);

        int ret = statement.executeUpdate();

        if(ret == 0) System.out.println("删除失败");
        else System.out.println("删除成功");
		// 5. 关闭释放资源
        statement.close();
        connection.close();
    }
}

8.3 修改对应的JDBC的使用

操作步骤:

  1. 创建 DataSource 对象(同样配置三方面信息)
  2. 创建数据库连接Connection
  3. 拼装 SQL 语句,用到 PrepareStatement 对象
  4. 拼装完成后,执行 SQL 语句
  5. 执行完毕后,关闭释放相关资源(后创建先释放)

代码实现:

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 UpdateJDBC {
    public static void main(String[] args) throws SQLException {
    	// 1. 创建 DataSource 对象
        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource) dataSource).setURL("jdbc:mysql://127.0.0.1:3306/java20220310?characterEncoding=utf-8&useSSL=true&serverTimezone=UTC");
        ((MysqlDataSource) dataSource).setUser("root");
        ((MysqlDataSource) dataSource).setPassword("0000");
		// 2. 连接数据库
        Connection connection = dataSource.getConnection();
		// 3. 拼接 SQL语句
        Scanner sc = new Scanner(System.in);
        System.out.println("请输入要修改的学生id: ");
        int id = sc.nextInt();
        System.out.println("请输入要修改的学生姓名: ");
        String name = sc.next();
        String sql = "update student set name = ? where id = ?";
        // 4. 执行 SQL 语句
        PreparedStatement statement = connection.prepareStatement(sql);
        statement.setString(1,name);
        statement.setInt(2,id);

        int ret = statement.executeUpdate();
        if(ret == 1) System.out.println("修改成功");
        else System.out.println("修改失败");
		// 5. 关闭释放资源
        statement.close();
        connection.close();
    }
}

8.4 查找对应的JDBC的使用

操作步骤:

  1. 创建 DataSource 对象 (同样处理三个方面信息)
  2. 创建 Connection 对象,和数据库建立连接
  3. 借助 PrepareStatement 拼接 SQL 语句
  4. 执行 SQL 语句
  5. 遍历结果集
  6. 关闭释放资源

代码实现:

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 SelectJDBC {
    public static void main(String[] args) throws SQLException {
        // 1. 创建 DataSource 对象
        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource) dataSource).setURL("jdbc:mysql://127.0.0.1:3306/java20220310?characterEncoding=utf-8&useSSL=true&serverTimezone=UTC");
        ((MysqlDataSource) dataSource).setUser("root");
        ((MysqlDataSource) dataSource).setPassword("0000");
        // 2. 创建 Connection 对象,和数据库建立连接
        Connection connection = dataSource.getConnection();
        // 3. 借助 PrepareStatement 拼接 SQL 语句
        String sql = "select * from student";
        PreparedStatement statement = connection.prepareStatement(sql);
        // 4. 执行 SQL 语句
        ResultSet resultSet = statement.executeQuery();
        // 5. 遍历结果集.
        while (resultSet.next()){
            int id = resultSet.getInt("id");
            String name = resultSet.getString("name");
            System.out.println("id: "+id+"name: "+name);
        }
        // 6. 关闭释放资源
        resultSet.close();
        statement.close();
        connection.close();
    }
}