import java.sql.*;
public class CRUDExample {
// 数据库连接信息
private static final String URL = "jdbc:mysql://localhost:3306/mydatabase";
private static final String USERNAME = "username";
private static final String PASSWORD = "password";
// 创建
public void create(String name, int age) {
try (Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
PreparedStatement stmt = conn.prepareStatement("INSERT INTO users (name, age) VALUES (?, ?)")) {
stmt.setString(1, name);
stmt.setInt(2, age);
int rowsAffected = stmt.executeUpdate();
if (rowsAffected > 0) {
System.out.println("成功创建用户:" + name);
} else {
System.out.println("创建用户失败!");
}
} catch (SQLException e) {
e.printStackTrace();
}
}
// 查询
public void retrieve() {
try (Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM users")) {
System.out.println("用户列表:");
while (rs.next()) {
String name = rs.getString("name");
int age = rs.getInt("age");
System.out.println("姓名:" + name + ",年龄:" + age);
}
} catch (SQLException e) {
e.printStackTrace();
}
}
// 更新
public void update(String name, int newAge) {
try (Connection conn = DriverManager.getConnection(URL, USERNAME,
12.11
发布时间 2023-12-18 22:53:25作者: 刘梦磊