如何使用JDBC连接并操作MySQL

Java数据库连接（JDBC）是Java语言用于和数据库进行交互的API。本文将详细介绍如何使用JDBC连接MySQL数据库，进行基本的增、删、改、查操作，使得初学者能够轻松上手。

1. 准备工作

在开始之前，你需要做一些准备工作：

• 下载MySQL：确保你的计算机上已安装MySQL数据库以及MySQL JDBC驱动。
• 配置环境：在Java项目中引入JDBC驱动的jar包，一般情况下，可以在Maven项目中通过如下依赖添加：

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.29</version> <!-- 请根据需要选择版本 -->
</dependency>

2. 基本的数据库配置

首先确保你有一个MySQL数据库以及用户可以连接到数据库。下面是一个简单的数据库和表的创建示例：

CREATE DATABASE mydatabase;
USE mydatabase;

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

3. 使用JDBC连接MySQL

以下是一个简单的JDBC连接MySQL的示例代码：

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

public class JDBCExample {
    private static final String URL = "jdbc:mysql://localhost:3306/mydatabase";
    private static final String USER = "yourusername"; // 替换为你的用户名
    private static final String PASSWORD = "yourpassword"; // 替换为你的密码

    public static void main(String[] args) {
        Connection connection = null;
        try {
            connection = DriverManager.getConnection(URL, USER, PASSWORD);
            if (connection != null) {
                System.out.println("成功连接到数据库！");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (connection != null) {
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

上述代码中，我们用DriverManager.getConnection() 方法建立了数据库连接。别忘了根据实际情况替换数据库的URL、用户名和密码。

4. 基本的CRUD操作

一旦成功连接到数据库，就可以进行基本的增、删、改、查操作。

4.1 插入数据

插入数据的示例代码如下：

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

public class InsertExample {
    public static void main(String[] args) {
        String URL = "jdbc:mysql://localhost:3306/mydatabase";
        String USER = "yourusername";
        String PASSWORD = "yourpassword";

        String sql = "INSERT INTO users (name, email) VALUES (?, ?)";

        try (Connection connection = DriverManager.getConnection(URL, USER, PASSWORD);
             PreparedStatement preparedStatement = connection.prepareStatement(sql)) {

            preparedStatement.setString(1, "John Doe");
            preparedStatement.setString(2, "john@example.com");
            preparedStatement.executeUpdate();
            System.out.println("数据插入成功！");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

4.2 查询数据

查询数据的示例代码如下：

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/mydatabase";
        String USER = "yourusername";
        String PASSWORD = "yourpassword";

        String sql = "SELECT * FROM users";

        try (Connection connection = DriverManager.getConnection(URL, USER, PASSWORD);
             Statement statement = connection.createStatement();
             ResultSet resultSet = statement.executeQuery(sql)) {

            while (resultSet.next()) {
                System.out.println("ID: " + resultSet.getInt("id") + ", Name: " + resultSet.getString("name") + ", Email: " + resultSet.getString("email"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

4.3 更新数据

更新数据的示例代码如下：

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

public class UpdateExample {
    public static void main(String[] args) {
        String URL = "jdbc:mysql://localhost:3306/mydatabase";
        String USER = "yourusername";
        String PASSWORD = "yourpassword";

        String sql = "UPDATE users SET email = ? WHERE name = ?";

        try (Connection connection = DriverManager.getConnection(URL, USER, PASSWORD);
             PreparedStatement preparedStatement = connection.prepareStatement(sql)) {

            preparedStatement.setString(1, "john.doe@example.com");
            preparedStatement.setString(2, "John Doe");
            preparedStatement.executeUpdate();
            System.out.println("数据更新成功！");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

4.4 删除数据

删除数据的示例代码如下：

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

public class DeleteExample {
    public static void main(String[] args) {
        String URL = "jdbc:mysql://localhost:3306/mydatabase";
        String USER = "yourusername";
        String PASSWORD = "yourpassword";

        String sql = "DELETE FROM users WHERE name = ?";

        try (Connection connection = DriverManager.getConnection(URL, USER, PASSWORD);
             PreparedStatement preparedStatement = connection.prepareStatement(sql)) {

            preparedStatement.setString(1, "John Doe");
            preparedStatement.executeUpdate();
            System.out.println("数据删除成功！");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

结语

通过本文的介绍，相信你已经对如何使用JDBC连接MySQL并进行基本的增、删、改、查操作有了一个清晰的认识。在实际项目中，可以根据需求进行代码的扩展及优化。希望你能在Java开发的道路上越走越远！