Java连接MySQL数据库并实现数据交互功能

更新时间：2024年10月25日 11:16:30 作者：一只蜗牛儿

在现代应用中,数据库是不可或缺的一部分,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();
    }
}

四、总结

通过本文的介绍，你已经学会了如何在 Java 中连接 MySQL 数据库并实现数据交互。主要内容包括：

数据库连接：使用 JDBC 连接 MySQL 数据库。
数据操作：实现插入、查询、更新和删除（CRUD）操作。
最佳实践：使用 PreparedStatement 避免 SQL 注入。

在实际应用中，建议使用连接池（如 HikariCP 或 DBCP）来提高性能和资源利用率。同时，可以考虑使用 ORM 框架（如 Hibernate 或 MyBatis）来简化数据库操作，提高开发效率。希望本文能帮助你快速上手 Java 与 MySQL 的数据交互！

以上就是Java连接MySQL数据库并实现数据交互功能的详细内容，更多关于Java连接MySQL数据交互的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

Java 数组复制clone方法实现详解
这篇文章主要介绍了Java 数组复制clone方法实现详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2019-11-11
SpringDataJpa的使用之一对一、一对多、多对多关系映射问题
这篇文章主要介绍了SpringDataJpa的使用 -- 一对一、一对多、多对多关系映射,本文主要讲述 @OneToOne、@OneToMany、@ManyToOne、@ManyToMany 这四个关系映射注解的使用，以及其对应的级联关系，需要的朋友可以参考下
2022-07-07
Java分布式锁、分布式ID和分布式事务的实现方案
在分布式系统中，分布式锁、分布式ID和分布式事务是常用的组件，用于解决并发控制、唯一标识和数据一致性的问题，本文将介绍Java中常用的分布式锁、分布式ID和分布式事务的实现方案，并通过具体的示例代码演示它们的用法和应用场景
2023-06-06
JavaGUI实现随机单词答题游戏
这篇文章主要为大家详细介绍了JavaGUI实现随机单词答题游戏，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2020-12-12
浅析fastjson2时间序列化和反序列化的简单使用
在项目中将fastjson升级为fastjson2后,我们遇到了一些与fastjson不完全兼容的问题,所以本文就来探讨下fastjson2的时间序列化和反序列化的简单使用吧
2025-01-01
Java中处理邮件附件的方法(本地文件和在线URL)
这篇文章主要介绍了在Java中处理邮件附件的方法,针对本地文件和在线URL两种附件来源,提供了两种解决方案,并提供了下载文件和发送邮件的代码示例,需要的朋友可以参考下
2025-03-03
java实现同步的几种方式(示例详解)
这篇文章主要介绍了java实现同步的几种方式,本文通过实例代码给大家介绍的非常详细,感兴趣的朋友一起看看吧
2024-12-12
Java基础详解之面向对象的那些事儿
这篇文章主要介绍了Java基础之面向对象那些事儿,文中有非常详细的代码示例,对正在学习java基础的小伙伴们有很好的帮助,需要的朋友可以参考下
2021-04-04
Java中LocalCache本地缓存实现代码
本篇文章主要介绍了Java中LocalCache本地缓存实现代码，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-05-05
Java代码如何判断linux系统windows系统
这篇文章主要介绍了Java代码如何判断linux系统windows系统问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-01-01