BaseDao封装JavaWeb的增删改查的实现代码

/**
 * 获取数据库连接对象
 */
public Connection getConnection() throws Exception {  //获取连接对象方法
    //加载配置文件
    Properties properties = new Properties();
    properties.load(Files.newInputStream(Paths.get("D:\\druid.properties")));
 
    //创建一个指定参数的数据库连接池
    DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
    return dataSource.getConnection();  //返回连接对象
}

driverClassName = com.mysql.cj.jdbc.Driver
url = jdbc:mysql://localhost:3306/student?useServerPrepStmts=true
username = root
password = root
initialSize = 10
maxActive = 30
maxWait = 1000

/**
 * 关闭数据库连接
 * @param conn 数据库连接
 * @param stmt PreparedStatement预处理对象
 * @param rs 结果集
 */
public void closeAll(Connection conn, PreparedStatement stmt, ResultSet rs) {  //关闭连接方法
        // 若结果集对象(RresuleSet)不为空，则关闭
        if (rs != null) {
            try {
                rs.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        // 若预处理对象(PreparedStatement)不为空，则关闭
        if (stmt != null) {
            try {
                stmt.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        // 若数据库连接对象(Connection)不为空，则关闭
        if (conn != null) {
            try {
                conn.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

/**
 * 增、删、改的操作
 * @param preparedSql 预编译的 SQL 语句
 * @param param 参数的字符串数组
 * @return 影响的行数
 */
public int updateRow (String preparedSql, Object[] param) throws Exception {  //增删改操作的方法
    PreparedStatement preparedStatement = null;  //创建预处理对象并初始为空(通过预处理可以防止SQL恶意注入)
    int row = 0;  //初始受影响行数(当受影响行数大于0时,说明执行成功数据则更新)
    Connection connection = getConnection();  //调用getConnection()方法获取数据库连接
    try {
        preparedStatement = connection.prepareStatement(preparedSql);  //对sql形参预处理
        if (param != null) {  //形参数组(注入参数)不为空时,循环遍历对预处理sql注入参数
            for (int i = 0; i < param.length; i++) {
                //为预编译sql设置参数
                preparedStatement.setObject(i + 1, param[i]);
            }
        }
        row = preparedStatement.executeUpdate();  //执行sql语句并得到受影响的行数
        closeAll(connection,preparedStatement,null);  //调用closeAll()方法关闭资源,因为执行操作不含查询,则将结果集的实参传空
    } catch (SQLException e) {
        e.printStackTrace();
    }
    return row;  //返回受影响行数
}

public class Student {
    //初始字段
    private int id;
    private String name;
    private int age;
 
    public Student(int id, String name, int age) {  //构造函数
        this.id = id;
        this.name = name;
        this.age = age;
    }
 
    public int getId() {
        return id;
    }
 
    public void setId(int id) {
        this.id = id;
    }
 
    public String getName() {
        return name;
    }
 
    public void setName(String name) {
        this.name = name;
    }
 
    public int getAge() {
        return age;
    }
 
    public void setAge(int age) {
        this.age = age;
    }
 
    @Override
    public String toString() {  //toString方法
        return "Student{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", age=" + age +
                '}';
    }
}

public List<Student> queryData (String sql, Object[] param) throws Exception {  //查询操作的方法
    PreparedStatement preparedStatement = null;  //创建预处理对象并初始为空(通过预处理可以防止SQL恶意注入)
    Connection connection = getConnection();  //调用getConnection()方法获取数据库连接
    preparedStatement = connection.prepareStatement(sql);  //调用getConnection()方法获取数据库连接
    if (param != null) {  //形参数组(注入参数)不为空时,循环遍历对预处理sql注入参数
        for (int i = 0; i < param.length; i++) {
            //为预编译sql设置参数
            preparedStatement.setObject(i + 1, param[i]);
        }
    }
    ResultSet resultSet = preparedStatement.executeQuery();  //得到返回的结果集
    List<Student> list = new ArrayList<Student>();  //创建List接口对象,泛型为指定Student对象类型,代表每个实体对象都是一行数据
    while (resultSet.next()) {  //循环遍历结果集,将每行数据封装成Student对象,并添加到List集合中
        Student student= new Student(resultSet.getInt(1), resultSet.getString(2), resultSet.getInt(3));  //获取结果集中的数据存入Student对象中
        list.add(student);  //将Student对象存入list接口中
    }
    closeAll(connection,preparedStatement,resultSet);  //调用closeAll()方法关闭数据库连接
    return list;  //返回List集合对象 
}

//增删改测试
BaseDao baseDao = new BaseDao();  //创建BaseDao对象
String sql = "insert into student(id,name,age) values(?,?,?)";  //定义预处理sql
Object[] list = {6, "老八", 35};  //将sql需要的参数存入至Object类型的数组
int add = baseDao.updateRow(sql, list); //调用增删改的方法并接收返回的受影响行数
if (add > 0) {  //受影响行数大于0则说明数据更新成功
    System.out.println("新增成功!受影响行数：" + add);
}
/* 删除、修改也是一样 */

//查询测试
BaseDao baseDao = new BaseDao();  //创建BaseDao对象
String sql = "select * from student";  //定义预处理sql
List<Student> list = baseDao.queryData(sql, null);  //创建List接口,泛型为Student对象类型,用于存储查询返回的数据
for (Student student : list) {
    System.out.println(student.getId() + "\t\t" + student.getName() + "\t\t" + student.getAge());  //输出数据
}