Java JDBC连接MySQL数据库实现增删改查操作

简介

Java中的JDBC（Java Database Connectivity）是Java语言操作数据库的通用API，能够与各种关系型数据库进行交互。MySQL是一种流行的关系型数据库，在Java中使用JDBC连接MySQL数据库进行增删改查操作既方便又常用。

步骤

1. 准备工作

在使用JDBC连接MySQL之前，需要进行一些准备工作：

• 安装MySQL数据库（略）
• 下载MySQL JDBC驱动
• 导入MySQL JDBC驱动到项目中

以下为Maven项目中导入MySQL JDBC驱动的方式，也可以将其手动导入到项目中：

<!-- MySQL JDBC驱动 -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.26</version>
</dependency>

2. 连接MySQL数据库

连接MySQL数据库可以使用java.sql.Connection接口，该接口包含以下方法：

public interface Connection extends Wrapper, AutoCloseable {
    // 标准SQL查询语句 
    public Statement createStatement() throws SQLException;
    // 标准SQL查询语句，即可滚动的结果集 
    public Statement createStatement(int resultSetType, int resultSetConcurrency) throws SQLException;
    // 将标准SQL查询语句编译为可重用的语句 
    public PreparedStatement prepareStatement(String sql) throws SQLException;
    // 将标准SQL查询语句编译为可重用的语句，即可滚动的结果集 
    public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) throws SQLException;
    // 开启事务 
    public void setAutoCommit(boolean autoCommit) throws SQLException;
    // 提交事务 
    public void commit() throws SQLException;
    // 回滚事务 
    public void rollback() throws SQLException;
    // 关闭连接 
    public void close() throws SQLException;
}

下面是连接MySQL数据库的示例：

public class JdbcDemo {

    public static void main(String[] args) throws ClassNotFoundException, SQLException {

        // 注册MySQL数据库的驱动
        Class.forName("com.mysql.cj.jdbc.Driver");

        // 获取到连接MySQL的驱动
        String url = "jdbc:mysql://localhost:3306/example?serverTimezone=UTC";
        String username = "root";
        String password = "root123456";
        Connection conn = DriverManager.getConnection(url, username, password);

        System.out.println("已连接MySQL数据库");

        // ...
    }

}

3. 实现增、删、改、查操作

连接成功后，就可以使用JDBC API对MySQL数据库进行增、删、改、查操作。以下是操作MySQL数据库的示例：

public class JdbcDemo {

    public static void main(String[] args) throws ClassNotFoundException, SQLException {

        // 注册MySQL数据库的驱动
        Class.forName("com.mysql.cj.jdbc.Driver");

        // 获取到连接MySQL的驱动
        String url = "jdbc:mysql://localhost:3306/example?serverTimezone=UTC";
        String username = "root";
        String password = "root123456";
        Connection conn = DriverManager.getConnection(url, username, password);

        System.out.println("已连接MySQL数据库");

        // 实现增加数据
        String insertSql = "INSERT INTO user(username, password) VALUES (?, ?)";
        PreparedStatement ps = conn.prepareStatement(insertSql);
        ps.setString(1, "John");
        ps.setString(2, "123456");
        ps.executeUpdate();
        System.out.println("增加数据操作成功");

        // 实现删除数据
        String deleteSql = "DELETE FROM user WHERE username = ?";
        PreparedStatement ps1 = conn.prepareStatement(deleteSql);
        ps1.setString(1, "John");
        ps1.executeUpdate();
        System.out.println("删除数据操作成功");

        // 实现更新数据
        String updateSql = "UPDATE user SET password = ? WHERE username = ?";
        PreparedStatement ps2 = conn.prepareStatement(updateSql);
        ps2.setString(1, "654321");
        ps2.setString(2, "Lucy");
        ps2.executeUpdate();
        System.out.println("更新数据操作成功");

        // 实现查询数据
        String querySql = "SELECT * FROM user";
        Statement statement = conn.createStatement();
        ResultSet resultSet = statement.executeQuery(querySql);
        while (resultSet.next()) {
            int id = resultSet.getInt("id");
            String username1 = resultSet.getString("username");
            String password1 = resultSet.getString("password");
            System.out.println("id=" + id + ", username=" + username1 + ", password=" + password1);
        }

        //关闭连接
        conn.close();
    }

}

结束语

Java JDBC连接MySQL数据库实现增删改查操作是在Java语言中访问MySQL数据库的基础标准库之一，它提供了面向关系型数据的API和底层实现，封装了大量的访问底层的细节和异常，使开发者能够更加专注于SQL语句本身的实现。