Java初级增删改查实现指南

在Java编程中,增删改查(CRUD)是数据库操作中最基本也是最核心的部分,本文将详细介绍如何在Java中实现基本的增删改查操作,我们将使用JDBC(Java Database Connectivity)作为数据库连接工具,以MySQL数据库为例进行演示。
环境准备
- 安装Java开发环境:JDK(Java Development Kit)
- 安装MySQL数据库,并创建一个数据库和表
- 安装并配置IDE(如IntelliJ IDEA或Eclipse)
JDBC连接数据库
引入JDBC驱动包
在项目的lib目录下,将MySQL的JDBC驱动jar包(mysql-connector-java-x.x.x-bin.jar)添加到项目的类路径中。

加载驱动
Class.forName("com.mysql.jdbc.Driver");
获取数据库连接
String url = "jdbc:mysql://localhost:3306/数据库名?useSSL=false"; String username = "用户名"; String password = "密码"; Connection conn = DriverManager.getConnection(url, username, password);
实现增删改查操作
添加(Create)
public void add(String name, int age) {
String sql = "INSERT INTO 表名 (name, age) VALUES (?, ?)";
try (Connection conn = DriverManager.getConnection(url, username, password);
PreparedStatement pstmt = conn.prepareStatement(sql)) {
pstmt.setString(1, name);
pstmt.setInt(2, age);
pstmt.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
}
}
删除(Delete)

public void delete(int id) {
String sql = "DELETE FROM 表名 WHERE id = ?";
try (Connection conn = DriverManager.getConnection(url, username, password);
PreparedStatement pstmt = conn.prepareStatement(sql)) {
pstmt.setInt(1, id);
pstmt.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
}
}
修改(Update)
public void update(int id, String name, int age) {
String sql = "UPDATE 表名 SET name = ?, age = ? WHERE id = ?";
try (Connection conn = DriverManager.getConnection(url, username, password);
PreparedStatement pstmt = conn.prepareStatement(sql)) {
pstmt.setString(1, name);
pstmt.setInt(2, age);
pstmt.setInt(3, id);
pstmt.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
}
}
查询(Query)
public List<Map<String, Object>> query() {
List<Map<String, Object>> list = new ArrayList<>();
String sql = "SELECT * FROM 表名";
try (Connection conn = DriverManager.getConnection(url, username, password);
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(sql)) {
ResultSetMetaData metaData = rs.getMetaData();
int columnCount = metaData.getColumnCount();
while (rs.next()) {
Map<String, Object> map = new HashMap<>();
for (int i = 1; i <= columnCount; i++) {
map.put(metaData.getColumnName(i), rs.getObject(i));
}
list.add(map);
}
} catch (Exception e) {
e.printStackTrace();
}
return list;
}
注意事项
- 在实际开发中,为了提高代码的健壮性和可维护性,建议使用数据库连接池(如Druid、HikariCP等)来管理数据库连接。
- 使用PreparedStatement可以防止SQL注入攻击。
- 在执行数据库操作时,务必使用try-with-resources语句来自动关闭资源,避免资源泄漏。
通过以上步骤,您已经掌握了Java初级增删改查的基本操作,在实际开发中,可以根据需求对代码进行优化和扩展,祝您编程愉快!

















