码迷,mamicode.com
首页 > 其他好文 > 详细

通用增删改查方法

时间:2017-09-09 19:01:02      阅读:236      评论:0      收藏:0      [点我收藏+]

标签:object c   exec   com   get   oms   trace   stack   put   mysql   

1.增删改通用的方法

    传入SQL语句和SQL占位符

public static Boolean adu(String sql ,Object ...objs) {
Boolean f
=false; try { Connection con=DBUtil.getconnection(); PreparedStatement pst=con.prepareStatement(sql); for (int i=0;i<objs.length;i++) { pst.setObject((i+1), objs[i]); } int n=pst.executeUpdate(); f=n>0; } catch (SQLException e) { // TODO Auto-generated catch block//异常处理 e.printStackTrace(); } finally { DBUtil.closeAll(null, pst, con); } return f; }

2.查询通用的方法

   传入查询的类,SQL语句和SQL占位符

public static <T> T comSelect(Class<T> clazz, String sql, Object... args) {

        T entity = null;

        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        try {
            // 获取resultSet
            connection = DBUtil.getconnection();
            preparedStatement = connection.prepareStatement(sql);
            for (int i = 0; i < args.length; i++) {
                preparedStatement.setObject(i + 1, args[i]);
            }
            resultSet = preparedStatement.executeQuery();
            // 获取resultSetMetaData
            ResultSetMetaData resultSetMetaData = resultSet.getMetaData();
            // 创建一个MAP 键 :SQL查询得到的列的别名,别名和javaBean的属性名对应 值:对应列的值
            Map<String, Object> values = new HashMap<String, Object>();

            // 处理结果集,利用resultSetMetaData填充Map
            while (resultSet.next()) {
                for (int i = 0; i < resultSetMetaData.getColumnCount(); i++) {
                    String columnLable = resultSetMetaData
                            .getColumnLabel(i + 1);
                    Object columnValue = resultSet.getObject(i + 1);

                    values.put(columnLable, columnValue);
                }
            }

            // 如果map不为空,利用反射创建对象
            if (values.size() > 0) {
                // 反射创建对象
                entity = clazz.newInstance();
                // 遍历Map ,利用反射为属性赋值
                for (Map.Entry<String, Object> entry : values.entrySet()) {
                    String fieldName = entry.getKey();
                    Object value = null;
                    // 因为java中和mysql中数据类型对应不一致
                    // mysql中int对应JAVA中的long,所以当查询出int型数据的时候需要转换
                    if (entry.getValue() instanceof Long) {
                        value = Integer.parseInt(entry.getValue().toString());
                    } else {
                        value = entry.getValue();
                    }
                    // ReflectionUtils.setFieldValue(entity, fieldName, value);
                    Field field = clazz.getDeclaredField(fieldName);
                    field.setAccessible(true);
                    field.set(entity, value);
                }

            }
        } catch (Exception e) {
            // TODO: handle exception
            e.printStackTrace();
           
        }
        return entity;
    }

 

通用增删改查方法

标签:object c   exec   com   get   oms   trace   stack   put   mysql   

原文地址:http://www.cnblogs.com/Sscholar/p/7498833.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!