 //1. 加载数据库厂商提供的驱动
 //通过完全限定名记载指定的类到JVM
 Class.forName("com.mysql.cj.jdbc.Driver");
 //2. 获取数据库连接（物理连接）
 connection = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test2?characterEncoding=utf8&" +
                    "allowPublicKeyRetrieval=true&useSSL=false", "root", "111111");

2.1.2 DataSource对象获取

通过数据源DataSource对象获取，一个连接可以执行很多SQL，直到关闭数据源。

这种方式是通过一个连接池去管理很多个连接，当需要SQL执行时，就从连接池里拿出一个连接，用完后返还给连接池。

推荐在实际开发中使用这种方式。

        //1. 定义MySQL数据源对象（连接池）
        MysqlDataSource mysqlDataSource = new MysqlDataSource();
        //2. 设置数据库连接串
        mysqlDataSource.setURL("jdbc:mysql://127.0.0.1:3306/test2?characterEncoding=utf8" +
                "&allowPublicKeyRetrieval=true&useSSL=false");
        //用户
        mysqlDataSource.setUser("root");
        //密码
        mysqlDataSource.setPassword("111111");

        //定义JDBC的数据源对象
        DataSource dataSource = mysqlDataSource;

        //1. 通过数据源获得数据库连接对象
        connection = dataSource.getConnection();

2.2 获取SQL执行对象

2.2.1 SQL注入

SQL注入即是指web应用程序对用户输入数据的合法性没有判断或过滤不严，攻击者可以在web应用程序中事先定义好的查询语句的结尾上添加额外的SQL语句，在管理员不知情的情况下实现非法操作，以此来实现欺骗数据库服务器执行非授权的任意查询，从而进一步得到相应的数据信息。

2.2.2 Statement(执行静态SQL)

Statement是用于执行静态SQL语句并返回执行结果的对象

注意：该方式存在SQL注入的安全问题！！！

如下图：该方式是通过字符串拼接的方式组装完成的SQL语句，字符串拼接形式构造SQL语句时，如果不处理参数中的特殊字符就会造成SQL注入，这是⼀个非常严重的安全性问题。

//定义Statement 
Statement statement = null;
//3. 创建Statement对象
statement = connection.createStatement();
//4. 定义SQL并执行SQL语句
Scanner scanner = new Scanner(System.in);
System.out.println("请输入要查询的学生的姓名：");
//接收用户输入
String name = scanner.next();
String sql = "select student_id, sn, name, mail, class_id from student where name = '" + name + "'";
//5. 执行SQL并获取查询结果
resultSet = statement.executeQuery(sql);

2.2.3 PreparedStatement(预处理的SQL执行对象)

预编译SQL语句对象，SQL语句被预编译并存储在PreparedStatement对象中，可以使用该对象多次执行SQL语句，同时可以解决SQL注入问题。

动态参数用占位符 ? 表示。

简单以上文SQL注入的输入为例，该方式直接将用户输入的内容全部当做name的值（利用占位符），直接在数据表中通过输入值来查找相应记录。

注意：使用真实值替换占位符时，使用setString/setLong/....方法，编号从1开始，有多少个参数就设置多少个值。

            //定义要执行的SQL
            String sql = "select student_id, sn, name, mail, class_id from student where name = ?";
            Scanner scanner = new Scanner(System.in);
            //2. 获取预处理SQL执行对象
            statement = connection.prepareStatement(sql);
            //接收用户输入
            System.out.println("请输入要查询的学生的姓名：");
            String name = scanner.next();
            //3. 用真实值替换占位符
            statement.setString(1, name);

2.3 执行SQL并返回结果

执行select语句，返回结果集（ResultSet结果集接收）：

//定义结果集对象
ResultSet resultSet = null; 
//4. 执行SQL，获取结果集对象
resultSet = statement.executeQuery();
//迭代打印结果集
//最初游标位于第⼀⾏之前，调⽤next⽅法将游标移动到下⼀⾏，
//当ResultSet中没有更多的数据⾏时返回false
while (resultSet.next()) {
    long stuId = resultSet.getLong(1);
    String stuSn = resultSet.getString(2);
    String stuName = resultSet.getString(3);
    String stuMail = resultSet.getString(4);
    long stuClassId = resultSet.getLong(5);
    System.out.println(MessageFormat.format("学生编号={0}, 学号={1}, 姓名={2}, 邮箱={3}, 班级编号={4}",
            stuId, stuSn, stuName, stuMail, stuClassId));
}

执行update、delete、insert操作，返回所影响的行数：

int row = statement.executeUpdate();

2.4 关闭连接，释放资源

自下而上，依次关闭。

// 依次释放资源，关闭连接
            if (resultSet != null) {
                try {
                    resultSet.close();
                } catch (SQLException e) {
                    throw new RuntimeException(e);
                }
            }
            if (statement != null) {
                try {
                    statement.close();
                } catch (SQLException e) {
                    throw new RuntimeException(e);
                }
            }
            if (connection != null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    throw new RuntimeException(e);
                }
            }

3、示例

封装数据库连接、资源关闭方法：

package org.example.utils;

import com.mysql.cj.jdbc.MysqlDataSource;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/**
 * Created with IntelliJ IDEA.
 * Description:封装方法
 * User: dings
 * Date: 2024-09-21
 * Time: 14:53
 */
public class DBUtils {
    private static DataSource dataSource = null;
    private static MysqlDataSource mysqlDataSource = new MysqlDataSource();
    private static String URL = "jdbc:mysql://127.0.0.1:3306/test2?characterEncoding=utf8&allowPublicKeyRetrieval=true&useSSL=false";
    private static String USER = "root";
    private static String PASSWORD = "111111";


    private DBUtils() {}//构造方法私有化

    static {
        mysqlDataSource.setURL(URL);
        mysqlDataSource.setUser(USER);
        mysqlDataSource.setPassword(PASSWORD);
        dataSource = mysqlDataSource;
    }
    public static Connection getConnection() throws SQLException {
        return dataSource.getConnection();
    }
    public static void close(ResultSet resultSet, Statement statement, Connection connection) {
        if (resultSet != null) {
            try {
                resultSet.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
        if (statement != null) {
            try {
                statement.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
        if (connection != null) {
            try {
                connection.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
    }
}

实现记录的插入：

package org.example;

import org.example.utils.DBUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;

/**
 * Created with IntelliJ IDEA.
 * Description:向表中插入记录
 * User: dings
 * Date: 2024-09-21
 * Time: 15:06
 */
public class Demo03_insert {
    public static void main(String[] args) {
        Connection connection = null;
        PreparedStatement statement = null;
        try {
            connection = DBUtils.getConnection();
            String sql = "insert into student (sn, name, mail, class_id) values (?,?,?,?)";
            statement = connection.prepareStatement(sql);
            Scanner scanner = new Scanner(System.in);

            System.out.println("请输入学号：");
            String sn = scanner.next();

            System.out.println("请输入姓名：");
            String name = scanner.next();

            System.out.println("请输入邮箱：");
            String mail = scanner.next();

            System.out.println("请输入班级编号：");
            Long classId = Long.valueOf(scanner.next());

            //编号从1开始
            statement.setString(1, sn);
            statement.setString(2, name);
            statement.setString(3, mail);
            statement.setLong(4, classId);

            int row = statement.executeUpdate();
            if(row == 1) {
                System.out.println("插入成功！");
            }else {
                System.out.println("插入失败！");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            // 释放资源,关闭连接
            DBUtils.close(null, statement, connection);
        }
    }
}

END