将 Java 连接到 MySQL 数据库
MySQL 是全球开发者使用最广泛的关系型数据库管理系统之一。它是开源且可靠的,因此非常适合构建需要强大后端的 Web 应用程序。
Java 是一种存在数十年的编程语言,广泛用于开发企业级应用程序。本文将介绍如何将 Java 连接到 MySQL 数据库并执行 CRUD(Create、Read、Update 和 Delete)操作。
阅读更多:MySQL 教程
先决条件
在开始之前,请确保已在计算机上安装以下软件:
- JDK(Java 开发工具包)
- MySQL 数据库服务器
- MySQL connector/J 驱动程序
详细步骤
- 使用以下命令在 MySQL 中创建一个数据库:
CREATE DATABASE mydatabase;
- 使用以下命令在该数据库中创建一个表:
USE mydatabase;
CREATE TABLE users (
id INT PRIMARY KEY,
name varchar(50),
email varchar(100)
);
- 下载 MySQL connector/J 驱动程序,并将其添加到 Java 项目的类路径中。
-
创建一个 Java 类来表示数据库连接。以下是一个示例:
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class DatabaseConnection {
private final String url = "jdbc:mysql://localhost:3306/mydatabase";
private final String username = "root";
private final String password = "password";
public Connection getConnection() throws SQLException {
return DriverManager.getConnection(url, username, password);
}
}
将 "localhost"、"mydatabase"、"root" 和 "password" 替换为您自己的数据库服务器名称、数据库名称、用户名和密码。
- 使用
DatabaseConnection类建立到数据库的连接并执行查询。以下是一个示例:
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class Main {
public static void main(String[] args) throws SQLException {
DatabaseConnection connection = new DatabaseConnection();
Connection conn = connection.getConnection();
// 插入
String insertQuery = "INSERT INTO users (id, name, email) VALUES (?, ?, ?)";
PreparedStatement insertStatement = conn.prepareStatement(insertQuery);
insertStatement.setInt(1, 1);
insertStatement.setString(2, "John Doe");
insertStatement.setString(3, "johndoe@example.com");
insertStatement.executeUpdate();
// 查询
String selectQuery = "SELECT * FROM users";
PreparedStatement selectStatement = conn.prepareStatement(selectQuery);
ResultSet resultSet = selectStatement.executeQuery();
while (resultSet.next()) {
int id = resultSet.getInt("id");
String name = resultSet.getString("name");
String email = resultSet.getString("email");
System.out.println(id + "\t" + name + "\t" + email);
}
// 更新
String updateQuery = "UPDATE users SET email = ? WHERE id = ?";
PreparedStatement updateStatement = conn.prepareStatement(updateQuery);
updateStatement.setString(1, "newemail@example.com");
updateStatement.setInt(2, 1);
updateStatement.executeUpdate();
// 删除
String deleteQuery = "DELETE FROM users WHERE id = ?";
PreparedStatement deleteStatement = conn.prepareStatement(deleteQuery);
deleteStatement.setInt(1, 1);
deleteStatement.executeUpdate();
conn.close();
}
}
此代码将向 users 表插入一个新用户记录,选择表中的所有记录,更新现有记录并删除一条记录。
总结
本文介绍了如何将 Java 连接到 MySQL 数据库并执行 CRUD 操作。我们还学习了如何在 MySQL 中创建数据库和表,下载并添加 MySQL connector/J 驱动程序到 Java 项目中,以及编写 Java 代码来执行数据库上的 SQL 查询。MySQL 和 Java 是构建需要可靠且可扩展后端的复杂 Web 应用程序的强大组合。
极客教程