首页 > 数据库> 文章详细

数据库CRUD封装

2022-05-05 00:32:28 阅读：200 来源： 互联网

标签：ps 封装 rs 数据库 CRUD clazz sql return public

数据库CRUD封装

在一个项目中,我们会进行后台数据库的连接。所以会频繁的使用数据库的CRUD操作，所以我们能不能抽取公共部分，并形成一个工具类呢？我们来试试。

CRUD方法封装

public class CRUDUtils {
/**
    * @Description: 增删改的sql封装
    * @Param: [sql:具体的sql语句; params:字段信息(使用prepareStatement)]
    * @return: int
    */
public static int update(String sql,Object... params){
        Connection con = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            //1.获取连接,DbUtil工具类的获取见末尾文章。
            con = DbUtil.getConn();
            //2.预处理sql语句
            ps = con.prepareStatement(sql);
            //3.params.length 获取可变长度的长度，进行？填充
            for (int i = 0; i < params.length; i++) {
                ps.setObject(i + 1,params[i]);
            }
            /*4.返回执行结果(int),数字是受影响的行数,如果为0表示一行数据都没有影响到,不代表数据库执行错*/
            return ps.executeUpdate();
        } catch (Exception e) {
            e.printStackTrace();
            //这个就是执行失败返回0
            return 0;
        }finally {
            try {
                //5.数据源关闭
                DbUtil.release(con,ps,rs);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        return 0;
    }
    
    /**
    * @Description:封装查询语句
    * @Param: [sql:查询的sql语句, handler:接口,可以指定传入的对象类型, params:字段信息(使用			* prepareStatement)]
    * @return: T
    */
    public static <T> T query(String sql, IResultSetHandler<T> handler, Object... params) {
        Connection con = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            //1.获取连接
            con = DbUtil.getConn();
            //2.执行查询
            ps = con.prepareStatement(sql);
            for (int i = 0; i < params.length; i++) {
                ps.setObject(i + 1,params[i]);
            }
            rs = ps.executeQuery();
            return handler.handle(rs);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            DbUtil.release(con,ps,rs);
        }
        return null;
    }
}

handler接口

public interface IResultSetHandler <T>{

    /**
    * @Description: 接口中抽象方法,实现对结果集的处理,返回所指定的类型
    * @Param: [rs]
    * @return: T
    */
    T handle(ResultSet rs) throws Exception;
}

接口实现类一,bean

/**
 * @description: IResultSetHandler的实现类之一, 返回一个javaBean
 **/
public class BeanHandler<T> implements IResultSetHandler<T> {
    private Class<T> clazz;

    /**获取传进来的类对象的字节码信息*/
    public BeanHandler(Class<T> clazz) {
        this.clazz = clazz;
    }


    @Override
    public T handle(ResultSet rs) throws Exception {
        //如果查到了东西
        if (rs.next()) {
            //首先先根据字节码信息创建对象,等会返回
            T obj = clazz.newInstance();
            //再拿到类的信息
            BeanInfo beanInfo = Introspector.getBeanInfo(clazz, Object.class);
            //拿到类中的属性描述器
            PropertyDescriptor[] pds = beanInfo.getPropertyDescriptors();
            //遍历描述器,进行获取查询结果的对象信息进行封装
            for (PropertyDescriptor pd : pds) {
                //获取查询结果集的对应字段的信息
                String name = pd.getName();

                Object object = rs.getObject(pd.getName());

                //通过调用setter写进信息
                pd.getWriteMethod().invoke(obj,object);
            }
            return obj;
        }
        //查不到直接返回null
        return null;
    }
}

接口实现类二,beanList

/**
 * @program: Dream01
 * @description: IResultSetHandler的实现类之一, 返回一个javaBean集合
 * @author: stop.yc
 * @create: 2022-03-29 22:28
 **/
public class BeanListHandle<T> implements IResultSetHandler<List<T>> {
    private Class<T> clazz;

    //获取当前对象的字节码信息
    public BeanListHandle(Class<T> clazz) {
        this.clazz = clazz;
    }

    @Override
    public List<T> handle(ResultSet rs) throws Exception {
        //通过字节码信息获取类的信息
        BeanInfo beanInfo = Introspector.getBeanInfo(clazz, Object.class);
        //再通过类获取属性描述器,比如getter,setter这些
        PropertyDescriptor[] pds = beanInfo.getPropertyDescriptors();
        //类的列表
        List<T>list = new ArrayList<>();
        //进行遍历
        while(rs.next()) {
            //通过对象信息创建对象
            T obj = clazz.newInstance();

            for (PropertyDescriptor pd : pds) {
                //获取对应字段的信息
                Object object = rs.getObject(pd.getName());
                //获取setter
                pd.getWriteMethod().invoke(obj,object);
            }
            list.add(obj);
        }
        return list;
    }
}

主函数测试

public class Main {
    public static void main(String[] args) {

       	String qSql = "select * from `t_user` where `userName`=?";
        String userName = "张三";
        //User为自定义的类.
        User user = CRUDUtils.query(qSql,new BeanHandler<>(User.class),userName);
        
        String sql = "select * from `t_user` where `gender`=0";
      	//List<User> list = CRUDUtils.query(sql,new BeanListHandle<>(User.class));
        
        //update语句都行,这里只展示一种
        String updateSql = "isnert into `t_user` (`userName`,`gender`) values ('李四','男')";
	    int ret = CRUDUtils.update(updateSql);
    }
}

文章里的数据库工具类详见数据库工具类

标签：ps,封装,rs,数据库,CRUD,clazz,sql,return,public
来源： https://www.cnblogs.com/stopyc/p/16223089.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

数据库CRUD封装

数据库CRUD封装