Java怎么使用jdbc连接实现对MySQL增删改查

发布时间：2023-03-07 15:51:14 作者：iii
来源：亿速云阅读：490

Java怎么使用JDBC连接实现对MySQL增删改查

引言

在Java开发中，数据库操作是非常常见的需求。MySQL作为一种流行的关系型数据库，广泛应用于各种项目中。Java通过JDBC（Java Database Connectivity）技术可以实现与MySQL数据库的连接和操作。本文将详细介绍如何使用JDBC连接MySQL数据库，并实现对数据库的增删改查（CRUD）操作。

JDBC简介

JDBC是Java语言中用于执行SQL语句的API，它提供了一种标准的方法来访问各种关系型数据库。通过JDBC，Java程序可以与数据库进行交互，执行SQL语句并处理结果。

JDBC的主要组件包括： - DriverManager：管理数据库驱动程序的加载和连接。 - Connection：表示与数据库的连接。 - Statement：用于执行SQL语句。 - ResultSet：表示SQL查询的结果集。

环境准备

在开始之前，我们需要准备以下环境： 1. Java开发环境：确保已经安装JDK并配置好环境变量。 2. MySQL数据库：安装MySQL数据库并启动服务。 3. MySQL JDBC驱动：下载并导入MySQL的JDBC驱动包（mysql-connector-java）。

下载MySQL JDBC驱动

可以从MySQL官方网站或Maven仓库下载mysql-connector-java驱动包。如果使用Maven管理项目依赖，可以在pom.xml中添加以下依赖：

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.26</version>
</dependency>

JDBC连接MySQL

在使用JDBC连接MySQL之前，需要确保MySQL服务已经启动，并且有一个可用的数据库和用户。

创建数据库和表

首先，在MySQL中创建一个数据库和表：

CREATE DATABASE testdb;
USE testdb;

CREATE TABLE users (
    id INT PRIMARY KEY AUTO_INCREMENT,
    name VARCHAR(50) NOT NULL,
    email VARCHAR(100) NOT NULL
);

编写Java代码连接MySQL

接下来，编写Java代码连接MySQL数据库：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class JDBCExample {
    public static void main(String[] args) {
        // 数据库连接信息
        String url = "jdbc:mysql://localhost:3306/testdb";
        String username = "root";
        String password = "password";

        // 加载JDBC驱动
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            return;
        }

        // 建立数据库连接
        try (Connection connection = DriverManager.getConnection(url, username, password)) {
            System.out.println("数据库连接成功！");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

代码解析

加载JDBC驱动：通过Class.forName("com.mysql.cj.jdbc.Driver")加载MySQL的JDBC驱动。
建立连接：使用DriverManager.getConnection(url, username, password)方法建立与数据库的连接。
关闭连接：使用try-with-resources语句自动关闭连接。

增删改查操作

插入数据

插入数据是数据库操作中最基本的操作之一。我们可以使用Statement或PreparedStatement来执行插入操作。

使用Statement插入数据

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class InsertExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/testdb";
        String username = "root";
        String password = "password";

        try (Connection connection = DriverManager.getConnection(url, username, password);
             Statement statement = connection.createStatement()) {

            String sql = "INSERT INTO users (name, email) VALUES ('John Doe', 'john.doe@example.com')";
            int rowsInserted = statement.executeUpdate(sql);
            System.out.println(rowsInserted + " 行数据插入成功！");

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

使用PreparedStatement插入数据

PreparedStatement可以防止SQL注入，并且性能更好。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class PreparedInsertExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/testdb";
        String username = "root";
        String password = "password";

        try (Connection connection = DriverManager.getConnection(url, username, password);
             PreparedStatement preparedStatement = connection.prepareStatement(
                     "INSERT INTO users (name, email) VALUES (?, ?)")) {

            preparedStatement.setString(1, "Jane Doe");
            preparedStatement.setString(2, "jane.doe@example.com");

            int rowsInserted = preparedStatement.executeUpdate();
            System.out.println(rowsInserted + " 行数据插入成功！");

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

查询数据

查询数据是数据库操作中最常见的操作之一。我们可以使用Statement或PreparedStatement来执行查询操作，并使用ResultSet来处理查询结果。

使用Statement查询数据

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

public class SelectExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/testdb";
        String username = "root";
        String password = "password";

        try (Connection connection = DriverManager.getConnection(url, username, password);
             Statement statement = connection.createStatement()) {

            String sql = "SELECT * FROM users";
            ResultSet resultSet = statement.executeQuery(sql);

            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                String email = resultSet.getString("email");

                System.out.println("ID: " + id + ", Name: " + name + ", Email: " + email);
            }

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

使用PreparedStatement查询数据

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class PreparedSelectExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/testdb";
        String username = "root";
        String password = "password";

        try (Connection connection = DriverManager.getConnection(url, username, password);
             PreparedStatement preparedStatement = connection.prepareStatement(
                     "SELECT * FROM users WHERE id = ?")) {

            preparedStatement.setInt(1, 1);
            ResultSet resultSet = preparedStatement.executeQuery();

            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                String email = resultSet.getString("email");

                System.out.println("ID: " + id + ", Name: " + name + ", Email: " + email);
            }

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

更新数据

更新数据是数据库操作中常见的操作之一。我们可以使用Statement或PreparedStatement来执行更新操作。

使用Statement更新数据

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class UpdateExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/testdb";
        String username = "root";
        String password = "password";

        try (Connection connection = DriverManager.getConnection(url, username, password);
             Statement statement = connection.createStatement()) {

            String sql = "UPDATE users SET email = 'john.doe.new@example.com' WHERE id = 1";
            int rowsUpdated = statement.executeUpdate(sql);
            System.out.println(rowsUpdated + " 行数据更新成功！");

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

使用PreparedStatement更新数据

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class PreparedUpdateExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/testdb";
        String username = "root";
        String password = "password";

        try (Connection connection = DriverManager.getConnection(url, username, password);
             PreparedStatement preparedStatement = connection.prepareStatement(
                     "UPDATE users SET email = ? WHERE id = ?")) {

            preparedStatement.setString(1, "jane.doe.new@example.com");
            preparedStatement.setInt(2, 2);

            int rowsUpdated = preparedStatement.executeUpdate();
            System.out.println(rowsUpdated + " 行数据更新成功！");

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

删除数据

删除数据是数据库操作中常见的操作之一。我们可以使用Statement或PreparedStatement来执行删除操作。

使用Statement删除数据

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class DeleteExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/testdb";
        String username = "root";
        String password = "password";

        try (Connection connection = DriverManager.getConnection(url, username, password);
             Statement statement = connection.createStatement()) {

            String sql = "DELETE FROM users WHERE id = 1";
            int rowsDeleted = statement.executeUpdate(sql);
            System.out.println(rowsDeleted + " 行数据删除成功！");

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

使用PreparedStatement删除数据

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class PreparedDeleteExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/testdb";
        String username = "root";
        String password = "password";

        try (Connection connection = DriverManager.getConnection(url, username, password);
             PreparedStatement preparedStatement = connection.prepareStatement(
                     "DELETE FROM users WHERE id = ?")) {

            preparedStatement.setInt(1, 2);

            int rowsDeleted = preparedStatement.executeUpdate();
            System.out.println(rowsDeleted + " 行数据删除成功！");

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

事务管理

在数据库操作中，事务管理是非常重要的。事务可以确保一组操作要么全部成功，要么全部失败。JDBC提供了事务管理功能，可以通过Connection对象的setAutoCommit、commit和rollback方法来管理事务。

事务管理示例

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class TransactionExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/testdb";
        String username = "root";
        String password = "password";

        Connection connection = null;
        try {
            connection = DriverManager.getConnection(url, username, password);
            connection.setAutoCommit(false); // 关闭自动提交

            // 插入数据
            try (PreparedStatement preparedStatement = connection.prepareStatement(
                    "INSERT INTO users (name, email) VALUES (?, ?)")) {

                preparedStatement.setString(1, "Alice");
                preparedStatement.setString(2, "alice@example.com");
                preparedStatement.executeUpdate();

                // 模拟异常
                if (true) {
                    throw new SQLException("模拟异常");
                }

                preparedStatement.setString(1, "Bob");
                preparedStatement.setString(2, "bob@example.com");
                preparedStatement.executeUpdate();
            }

            connection.commit(); // 提交事务
            System.out.println("事务提交成功！");

        } catch (SQLException e) {
            e.printStackTrace();
            if (connection != null) {
                try {
                    connection.rollback(); // 回滚事务
                    System.out.println("事务回滚成功！");
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
        } finally {
            if (connection != null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

代码解析

关闭自动提交：通过connection.setAutoCommit(false)关闭自动提交，开启事务。
提交事务：在事务中的所有操作成功后，调用connection.commit()提交事务。
回滚事务：如果事务中的任何操作失败，调用connection.rollback()回滚事务。

连接池

在高并发场景下，频繁地创建和关闭数据库连接会导致性能问题。连接池技术可以有效地管理数据库连接，提高系统性能。

使用HikariCP连接池

HikariCP是一个高性能的JDBC连接池，广泛应用于Java项目中。

添加HikariCP依赖

在pom.xml中添加HikariCP依赖：

<dependency>
    <groupId>com.zaxxer</groupId>
    <artifactId>HikariCP</artifactId>
    <version>5.0.1</version>
</dependency>

配置HikariCP连接池

import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;

import java.sql.Connection;
import java.sql.SQLException;

public class HikariCPExample {
    public static void main(String[] args) {
        HikariConfig config = new HikariConfig();
        config.setJdbcUrl("jdbc:mysql://localhost:3306/testdb");
        config.setUsername("root");
        config.setPassword("password");
        config.setMaximumPoolSize(10);

        HikariDataSource dataSource = new HikariDataSource(config);

        try (Connection connection = dataSource.getConnection()) {
            System.out.println("数据库连接成功！");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

代码解析

配置连接池：通过HikariConfig配置连接池的参数，如数据库URL、用户名、密码和最大连接数。
获取连接：通过HikariDataSource获取数据库连接。

异常处理

在数据库操作中，异常处理是非常重要的。JDBC操作可能会抛出SQLException，我们需要捕获并处理这些异常。

异常处理示例

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class ExceptionHandlingExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/testdb";
        String username = "root";
        String password = "password";

        try (Connection connection = DriverManager.getConnection(url, username, password)) {
            System.out.println("数据库连接成功！");
        } catch (SQLException e) {
            System.err.println("数据库连接失败：" + e.getMessage());
            e.printStackTrace();
        }
    }
}

代码解析

捕获异常：使用try-catch块捕获SQLException。
处理异常：在catch块中处理异常，如打印错误信息或记录日志。

性能优化

在数据库操作中，性能优化是非常重要的。以下是一些常见的性能优化技巧：

使用连接池：连接池可以有效地管理数据库连接，减少连接创建和关闭的开销。
使用PreparedStatement：PreparedStatement可以防止SQL注入，并且性能更好。
批量操作：对于大量数据的插入、更新和删除操作，可以使用批量操作来提高性能。
索引优化：在数据库表中创建合适的索引，可以加快查询速度。
减少数据库交互：尽量减少与数据库的交互次数，如使用JOIN查询代替多次查询。

批量操作示例

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class BatchExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/testdb";
        String username = "root";
        String password = "password";

        try (Connection connection = DriverManager.getConnection(url, username, password);
             PreparedStatement preparedStatement = connection.prepareStatement(
                     "INSERT INTO users (name, email) VALUES (?, ?)")) {

            for (int i = 1; i <= 1000; i++) {
                preparedStatement.setString(1, "User" + i);
                preparedStatement.setString(2, "user" + i + "@example.com");
                preparedStatement.addBatch();
            }

            int[] rowsInserted = preparedStatement.executeBatch();
            System.out.println(rowsInserted.length + " 行数据插入成功！");

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

代码解析

批量操作：通过preparedStatement.addBatch()将多个操作添加到批量中。
执行批量操作：通过preparedStatement.executeBatch()执行批量操作。

总结

本文详细介绍了如何使用JDBC连接MySQL数据库，并实现对数据库的增删改查操作。我们还讨论了事务管理、连接

Java怎么使用jdbc连接实现对MySQL增删改查

Java怎么使用JDBC连接实现对MySQL增删改查

目录

引言

JDBC简介

环境准备

下载MySQL JDBC驱动

JDBC连接MySQL

创建数据库和表

编写Java代码连接MySQL

代码解析

增删改查操作

插入数据

使用Statement插入数据

使用PreparedStatement插入数据

查询数据

使用Statement查询数据

使用PreparedStatement查询数据

更新数据

使用Statement更新数据

使用PreparedStatement更新数据

删除数据

使用Statement删除数据

使用PreparedStatement删除数据

事务管理

事务管理示例

代码解析

连接池

使用HikariCP连接池

添加HikariCP依赖

配置HikariCP连接池

代码解析

异常处理

异常处理示例

代码解析

性能优化

批量操作示例

代码解析

总结

相关阅读