如何通过JDBC实现MySQL数据库的连接与测试？

如何通过JDBC连接MySQL数据库

准备工作

1、启动MySQL服务器：在Mac系统中，可以通过系统设置找到MySQL并点击打开服务，或通过命令行输入sudo /usr/local/mysql/supportfiles/mysql.server start来启动，其他操作系统的命令略有不同，可以在MySQL官网上找到。

2、创建测试表和数据：使用Navicat Premium或其他数据库管理工具，在事先创建好的数据库中执行以下SQL语句来创建一个表并插入数据：

 创建physicists表
CREATE TABLE physicists (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(255) NOT NULL,
    birthdate DATE,
    deathdate DATE,
    research VARCHAR(255)
);
 插入示例数据
INSERT INTO physicists (name, birthdate, deathdate, research)
VALUES ('Isaac Newton', '16430104', '17270331', 'Classical mechanics, gravitation'),
       ('Albert Einstein', '18790314', '19550418', 'Relativity, Quantum mechanics'),
       ('Marie Curie', '18671107', '19340704', 'Radioactivity');

JDBC连接步骤

1、导入必要的包：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;

2、注册JDBC驱动程序：

// 加载驱动类名
String driver = "com.mysql.cj.jdbc.Driver";
// 加载并注册JDBC驱动程序
Class.forName(driver);

3、打开连接：

// 声明Connection对象
Connection con;
// URL指向要访问的数据库名my_database
String url = "jdbc:mysql://localhost:3306/my_database";
// MySQL配置时的用户名
String user = "root";
// MySQL配置时的密码
String password = "zap200429";
// 获取与数据库的连接
con = DriverManager.getConnection(url, user, password);
// 检查是否连接成功
if (!con.isClosed()) {
    System.out.println("Succeeded connecting to the Database!");
}

4、执行查询并保存查询结果：

// 创建statement类对象，用来执行SQL语句
Statement stmt = con.createStatement();
// 执行查询并获取结果集
ResultSet rs = stmt.executeQuery("SELECT * FROM physicists");
// 遍历结果集并打印数据
while (rs.next()) {
    String name = rs.getString("name");
    Date birthdate = rs.getDate("birthdate");
    Date deathdate = rs.getDate("deathdate");
    String research = rs.getString("research");
    System.out.println(name + ", " + birthdate + ", " + deathdate + ", " + research);
}
// 关闭连接、释放资源
rs.close();
stmt.close();
con.close();

代码优化建议

1、使用PreparedStatement：为了防止SQL注入攻击，建议使用PreparedStatement来预编译SQL语句。

PreparedStatement pstmt = con.prepareStatement("INSERT INTO physicists (name, birthdate, deathdate, research) VALUES (?, ?, ?, ?)");
pstmt.setString(1, "Newton");
pstmt.setDate(2, new Date(System.currentTimeMillis()));
pstmt.setDate(3, new Date(System.currentTimeMillis()));
pstmt.setString(4, "Physics");
pstmt.executeUpdate();

2、异常处理：在实际应用中，应该添加适当的异常处理机制，以处理可能的SQLException等错误。

try {
    // 数据库操作代码
} catch (SQLException e) {
    e.printStackTrace();
} finally {
    // 关闭连接、释放资源
}

下面是一个使用JDBC连接MySQL数据库的测试表格，其中包含了必要的步骤和相应的代码示例。

在实际应用中，您可能需要处理异常和资源管理，例如使用trycatch块和trywithresources语句，以下是一个包含异常处理的完整示例：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class JdbcTest {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            // 加载JDBC驱动
            Class.forName("com.mysql.cj.jdbc.Driver");
            // 建立数据库连接
            String url = "jdbc:mysql://localhost:3306/数据库名?useSSL=false";
            String user = "用户名";
            String password = "密码";
            conn = DriverManager.getConnection(url, user, password);
            // 创建Statement
            stmt = conn.createStatement();
            // 执行SQL语句
            String sql = "SELECT * FROM 表名";
            rs = stmt.executeQuery(sql);
            // 处理结果
            while (rs.next()) {
                // 处理结果
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 关闭连接
            try {
                if (rs != null) {
                    rs.close();
                }
                if (stmt != null) {
                    stmt.close();
                }
                if (conn != null) {
                    conn.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}