澳门mgm线上娱乐

028-86261949

当前位置:澳门mgm线上娱乐 > 技术交流 > BaseDao基类实现基础CRUD操作

BaseDao基类实现基础CRUD操作

2019/11/15 10:27 分类: 技术交流 浏览:1

在现实开发中,我们会碰到大量的CRUD的sql语句,我们将最常用的重复性的基础sql语句抽象成一个基类,以便于代码的复用,具体代码如下

代码清单:

package cn.itsource.base;

 

import java.lang.reflect.Field;

import java.lang.reflect.InvocationTargetException;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.ResultSetMetaData;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

 

import cn.itsource.util.JdbcUtil;

import cn.itsource.util.StringUtil;

 

/**

 * 该Dao层的基类实现了基本的CRUD操作

 *

 * @author lv

 */

public class Basedao<T> {

 

澳门mgm线上娱乐    /**

澳门mgm线上娱乐     * 该方法执行所有的增删改

     *

     * @param sql

     * @param objects

     * @return

     * @throws Exception

澳门mgm线上娱乐     */

    protected boolean update(String sql, Object... objects) throws澳门mgm线上娱乐 Exception {

澳门mgm线上娱乐        //声明连接变量

        Connection connection = null;

澳门mgm线上娱乐        //声明动态语句变量

        PreparedStatement psmt = null;

        //声明查询结果集变量

        ResultSet resultSet = null;

        //获取工具类实例

        JdbcUtil util = JdbcUtil.getInstance();

        try {

澳门mgm线上娱乐            //通过工具类实例获取连接对象

澳门mgm线上娱乐            connection = util.getConn();

            //通过连接对象获取动态语句对象,并且预编译sql语句

澳门mgm线上娱乐            psmt = connection.prepareStatement(sql);

            //给sql中的参数赋值

            if (objects != null) {

                for (int澳门mgm线上娱乐 i = 0; i < objects.length; i++) {

                    //第一个?索引是1,所以在数组下标的基础上+1,值为数组中对应的元素值

                    psmt.setObject(i + 1, objects[i]);

                }

            }

澳门mgm线上娱乐            //执行增删改操作

            int executeUpdate = psmt.executeUpdate();

            //提交事务

            connection.commit();

            //如果执行sql的返回值是1,曾表示成功,否则执行sql失败

            return executeUpdate == 1 ? true : false;

        } catch (SQLException e) {

            e.printStackTrace();

澳门mgm线上娱乐            //有异常,回滚事务

            connection.rollback();

        } finally {

            //释放资源

澳门mgm线上娱乐            util.close(connection, psmt, resultSet);

澳门mgm线上娱乐        }

        return false;

澳门mgm线上娱乐    }

 

    /**

     * 该方法执行所有的查询操作,并且将查询的数据封装到一个集合中

澳门mgm线上娱乐     *

     * @param sql

     * @param clazz

     * @param objects

     * @return

     * @throws Exception

澳门mgm线上娱乐     */

    protected List<T> query(String sql, Class<T> clazz, Object... objects) throws Exception {

        //声明连接变量

        Connection connection = null;

        //声明动态语句变量

        PreparedStatement psmt = null;

        //声明查询结果集变量

        ResultSet resultSet = null;

        //获取工具类实例

        JdbcUtil util = JdbcUtil.getInstance();

        //声明集合变量

        ArrayList<T> list = null;

        try {

澳门mgm线上娱乐            //通过工具类实例获取连接对象

            connection = util.getConn();

            //通过连接对象获取动态语句对象,并且预编译sql语句

            psmt = connection.prepareStatement(sql);

            //给sql中的参数赋值

            if (objects != null) {

                for (int澳门mgm线上娱乐 i = 0; i < objects.length; i++) {

                    //第一个?索引是1,所以在数组下标的基础上+1,值为数组中对应的元素值

澳门mgm线上娱乐                    psmt.setObject(i + 1, objects[i]);

澳门mgm线上娱乐                }

澳门mgm线上娱乐            }

澳门mgm线上娱乐            //执行查询操作

            resultSet = psmt.executeQuery();

            //通过查询结果集对象获取对象的列的数量,类型和属性,并且封装到 列信息的对象ResultSetMetaData中

澳门mgm线上娱乐            ResultSetMetaData metaData = resultSet.getMetaData();

            //通过列信息的对象ResultSetMetaData查询当前对象中的列的数量

            int columnCount = metaData.getColumnCount();

            //判断如果有列信息对象不为null,将ResultSetMetaData对象中的字段值封装到Java中的对应类的对象中

            if (metaData != null) {

                //创建集合对象

                list = new ArrayList<>();

                //遍历结果集

                while (resultSet.next()) {

澳门mgm线上娱乐                    //通过反射创建对象

                    T o = clazz.getConstructor().newInstance();

                    //根据ResultSetMetaData中列的数量,遍历获取列的值,给Java中对应的对象字段赋值

                    for (int i = 0; i < columnCount; i++) {

                        //根据ResultSetMetaData对象获取数据库中字段名(数据库中该字段名和Java中对应的JavaBean中的字段名必须已经约定好对应的规则)

澳门mgm线上娱乐                        String columnName = metaData.getColumnName(i + 1);

                        //将数据库字段根据约定规则,调用StringUtil工具类,转换为JavaBean中的字段名,再根据该字段名获取字段对象

                        Field field = clazz.getDeclaredField(StringUtil.lineToHump澳门mgm线上娱乐(columnName));

澳门mgm线上娱乐                        //由于字段是private修饰,所以赋值之前,要先破坏封装

                        field.setAccessible(true);

澳门mgm线上娱乐                        //给对应的字段赋值

                        setFieldValue(field, resultSet, i, o);

澳门mgm线上娱乐                    }

澳门mgm线上娱乐                    //将每一个对象添加到集合中

                    list.add(o);

澳门mgm线上娱乐                }

            }

        } catch (SQLException e) {

澳门mgm线上娱乐            e.printStackTrace();

        } catch (IllegalAccessException e) {

            e.printStackTrace();

        } catch (InstantiationException e) {

            e.printStackTrace();

        } catch (NoSuchMethodException e) {

            e.printStackTrace();

        } catch澳门mgm线上娱乐 (InvocationTargetException e) {

            e.printStackTrace();

        } catch澳门mgm线上娱乐 (NoSuchFieldException e) {

            e.printStackTrace();

        } finally {

澳门mgm线上娱乐            //释放资源

澳门mgm线上娱乐            util.close(connection, psmt, resultSet);

澳门mgm线上娱乐        }

        return list;

澳门mgm线上娱乐    }

 

    /**

     * 该方法执行根据ID查询操作,并且将查询的数据封装到一个对象中

澳门mgm线上娱乐     *

     * @param sql

     * @param clazz

     * @param id

     * @return

     * @throws Exception

澳门mgm线上娱乐     */

    protected T queryById(String sql, Class<T> clazz, long id) throws澳门mgm线上娱乐 Exception {

        T o = null;

        //声明连接变量

        Connection connection = null;

澳门mgm线上娱乐        //声明动态语句变量

        PreparedStatement psmt = null;

澳门mgm线上娱乐        //声明查询结果集变量

        ResultSet resultSet = null;

澳门mgm线上娱乐        //获取工具类实例

        JdbcUtil util = JdbcUtil.getInstance();

        try {

澳门mgm线上娱乐            //通过工具类实例获取连接对象

澳门mgm线上娱乐            connection = util.getConn();

            //通过连接对象获取动态语句对象,并且预编译sql语句

澳门mgm线上娱乐            psmt = connection.prepareStatement(sql);

            //给sql中的参数赋值

            psmt.setLong(1,id);

            //执行查询操作

            resultSet = psmt.executeQuery();

澳门mgm线上娱乐            //通过查询结果集对象获取对象的列的数量,类型和属性,并且封装到 列信息的对象ResultSetMetaData中

            ResultSetMetaData metaData = resultSet.getMetaData();

澳门mgm线上娱乐            //通过列信息的对象ResultSetMetaData查询当前对象中的列的数量

            int columnCount = metaData.getColumnCount();

            //判断如果有列信息对象不为null,将ResultSetMetaData对象中的字段值封装到Java中的对应类的对象中

            if (metaData != null) {

                //遍历结果集

                while (resultSet.next()) {

                    //通过反射创建对象

                    o = clazz.getConstructor().newInstance();

                    //根据ResultSetMetaData中列的数量,遍历获取列的值,给Java中对应的对象字段赋值

                    for (int i = 0; i < columnCount; i++) {

                        //根据ResultSetMetaData对象获取数据库中字段名(数据库中该字段名和Java中对应的JavaBean中的字段名必须已经约定好对应的规则)

澳门mgm线上娱乐                        String columnName = metaData.getColumnName(i + 1);

                        //将数据库字段根据约定规则,调用StringUtil工具类,转换为JavaBean中的驼峰字段名,再根据该字段名获取字段对象

                        Field field = clazz.getDeclaredField(StringUtil.lineToHump澳门mgm线上娱乐(columnName));

澳门mgm线上娱乐                        //由于字段是private修饰,所以赋值之前,要先破坏封装

                        field.setAccessible(true);

                        //给对应的字段赋值

                        setFieldValue(field, resultSet, i, o);

                    }

澳门mgm线上娱乐                }

澳门mgm线上娱乐            }

        } catch (SQLException e) {

澳门mgm线上娱乐            e.printStackTrace();

        } catch澳门mgm线上娱乐 (IllegalAccessException e) {

            e.printStackTrace();

        } catch (InstantiationException e) {

澳门mgm线上娱乐            e.printStackTrace();

        } catch (NoSuchMethodException e) {

            e.printStackTrace();

        } catch (InvocationTargetException e) {

            e.printStackTrace();

        } catch (NoSuchFieldException e) {

            e.printStackTrace();

        } finally {

            //释放资源

            util.close(connection, psmt, resultSet);

澳门mgm线上娱乐        }

        return o;

    }

 

 

澳门mgm线上娱乐    /**

澳门mgm线上娱乐     * 查询数据条数

澳门mgm线上娱乐     *

     * @param sql

     * @param objects

     * @return

     * @throws Exception

澳门mgm线上娱乐     */

    protected long getQueryCount(String sql,Object... objects) throws Exception {

        //声明变量,保存行数

        long row = 0;

        //声明连接变量

        Connection connection = null;

        //声明动态语句变量

        PreparedStatement psmt = null;

澳门mgm线上娱乐        //声明查询结果集变量

        ResultSet resultSet = null;

        //获取工具类实例

        JdbcUtil util = JdbcUtil.getInstance();

        try {

澳门mgm线上娱乐            //通过工具类实例获取连接对象

            connection = util.getConn();

            //通过连接对象获取动态语句对象,并且预编译sql语句

            psmt = connection.prepareStatement(sql);

            //给sql中的参数赋值

            if (objects != null) {

                for (int澳门mgm线上娱乐 i = 0; i < objects.length; i++) {

澳门mgm线上娱乐                    //第一个?索引是1,所以在数组下标的基础上+1,值为数组中对应的元素值

                    psmt.setObject(i + 1, objects[i]);

澳门mgm线上娱乐                }

澳门mgm线上娱乐            }

            //执行查询操作

            resultSet = psmt.executeQuery();

澳门mgm线上娱乐            //将光标移动到此 ResultSet对象中的最后一行

            resultSet.last();

            //获取当前光标所在行的行号

            row = resultSet.getRow();

        } catch (SQLException e) {

            e.printStackTrace();

        } finally {

澳门mgm线上娱乐            //释放资源

澳门mgm线上娱乐            util.close(connection, psmt, resultSet);

澳门mgm线上娱乐        }

        return row;

澳门mgm线上娱乐    }

澳门mgm线上娱乐   

澳门mgm线上娱乐    /**

澳门mgm线上娱乐     * 给对象中字段Field赋值

     *

     * @param field

     * @param resultSet

     * @param i

     * @param o

澳门mgm线上娱乐     */

    private void setFieldValue(Field field, ResultSet resultSet, int i, Object o){

        if(field == null || resultSet == null || o == null){

            return;

澳门mgm线上娱乐        }

澳门mgm线上娱乐        //获取字段数据类型

澳门mgm线上娱乐        Class<?> type = field.getType();

        try {

            //根据字段的数据类型给JavaBean中字段赋对应类型的值

            if (type == byte.class || type == Byte.class) {

澳门mgm线上娱乐                field.setByte(o, resultSet.getByte(i + 1));

            } else if (type == short.class || type == Short.class) {

                field.setShort(o, resultSet.getShort(i + 1));

            } else if (type == int.class || type == Integer.class) {

                field.setInt(o, resultSet.getInt(i + 1));

            } else if (type == long.class || type == Long.class) {

澳门mgm线上娱乐                field.setLong(o, resultSet.getLong(i + 1));

            } else if (type == float.class || type == Float.class) {

澳门mgm线上娱乐                field.setFloat(o, resultSet.getFloat(i + 1));

            } else if (type == double.class || type == Double.class) {

澳门mgm线上娱乐                field.setDouble(o, resultSet.getDouble(i + 1));

            } else if (type == boolean.class || type == Boolean.class) {

澳门mgm线上娱乐                field.setBoolean(o, resultSet.getBoolean(i + 1));

            } else if (type == Date.class) {

澳门mgm线上娱乐                //Date类型

澳门mgm线上娱乐                field.set(o, resultSet.getDate(i + 1));

            } else if (type == String.class) {

                //String类型

                field.set(o, resultSet.getString(i + 1));

            } else {

                //其它类型

澳门mgm线上娱乐                field.set(o, resultSet.getObject(i + 1));

            }

        } catch (IllegalArgumentException e) {

            e.printStackTrace();

        } catch澳门mgm线上娱乐 (IllegalAccessException e) {

            e.printStackTrace();

        } catch (SQLException e) {

澳门mgm线上娱乐            e.printStackTrace();

        }

    }

}

#标签:BaseDao,CRUD