使用Java JDBC连接MySQL数据库，进行基本增删查操作

原创淡淡的烟草味﹌ 2024-11-09 00:21 28阅读 0赞

使用Java JDBC连接MySQL数据库并进行基本的增删查操作，你需要遵循以下步骤：

1. **添加MySQL JDBC驱动到项目中**：
-你可以从MySQL官网下载JDBC驱动（mysql-connector-java），然后将其添加到项目的类路径中。

2. **加载JDBC驱动**：
- 使用`Class.forName()`方法加载JDBC驱动。

3. **建立数据库连接**：
- 使用`DriverManager.getConnection()`方法建立与数据库的连接。

4. **创建`Statement`对象**：
- 使用`connection.createStatement()`创建`Statement`对象，用于执行SQL语句。

5. **执行SQL语句**：
- 使用`Statement`对象的`executeQuery()`方法执行查询操作，`executeUpdate()`方法执行更新（增删改）操作。

6. **处理结果**：
- 对于查询操作，使用`ResultSet`对象处理返回的结果集。
- 对于更新操作，`executeUpdate()`方法返回一个整数，表示影响的行数。

7. **关闭资源**：
- 最后，关闭`ResultSet`、`Statement`和`Connection`对象，释放资源。

下面是一个简单的示例代码，展示了如何使用JDBC连接MySQL数据库，并执行基本的增删查操作：

```javaimport java.sql.*;

public class JdbcDemo {
 public static void main(String[] args) {
// 数据库URL，用户名和密码String url = "jdbc:mysql://localhost:3306/yourDatabaseName";
String user = "yourUsername";
String password = "yourPassword";

Connection connection = null;
Statement statement = null;
ResultSet resultSet = null;

try {
// 加载JDBC驱动Class.forName("com.mysql.cj.jdbc.Driver");

//建立数据库连接 connection = DriverManager.getConnection(url, user, password);

// 创建Statement对象 statement = connection.createStatement();

//执行查询操作String query = "SELECT * FROM yourTableName";
 resultSet = statement.executeQuery(query);
 while (resultSet.next()) {
//处理结果集int id = resultSet.getInt("id");
String name = resultSet.getString("name");
 System.out.println("ID: " + id + ", Name: " + name);
 }

//执行插入操作String insert = "INSERT INTO yourTableName (name) VALUES ('New Name')";
int rowsAffected = statement.executeUpdate(insert);
 System.out.println("Rows affected by insert: " + rowsAffected);

//执行删除操作String delete = "DELETE FROM yourTableName WHERE id =1";
rowsAffected = statement.executeUpdate(delete);
 System.out.println("Rows affected by delete: " + rowsAffected);

} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 关闭资源 try {
if (resultSet != null) resultSet.close();
if (statement != null) statement.close();
if (connection != null) connection.close();
} catch (SQLException e) {
e.printStackTrace();
 }
 }
 }
}
```请确保将`yourDatabaseName`、`yourUsername`、`yourPassword`、`yourTableName`和表中的列名替换为实际的数据库名称、用户名、密码和表信息。此外，确保你的MySQL服务正在运行，并且JDBC驱动版本与MySQL数据库版本兼容。