java连接mysql四六级数据库实现增删查改

下面是一个简单的 Java 程序，用于连接 MySQL 四六级数据库，并实现增删查改操作。

1. 导入相关包

首先需要导入 MySQL JDBC 驱动包，以及 Java SQL 包。

import java.sql.*;

2. 连接数据库

使用 `DriverManager` 类的 `getConnection()` 方法连接数据库，并返回一个 `Connection` 对象。

String url = "jdbc:mysql://localhost:3306/cet46?useSSL=false&serverTimezone=UTC";
String user = "root";
String password = "123456";

Connection conn = DriverManager.getConnection(url, user, password);

3. 添加数据

使用 `PreparedStatement` 类的 `executeUpdate()` 方法添加数据。

String sql = "INSERT INTO cet46(name, score) VALUES (?, ?)";

PreparedStatement pstmt = conn.prepareStatement(sql);

pstmt.setString(1, "张三");
pstmt.setInt(2, 530);

int result = pstmt.executeUpdate();

if (result > 0) {
    System.out.println("添加成功！");
} else {
    System.out.println("添加失败！");
}

4. 删除数据

使用 `PreparedStatement` 类的 `executeUpdate()` 方法删除数据。

String sql = "DELETE FROM cet46 WHERE id = ?";

PreparedStatement pstmt = conn.prepareStatement(sql);

pstmt.setInt(1, 1);

int result = pstmt.executeUpdate();

if (result > 0) {
    System.out.println("删除成功！");
} else {
    System.out.println("删除失败！");
}

5. 修改数据

使用 `PreparedStatement` 类的 `executeUpdate()` 方法修改数据。

String sql = "UPDATE cet46 SET score = ? WHERE id = ?";

PreparedStatement pstmt = conn.prepareStatement(sql);

pstmt.setInt(1, 550);
pstmt.setInt(2, 2);

int result = pstmt.executeUpdate();

if (result > 0) {
    System.out.println("修改成功！");
} else {
    System.out.println("修改失败！");
}

6. 查询数据

使用 `Statement` 类的 `executeQuery()` 方法查询数据，并将结果集封装到一个 `ResultSet` 对象中。

String sql = "SELECT * FROM cet46";

Statement stmt = conn.createStatement();

ResultSet rs = stmt.executeQuery(sql);

while (rs.next()) {
    int id = rs.getInt("id");
    String name = rs.getString("name");
    int score = rs.getInt("score");

    System.out.println(id + "\t" + name + "\t" + score);
}

7. 关闭连接

使用 `Connection` 对象的 `close()` 方法关闭连接。

conn.close();

完整代码如下：

import java.sql.*;

public class CET46 {
    public static void main(String[] args) throws SQLException {
        String url = "jdbc:mysql://localhost:3306/cet46?useSSL=false&serverTimezone=UTC";
        String user = "root";
        String password = "123456";

        Connection conn = DriverManager.getConnection(url, user, password);

        // 添加数据
        String sql = "INSERT INTO cet46(name, score) VALUES (?, ?)";

        PreparedStatement pstmt = conn.prepareStatement(sql);

        pstmt.setString(1, "张三");
        pstmt.setInt(2, 530);

        int result = pstmt.executeUpdate();

        if (result > 0) {
            System.out.println("添加成功！");
        } else {
            System.out.println("添加失败！");
        }

        // 删除数据
        sql = "DELETE FROM cet46 WHERE id = ?";

        pstmt = conn.prepareStatement(sql);

        pstmt.setInt(1, 1);

        result = pstmt.executeUpdate();

        if (result > 0) {
            System.out.println("删除成功！");
        } else {
            System.out.println("删除失败！");
        }

        // 修改数据
        sql = "UPDATE cet46 SET score = ? WHERE id = ?";

        pstmt = conn.prepareStatement(sql);

        pstmt.setInt(1, 550);
        pstmt.setInt(2, 2);

        result = pstmt.executeUpdate();

        if (result > 0) {
            System.out.println("修改成功！");
        } else {
            System.out.println("修改失败！");
        }

        // 查询数据
        sql = "SELECT * FROM cet46";

        Statement stmt = conn.createStatement();

        ResultSet rs = stmt.executeQuery(sql);

        while (rs.next()) {
            int id = rs.getInt("id");
            String name = rs.getString("name");
            int score = rs.getInt("score");

            System.out.println(id + "\t" + name + "\t" + score);
        }

        conn.close();
    }
}