利用元数据将CRUD简化

刺骨的言语ヽ痛彻心扉 2022-05-16 12:45 125阅读 0赞

1.  DataBaseMetaData对象  
    Connection.getDatabaseMetaData()  
    
    
     *  getURL()：返回一个String类对象，代表数据库的URL。
     *  getUserName()：返回连接当前数据库管理系统的用户名。
     *  getDatabaseProductName()：返回数据库的产品名称。
     *  getDatabaseProductVersion()：返回数据库的版本号。
     *  getDriverName()：返回驱动驱动程序的名称。
     *  getDriverVersion()：返回驱动程序的版本号。
     *  isReadOnly()：返回一个boolean值，指示数据库是否只允许读操作。
2.  ParameterMetaData对象  
    PreparedStatement.getParameterMetaData()

获得代表PreparedStatement元数据的ParameterMetaData对象。

Select \* from user where name=? And password=?

*  getParameterCount()获得指定参数的个数
 *  getParameterType(int param)获得指定参数的sql类型

3.ResultSetMetaData对象ResultSet.getMetaData()

获得代表ResultSet对象元数据的ResultSetMetaData对象。  
\- getColumnCount() 返回resultset对象的列数  
\- getColumnName(int column) 获得指定列的名称  
\- getColumnTypeName(int column)获得指定列的类型

JdbcUtils：

package com.kexin.utils;
    
    import java.io.InputStream;
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    import java.util.Properties;
    
    import javax.sql.DataSource;
    
    import org.apache.commons.dbcp.BasicDataSourceFactory;
    
    public class JdbcUtils {
        
    
        private static DataSource ds = null;
        static{
            try{
                InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");
                Properties prop = new Properties();
                prop.load(in);
                BasicDataSourceFactory factory = new BasicDataSourceFactory();
                ds = factory.createDataSource(prop);
            }catch (Exception e) {
                throw new ExceptionInInitializerError(e);
            }
        }
    
        public static Connection getConnection() throws SQLException{
            return ds.getConnection();
        }
    
    
        public static void release(Connection conn,Statement st,ResultSet rs){
    
            if(rs!=null){
                try{
                    rs.close();   //throw new 
                }catch (Exception e) {
                    e.printStackTrace();
                }
                rs = null;
            }
            if(st!=null){
                try{
                    st.close();
                }catch (Exception e) {
                    e.printStackTrace();
                }
                st = null;
            }
            if(conn!=null){
                try{
                    conn.close();
                }catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
        /**
         * 增删改框架
         * @param sql
         * @param params
         * @throws SQLException
         */
        //String sql = "insert into account(id,name,money) values(?,?,?)"   object[]{1,"aaa","10000"};
        public static void update(String sql,Object params[]) throws SQLException{
            Connection conn = null;
            PreparedStatement st = null;
            ResultSet rs = null;
            try{
                conn = getConnection();
                st = conn.prepareStatement(sql);
                for(int i=0;i<params.length;i++){
                    st.setObject(i+1,params[i]);
                }
                st.executeUpdate();
            }finally{
                release(conn, st, rs);
            }
        }
    
        /**
         * 查
         * @param sql
         * @param params
         * @param handler
         * @return
         * @throws SQLException
         */
        public static Object query(String sql,Object params[],ResultSetHandler handler) throws SQLException{
            Connection conn = null;
            PreparedStatement st = null;
            ResultSet rs = null;
            try{
                conn = getConnection();
                st = conn.prepareStatement(sql);
                for(int i=0;i<params.length;i++){
                    st.setObject(i+1,params[i]);
                }
                rs = st.executeQuery();
                return handler.handler(rs);
            }finally{
                release(conn, st, rs);
            }
        }
    }   
    
    interface ResultSetHandler{
        public Object handler(ResultSet rs);
    }

BeanHandler：

package com.kexin.utils;
    
    import java.lang.reflect.Field;
    import java.sql.ResultSet;
    import java.sql.ResultSetMetaData;
    
    public class BeanHandler implements ResultSetHandler{
        
    
        private Class clazz;
        public BeanHandler(Class clazz){
            this.clazz = clazz;
        }
    
        public Object handler(ResultSet rs) {
            try{
                if(!rs.next()){
                    return null;
                }
    
                //创建封装结果集的bean
                Object bean = clazz.newInstance();
    
                //得到结果集的元数据，以获取结果集的信息
                ResultSetMetaData meta = rs.getMetaData();
                int count = meta.getColumnCount();
                for(int i=0;i<count;i++){
                    String name = meta.getColumnName(i+1);   //获取到结果集每列的列名  id
                    Object value = rs.getObject(name);     //1
    
                    //反射出bean上与列名相应的属性
                    Field f = bean.getClass().getDeclaredField(name);
                    f.setAccessible(true);
                    f.set(bean, value);
                }
    
                return bean;
    
            }catch (Exception e) {
                throw new RuntimeException(e);
            }
        }
    }

BeanListHandler：

package com.kexin.utils;
    
    import java.lang.reflect.Field;
    import java.sql.ResultSet;
    import java.sql.ResultSetMetaData;
    import java.util.ArrayList;
    import java.util.List;
    
    public class BeanListHandler implements ResultSetHandler{
        
    
        private Class clazz;
        public BeanListHandler(Class clazz){
            this.clazz = clazz;
        }
        public Object handler(ResultSet rs) {
            List list = new ArrayList();
            try{
                while(rs.next()){
                    Object bean = clazz.newInstance();
                    ResultSetMetaData  meta = rs.getMetaData();
                    int count = meta.getColumnCount();
                    for(int i=0;i<count;i++){
                        String name = meta.getColumnName(i+1);
                        Object value = rs.getObject(name);
    
                        Field f = bean.getClass().getDeclaredField(name);
                        f.setAccessible(true);
                        f.set(bean, value);
                    }
                    list.add(bean);
                }
            }catch (Exception e) {
                throw new RuntimeException(e);
            }
            return list;
    
        }
    }