javaee增删改查代码
时间: 2023-12-25 19:04:34 浏览: 127
使用JavaEE实现对数据库的增删改查,需要使用JDBC连接数据库并执行相应的SQL语句。以下是一个简单的JavaEE增删改查代码示例:
```java
// 导入相关的包
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
// 定义一个数据库操作类
public class DBUtil {
// 定义数据库连接信息
private static final String URL = "jdbc:mysql://localhost:3306/test";
private static final String USER = "root";
private static final String PASSWORD = "123456";
// 定义数据库连接对象
private static Connection conn = null;
// 获取数据库连接
public static Connection getConnection() {
try {
// 加载数据库驱动
Class.forName("com.mysql.jdbc.Driver");
// 获取数据库连接
conn = DriverManager.getConnection(URL, USER, PASSWORD);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
// 关闭数据库连接
public static void closeConnection(Connection conn, PreparedStatement pstmt, ResultSet rs) {
try {
if (rs != null) {
rs.close();
}
if (pstmt != null) {
pstmt.close();
}
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
// 插入数据
public static void insertData(String name, int age) {
Connection conn = null;
PreparedStatement pstmt = null;
try {
// 获取数据库连接
conn = getConnection();
// 定义SQL语句
String sql = "insert into student(name, age) values(?, ?)";
// 创建PreparedStatement对象
pstmt = conn.prepareStatement(sql);
// 设置参数
pstmt.setString(1, name);
pstmt.setInt(2, age);
// 执行SQL语句
pstmt.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 关闭数据库连接
closeConnection(conn, pstmt, null);
}
}
// 更新数据
public static void updateData(int id, String name, int age) {
Connection conn = null;
PreparedStatement pstmt = null;
try {
// 获取数据库连接
conn = getConnection();
// 定义SQL语句
String sql = "update student set name=?, age=? where id=?";
// 创建PreparedStatement对象
pstmt = conn.prepareStatement(sql);
// 设置参数
pstmt.setString(1, name);
pstmt.setInt(2, age);
pstmt.setInt(3, id);
// 执行SQL语句
pstmt.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 关闭数据库连接
closeConnection(conn, pstmt, null);
}
}
// 删除数据
public static void deleteData(int id) {
Connection conn = null;
PreparedStatement pstmt = null;
try {
// 获取数据库连接
conn = getConnection();
// 定义SQL语句
String sql = "delete from student where id=?";
// 创建PreparedStatement对象
pstmt = conn.prepareStatement(sql);
// 设置参数
pstmt.setInt(1, id);
// 执行SQL语句
pstmt.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 关闭数据库连接
closeConnection(conn, pstmt, null);
}
}
// 查询数据
public static void queryData() {
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
// 获取数据库连接
conn = getConnection();
// 定义SQL语句
String sql = "select * from student";
// 创建PreparedStatement对象
pstmt = conn.prepareStatement(sql);
// 执行SQL语句
rs = pstmt.executeQuery();
// 处理查询结果
while (rs.next()) {
System.out.println("id=" + rs.getInt("id") + ", name=" + rs.getString("name") + ", age=" + rs.getInt("age"));
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 关闭数据库连接
closeConnection(conn, pstmt, rs);
}
}
}
```
以上代码演示了如何使用JavaEE实现对数据库的增删改查操作。其中,getConnection()方法用于获取数据库连接,closeConnection()方法用于关闭数据库连接,insertData()方法用于插入数据,updateData()方法用于更新数据,deleteData()方法用于删除数据,queryData()方法用于查询数据。
阅读全文