MySQL 篇 - Java 连接 MySQL 数据库并实现数据交互

在现代应用中，数据库是不可或缺的一部分。Java 作为一种广泛使用的编程语言，提供了丰富的 API 来与各种数据库进行交互。本文将详细介绍如何在 Java 中连接 MySQL 数据库，并实现基本的数据交互功能。

一、环境准备

1.1 安装 MySQL

首先，确保你已经安装了 MySQL 数据库。可以通过 MySQL 官网下载并安装适合你操作系统的版本。

1.2 创建数据库和表

在安装完成后，登录 MySQL 命令行工具，创建一个名为 test_db 的数据库，并在其中创建一个名为 users 的表：

CREATE DATABASE test_db;USE test_db;CREATE TABLE users (id INT AUTO_INCREMENT PRIMARY KEY,username VARCHAR(50) NOT NULL,password VARCHAR(50) NOT NULL
);

1.3 添加 MySQL Connector/J 依赖

在 Java 项目中，你需要添加 MySQL Connector/J 作为依赖。如果你使用 Maven，可以在 pom.xml 中添加如下依赖：

<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.32</version> <!-- 请根据最新版本更新 -->
</dependency>

二、Java 代码实现

2.1 创建数据库连接

接下来，在 Java 代码中实现与 MySQL 数据库的连接。以下是一个简单的连接示例：

package com.example.demo;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;public class MySQLConnection {private static final String URL = "jdbc:mysql://localhost:3306/test_db"; // 数据库地址private static final String USER = "root"; // 数据库用户名private static final String PASSWORD = "your_password"; // 数据库密码public static Connection getConnection() {Connection connection = null;try {// 加载 JDBC 驱动Class.forName("com.mysql.cj.jdbc.Driver");// 获取数据库连接connection = DriverManager.getConnection(URL, USER, PASSWORD);System.out.println("数据库连接成功！");} catch (ClassNotFoundException e) {System.out.println("找不到 JDBC 驱动！" + e.getMessage());} catch (SQLException e) {System.out.println("数据库连接失败！" + e.getMessage());}return connection;}
}

2.2 插入数据

接下来，我们编写一个方法来插入用户数据到 users 表中：

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;public class UserDAO {public void addUser(String username, String password) {String sql = "INSERT INTO users (username, password) VALUES (?, ?)";try (Connection connection = MySQLConnection.getConnection();PreparedStatement preparedStatement = connection.prepareStatement(sql)) {preparedStatement.setString(1, username);preparedStatement.setString(2, password);int rowsAffected = preparedStatement.executeUpdate();System.out.println("成功插入 " + rowsAffected + " 行数据。");} catch (SQLException e) {System.out.println("插入数据失败！" + e.getMessage());}}
}

2.3 查询数据

下面是一个查询用户数据的方法：

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;public class UserDAO {// 其他代码...public void getAllUsers() {String sql = "SELECT * FROM users";try (Connection connection = MySQLConnection.getConnection();PreparedStatement preparedStatement = connection.prepareStatement(sql);ResultSet resultSet = preparedStatement.executeQuery()) {while (resultSet.next()) {int id = resultSet.getInt("id");String username = resultSet.getString("username");String password = resultSet.getString("password");System.out.println("用户ID: " + id + ", 用户名: " + username + ", 密码: " + password);}} catch (SQLException e) {System.out.println("查询数据失败！" + e.getMessage());}}
}

2.4 更新数据

更新用户信息的方法如下：

public class UserDAO {// 其他代码...public void updateUserPassword(int id, String newPassword) {String sql = "UPDATE users SET password = ? WHERE id = ?";try (Connection connection = MySQLConnection.getConnection();PreparedStatement preparedStatement = connection.prepareStatement(sql)) {preparedStatement.setString(1, newPassword);preparedStatement.setInt(2, id);int rowsAffected = preparedStatement.executeUpdate();System.out.println("成功更新 " + rowsAffected + " 行数据。");} catch (SQLException e) {System.out.println("更新数据失败！" + e.getMessage());}}
}

2.5 删除数据

删除用户数据的方法如下：

public class UserDAO {// 其他代码...public void deleteUser(int id) {String sql = "DELETE FROM users WHERE id = ?";try (Connection connection = MySQLConnection.getConnection();PreparedStatement preparedStatement = connection.prepareStatement(sql)) {preparedStatement.setInt(1, id);int rowsAffected = preparedStatement.executeUpdate();System.out.println("成功删除 " + rowsAffected + " 行数据。");} catch (SQLException e) {System.out.println("删除数据失败！" + e.getMessage());}}
}

三、测试代码

在主程序中测试上述功能，创建 Main 类并添加如下代码：

public class Main {public static void main(String[] args) {UserDAO userDAO = new UserDAO();// 插入用户userDAO.addUser("john_doe", "password123");// 查询用户userDAO.getAllUsers();// 更新用户密码userDAO.updateUserPassword(1, "new_password");// 查询用户userDAO.getAllUsers();// 删除用户userDAO.deleteUser(1);// 查询用户userDAO.getAllUsers();}
}