封装JDBC连接MySQL数据库的方法实现数据的增删改查

1.需要用到的jar包
commons-beanutils-1.8.3.jar
mysql-connector-java-5.1.43-bin.jar

2.把连接数据库需要的信息，都保存在一个文件中，这个文件是一个properties文件
driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/javaee1707?useSSL=true
user=root
password=123456

3.建Class文件JDBCUtil自定义工具类用来连接数据库，具体见上篇文章

4.代码实现数据库的增删改查
public class BaseDao {
//初始化参数
private Connection conn;
private PreparedStatement pstmt;
private ResultSet rs;

/**
 * 主要针对增，删，改的通用方法
 * @param sql 要执行的SQL语句(insert, delete, updata)
 * @param paramsValue 参数数组，用来处理SQL语句中的占位符参数，如果没有参数，请传入null
 */
public void update(String sql, Object[] paramsValue) {
    try {
        //1. 数据库连接
        conn = JDBCUtil.getConnection();
        //2. 获取PreparedStatement
        pstmt = conn.prepareStatement(sql);
        
        //3. 得到参数元数据个数
        int count = pstmt.getParameterMetaData().getParameterCount();
        //4. 利用参数元数据给SQL语句的占位符需要的参数赋值
        if (paramsValue != null && paramsValue.length > 0) {
            for (int i = 0; i < count; i++) {
                //循环结束，就是可以给SQL语句完整赋值
                pstmt.setObject(i + 1, paramsValue[i]);
            }
        }
        //5. 执行
        pstmt.executeUpdate();
    } catch (SQLException e) {
        throw new RuntimeException(e);
    } finally {
        JDBCUtil.close(conn, pstmt);
    }
}

//Class.forName(com.qfedu.Student)
/**
 * 查询的通用方法
 * @param sql 查询需要的SQL语句
 * @param paramsValue 查询需要参数，如果么有参数，设置为null
 * @param cls List集合中保存的数据类型
 * @return List集合，返回一个带有指定数据类型List集合
 */
public <T> List<T> query(String sql, Object[] paramsValue, Class<T> cls) {
    
    try {
        //1.要返回的数据集合
        List<T> list = new ArrayList<T>();  
        //2.确定List集合中要保存的对象
        T t = null;
        //3. 连接数据库
        conn = JDBCUtil.getConnection();
        pstmt = conn.prepareStatement(sql);
        //4. 给SQL语句的占位符赋值参数
        if (paramsValue != null && paramsValue.length > 0) {
            for (int i = 0; i < pstmt.getParameterMetaData().getParameterCount(); i++) {
                pstmt.setObject(i + 1, paramsValue[i]);
            }
        }
        //5. 执行查询操作，返回ResultSet
        rs = pstmt.executeQuery();
        
        //6. 获取结果集元数据
        ResultSetMetaData rsMetaData = rs.getMetaData();
        //数据库列的数量
        int columnCount = rsMetaData.getColumnCount(); 
        
        //7. 遍历ResultSet数据集
        while (rs.next()) {
            //创建要保存的对象
            t = cls.newInstance();
            
            //8. 遍历数据行的每一列，得到每一列的名字，在获取到数据，保存到T对象中
            for (int i = 0; i < columnCount; i++) {
                //获取每一列的名字
                String columnName = rsMetaData.getColumnName(i + 1);
                //获取每一列的数据
                Object value = rs.getObject(columnName);
                
                //利用BeanUtils给T对象赋值
                BeanUtils.setProperty(t, columnName, value);
            }
            
            //把创建好的T对象，放入到List集合中
            list.add(t);
        }
        return list;
    } catch (SQLException e) {
        e.printStackTrace();
    } catch (InstantiationException e) {
        e.printStackTrace();
    } catch (IllegalAccessException | InvocationTargetException e) {
        e.printStackTrace();
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        JDBCUtil.close(conn, pstmt, rs);
    }
    return null;
}

}