数据库操作：Java连接MySQL并执行CRUD操作的实例

原创今天药忘吃喽~ 2024-11-01 03:30 48阅读 0赞

在Java中连接MySQL数据库并执行CRUD（创建、读取、更新、删除）操作，通常需要使用JDBC（Java Database Connectivity）API。以下是使用JDBC连接MySQL数据库并执行CRUD操作的一个简单示例。

首先，确保你已经安装了MySQL数据库，并且有一个数据库和表可以操作。以下示例假设你有一个名为`users`的表，它有`id`（主键）、`name`和`email`三个字段。

1. **添加MySQL JDBC驱动到项目中**：
你需要将MySQL JDBC驱动添加到你的项目依赖中。如果你使用Maven，可以在`pom.xml`文件中添加以下依赖：

```xml<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.23</version>
</dependency>
 ```2. **编写Java代码**：

```javaimport java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class MySQLExample {

public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
 try {
// 加载和注册JDBC驱动Class.forName("com.mysql.cj.jdbc.Driver");

//建立连接 conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/yourDatabaseName", "username", "password");

// 创建String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
 PreparedStatement pstmt = conn.prepareStatement(sql);
 pstmt.setString(1, "John Doe");
 pstmt.setString(2, "john.doe@example.com");
int rows = pstmt.executeUpdate();
 System.out.println(rows + " rows inserted.");

//读取sql = "SELECT id, name, email FROM users";
stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(sql);

while (rs.next()) {
//通过字段检索int id = rs.getInt("id");
String name = rs.getString("name");
String email = rs.getString("email");

// 输出数据 System.out.println("ID: " + id);
 System.out.println("Name: " + name);
 System.out.println("Email: " + email);
 }

// 更新sql = "UPDATE users SET email = ? WHERE name = ?";
 pstmt = conn.prepareStatement(sql);
 pstmt.setString(1, "new.john.doe@example.com");
 pstmt.setString(2, "John Doe");
rows = pstmt.executeUpdate();
 System.out.println(rows + " rows updated.");

// 删除sql = "DELETE FROM users WHERE name = ?";
 pstmt = conn.prepareStatement(sql);
 pstmt.setString(1, "John Doe");
rows = pstmt.executeUpdate();
 System.out.println(rows + " rows deleted.");

} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 关闭资源 try {
if (stmt != null) stmt.close();
} catch (SQLException se2) {
} //忽略关闭错误 try {
if (conn != null) conn.close();
} catch (SQLException se) {
se.printStackTrace();
 }
 }
 }
 }
 ```3. **运行程序**：
运行上述程序，它将连接到MySQL数据库，执行插入、查询、更新和删除操作。

请注意，你需要将`yourDatabaseName`、`username`和`password`替换为你的数据库名称、用户名和密码。此外，确保你的MySQL服务正在运行，并且防火墙设置允许你的应用程序连接到MySQL服务器。