Java用反射封装MySQL增删改查的工具

🕗 发布于 2024-07-23 13:36 java mysql 开发语言

首先，我们要搭建环境：

一、导入jar包

这是我们要加入的jar包。

二、创建德鲁伊的配置文件

三、获取链接：

这是整个的基础，有很多方法都要调用该链接用来给数据库传值；

public class sql_lianjie {
    //创建变量
    private static Connection connection;

    /**
     * 建立链接
     *
     * @return
     * @throws SQLException
     */
    //
    public static Connection getConnection() throws SQLException {
        //创建一个对象用来存储和加载配置文件
        Properties properties = new Properties();
        //try catch输出错误
        try {
            //使用FileInputStream读取名为dur.properties的文件
            // 使用load方法将文件内容加载到properties对象中
            properties.load(new FileInputStream("src/dur.properties"));
            //使用`DruidDataSourceFactory`的`createDataSource`静态方法，传入前面加载的`properties`对象。
            // 这个方法根据配置创建一个`DataSource`对象，`DataSource`是JDBC中用于获取数据库连接的对象。
            DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
//调用`DataSource`对象的`getConnection`方法来获取一个数据库`Connection`。
// 这个`Connection`对象是与数据库交互的基础，所有的SQL操作都需要通过这个对象执行。
            connection = dataSource.getConnection();
            //打印获取到的`Connection`对象。这通常用于调试目的，显示连接是否成功获取。
         //   System.out.println(connection);
        } catch (Exception e) {
            e.printStackTrace();
        }
        //最后，方法返回获取的`Connection`对象。
        return connection;
    }

四、关闭链接：

为了不占用电脑的资源，每次访问完成都要关闭链接；

//名为closeAll，它接受一个可变参数列表（varargs）类型为AutoCloseable。AutoCloseable是一个功能接口
// 用于自动管理资源的类。类型为AutoCloseable。AutoCloseable是一个功能接口,参数它指的是要关闭的资源。
    public static void closeAll(AutoCloseable... yaoguanbidemingcheng) {
        //首先检查传入的参数数组是否非空且长度大于零，以确保有资源需要处理。
        if (yaoguanbidemingcheng != null && yaoguanbidemingcheng.length > 0) {
            //使用Java 8的流（Stream）API来遍历AutoCloseable对象数组。
            // forEach方法接收一个Lambda表达式，对每个元素执行给定的操作。
            Arrays.stream(yaoguanbidemingcheng).forEach(x -> {
                //将捕获该异常并打印堆栈跟踪信息。这样可以避免因为单个资源的关闭失败而导致整个程序的崩溃。
                if (x != null) {
                    try {
                        x.close();
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            });
        }
    }

五、预编译：

创建并返回一个预编译的SQL语句对象（PreparedStatement）它接受三个参数：一个SQL语句（String sql），一个数据库连接对象（Connection connection）， 以及一个可变参数列表（Object... parameters），用于传递SQL语句中的参数值。

public static PreparedStatement getPrepar(String sql, Connection connection, Object... parameters) throws SQLException {
        //使用Connection对象和提供的SQL语句创建一个PreparedStatement对象。
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        //获取PreparedStatement对象的元数据，这提供了关于SQL语句中参数的信息，包括参数的数量和类型。
        ParameterMetaData parameterMetaData = preparedStatement.getParameterMetaData();
        //首先，获取参数的预期数量parameterCount
        int parameterCount = parameterMetaData.getParameterCount();
        //检查是否有参数需要设置，以及传入的参数列表是否非空，最后确认传入参数的数量是否与SQL语句中参数的数量相匹配。
        if (parameterCount != 0 && parameters != null && parameters.length == parameterCount) {
            //如果参数数量和传入的参数列表一致，则循环遍历所有参数。
            for (int i = 0; i < parameterCount; i++) {
                // 并使用setObject方法将每个参数值设置到PreparedStatement对象中。这里i + 1是因为参数索引是从1开始的，而数组索引是从0开始的
                preparedStatement.setObject(i + 1, parameters[i]);
            }
        }
        //方法返回配置好的PreparedStatement对象，以便后续调用者可以执行具体的数据库操
        return preparedStatement;
    }

其次、写方法：

六、写"增删改"的封装方法:

它用于执行SQL更新操作（如插入、更新或删除），并返回受影响的行数。

//它接受两个参数：一个SQL更新语句（String sql）和一个可变参数列表（Object... parametes）
// 用于传递SQL语句中的参数值。方法返回一个整型值（int），表示更新操作影响的行数，
    public static int update(String sql, Object... parametes) throws SQLException {
        //sql_lianjie的对象来获取数据库连接（Connection）。getConnection()是获取数据库连接的标准方法。
        Connection connection = sql_lianjie.getConnection();
        //将sql语句和参数返回给getPrepar（）方法送去预编译处理
        PreparedStatement prepar = getPrepar(sql, connection, parametes);
        //使用PreparedStatement对象的executeUpdate()方法来执行SQL更新操作。
        //此方法返回一个整数，表示数据库中受影响的行数。
        int i = prepar.executeUpdate();
        return i;
    }

七、写查的方法：

查多个数据：

1、将数据存储在List中以集合保存：

public static <T> List<T> selduo(String sql, Class<T> cls, Object... parameters) throws SQLException, InstantiationException, IllegalAccessException, InvocationTargetException {
        //定义 ArrayList 用于存储结果对象
        ArrayList<T> objects = new ArrayList<>();
        //数据库连接 (connection)
        Connection connection = null;
        //预编译的 SQL 语句 (preparedStatement)
        PreparedStatement preparedStatement = null;
        //结果集 (resultSet)
        ResultSet resultSet = null;
        T t = null;
        //2,获取链接
        connection = sql_lianjie.getConnection();
        //3,获取sql预编译对象
        preparedStatement = sql_lianjie.getPrepar(sql, connection, parameters);
        //4,执行查询结果，得到结果集
        resultSet = preparedStatement.executeQuery();
        //5,反编译对象，从结果集中获取表的元素
        ResultSetMetaData metaData = resultSet.getMetaData();
        //     System.out.println(metaData);
        while (resultSet.next()) {
            //实例化空的bean对象，用来封装数据
            t = cls.newInstance();
            int count = metaData.getColumnCount();
            for (int i = 1; i <= count; i++) {
               // 将结果集中的列值设置到对象的属性上。
                BeanUtils.setProperty(t, metaData.getColumnName(i), resultSet.getObject(i));
            }
            //然后将对象添加到结果列表中。
            objects.add(t);
        }
        sql_lianjie.closeAll(connection, preparedStatement, resultSet);
        return objects;


    }

2、将数据存储在Map中以集合保存：

 public static ArrayList<Map> chamap(String sql, Object... parameters) throws SQLException {
        //定义需要的变量
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        ArrayList<Map> map = new ArrayList<>();
//2.获取链接
        connection = sql_lianjie.getConnection();
//3.获取预编译对象
        PreparedStatement prepar = sql_lianjie.getPrepar(sql, connection, parameters);
        //4.执行查询，得到结果集
        resultSet = prepar.executeQuery();
        //5.反编译对象，从结果集中获取表的元数据
        ResultSetMetaData metaData = resultSet.getMetaData();
        int count = metaData.getColumnCount();
        while (resultSet.next()) {
            HashMap<Object, Object> objectObjectHashMap = new HashMap<>();
            for (int i = 1; i <= count; i++) {
                objectObjectHashMap.put(metaData.getColumnName(i), resultSet.getObject(i));
            }
            map.add(objectObjectHashMap);
        }
        sql_lianjie.closeAll(connection, preparedStatement, resultSet);
        return map;
    }

3、查询多条记录，以数组集合（集合中的数据是数组）的数据状态返回

public static List<Object[]> queryArraylist(String sql, Object... parameters) throws SQLException {
        //定义需要的变量
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        ArrayList<Object[]> objects = new ArrayList<>();
        //2.获取链接
        connection = sql_lianjie.getConnection();
        //3.获取预编译对象
        preparedStatement = sql_lianjie.getPrepar(sql, connection, parameters);
        //4.执行查询，得到结果集
        resultSet = preparedStatement.executeQuery();
        //5.反编译对象，从结果集中获取表的元数据
        ResultSetMetaData metaData = resultSet.getMetaData();
        int count = metaData.getColumnCount();

        while (resultSet.next()) {
            Object[] o = new Object[count];
            for (int i = 0; i < count; i++) {
                o[i] = resultSet.getObject(i + 1);
            }
            objects.add(o);
        }
        sql_lianjie.closeAll(connection, preparedStatement, resultSet);
        return objects;
    }

查一条数据：

1、查询一条记录，以键值对形式返回：

public static Map<String, Object> yiMap(String sql, Object... parameters) throws SQLException {
        //定义需要的变量
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        //2.获取链接
        connection = sql_lianjie.getConnection();
        //3.获取预编译对象
        preparedStatement = sql_lianjie.getPrepar(sql, connection, parameters);
        //4.执行查询，得到结果集
        resultSet = preparedStatement.executeQuery();
        //5.反编译对象，从结果集中获取表的元数据
        ResultSetMetaData metaData = resultSet.getMetaData();
        int count = metaData.getColumnCount();
        HashMap<String, Object> map = new HashMap<>();
        resultSet.next();
        for (int i = 1; i <= count; i++) {
            map.put(metaData.getColumnName(i), resultSet.getObject(i));
        }
        sql_lianjie.closeAll(connection, preparedStatement, resultSet);
        return map;
    }

2、查询一条记录以数组方式输出：

public static Object[] queryArray(String sql, Object... parameters) throws SQLException {
        //定义需要的变量
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        //2.获取链接
        connection = sql_lianjie.getConnection();
        //3.获取预编译对象
        preparedStatement = sql_lianjie.getPrepar(sql, connection, parameters);
        //4.执行查询，得到结果集
        resultSet = preparedStatement.executeQuery();
        //5.反编译对象，从结果集中获取表的元数据
        ResultSetMetaData metaData = resultSet.getMetaData();
        int count = metaData.getColumnCount();
        Object[] o = new Object[count];
        resultSet.next();
        for (int i = 0; i < count; i++) {
            o[i] = resultSet.getObject(i + 1);
        }

        sql_lianjie.closeAll(connection, preparedStatement, resultSet);
        mod stu = new mod();

        return o;
    }

3、查一条数据以Javabean的方式返回

public static <T> T selyi(String sql, Class<T> cls, Object... parameters) {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        T t = null;
        //2,获取链接
        try {
            connection = sql_lianjie.getConnection();
            //3,获取sql预编译对象
            preparedStatement = sql_lianjie.getPrepar(sql, connection, parameters);
            //4,执行查询结果，得到结果集
            resultSet = preparedStatement.executeQuery();
//5,反编译对象，从结果集中获取表的元素
            ResultSetMetaData metaData = resultSet.getMetaData();
            resultSet.next();//这个方法只会拿限定的需要的数据，不会有其他内容


            t = cls.newInstance();//实例化空的bean对象，用来封装数据
            int count = metaData.getColumnCount();
            for (int i = 1; i <= count; i++) {
                BeanUtils.setProperty(t, metaData.getColumnName(i), resultSet.getObject(i));
            }
            sql_lianjie.closeAll(connection, preparedStatement, resultSet);
        } catch (Exception e) {
            return null;
        }
        return t;
    }

原文地址：https://blog.csdn.net/daibadetianshi/article/details/140573285

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：6、OpenGL-glad 函数加载
下一篇：高效电机与普通电机

Redis——分布式锁
为什么要有分布式锁？在只有一台服务器提供服务的情况下，乐观锁和悲观锁足以解决线程并发导致的问题。但是企业开发中避免不了需要部署多台服务器，即采用分布式系统或集群模式，这时，多台服务器就有多个jvm，对
阅读更多2024-09-20
springboot使用minio(8.5.11)
1.配置minio MinioAutoConfiguration 类。3.创建minioTemplate工具类。1.上传时如果流是空的，不上传不成功的。
阅读更多2024-09-20
Redis的Key的过期策略是怎样实现的？
在学习Redis时，我们知道可以设置Key的过期时间，我们还知道，Redis一大特点–。那么当Redis中的数据量起来时，如果直接遍历所有的Key，那么对于Key过期时间的校验应该很费时间，那么Red
阅读更多2024-09-20
电气自动化入门03：安全用电
人体电阻：人体平均电阻：2000欧姆，计算分析时，通常去下线值1700欧姆；2.1 电工知识：触电原因与防触电措施_哔哩哔哩_bilibili。电磁场生理伤害：高频磁场影响人的神经系统；违章冒险
阅读更多2024-09-20
828 华为云征文｜华为 Flexus 云服务器搭建 PicGo 图床
通过在华为 Flexus 云服务器上搭建 PicGo 图床，我们成功地构建了一个高效、稳定的图片存储和管理平台。无论是个人博客、开发者文档还是其他需要图片资源的场景，都能从中受益。在未来，随着需求的不
阅读更多2024-09-20
Pycharm打印区打印数据不全问题
python
阅读更多2024-09-20
git重置本地提交与远程保持一致
【代码】git重置本地提交与远程保持一致。
阅读更多2024-09-20
阿里巴巴拍立淘API返回值：商家优化商品信息的深度指南
阿里巴巴的拍立淘API为商家提供了一个强大的工具，通过其返回值，商家可以深入了解市场竞品，并据此制定有效的商品信息优化策略。通过不断优化商品图片、标题、价格等关键信息，商家可以提升商品的竞争力和市场接
阅读更多2024-09-20
Java入门：09.Java中三大特性（封装、继承、多态）02
比如：类A 继承类BA类称为子类，衍生类，派生类B类称为父类，基类，超类子类自动的拥有父类的所有属性和方法（父类编写，子类不需要再编写）。代码复用目前私有的属性和方法无法访问。多态的基
阅读更多2024-09-20
力扣560 和为k的子数组 Java版本
给你一个整数数组 nums 和一个整数 k ，请你统计并返回该数组中和为 k 的子数组的个数。输入：nums = [1,1,1], k = 2。输入：nums = [1,2,3], k = 3。子数
阅读更多2024-09-20