一、环境准备

1、安装MySQL

确保你已经安装了MySQL数据库，可以通过MySQL官网下载并安装适合你操作系统的版本，安装完成后，登录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
);

2、添加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代码实现

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、插入数据

编写一个方法来插入用户数据到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());
        }
    }
}

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()) {
                System.out.println("ID: " + resultSet.getInt("id"));
                System.out.println("Username: " + resultSet.getString("username"));
                System.out.println("Password: " + resultSet.getString("password"));
            }
        } catch (SQLException e) {
            System.out.println("查询数据失败！" + e.getMessage());
        }
    }
}

4、更新数据

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

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());
    }
}

5、删除数据

删除用户的方法如下：

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());
    }
}

通过以上步骤，你可以在Java应用程序中实现对MySQL数据库的基本操作，包括插入、查询、更新和删除数据，这些操作是构建任何基于数据库的应用程序的基础。