元数据和DbUtils

Posted 十三弦

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了元数据和DbUtils相关的知识,希望对你有一定的参考价值。

  使用元数据可以在jdbc中获取数据库的定义,例如:数据库、表、列的定义信息。

  在jdbc中可以使用: 数据库元数据、参数元数据、结果集元数据。

1.DataBaseMetaData对象

  Connection.getDatabaseMetaData()

getURL():返回一个String类对象,代表数据库的URL。

getUserName():返回连接当前数据库管理系统的用户名。

getDatabaseProductName():返回数据库的产品名称。

getDatabaseProductVersion():返回数据库的版本号。

getDriverName():返回驱动驱动程序的名称。

getDriverVersion():返回驱动程序的版本号。

isReadOnly():返回一个boolean值,指示数据库是否只允许读操作。

2.ParameterMetaData对象

  PreparedStatement . getParameterMetaData()

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

getParameterCount():获得指定参数的个数。

getParameterType(int param):获得指定参数的sql类型。

3.ResultSetMetaData对象

ResultSet. getMetaData()

getColumnCount():返回resultset对象的列数。

getColumnName(int column):获得指定列的名称。

getColumnTypeName(int column):获得指定列的类型。

4.使用元数据优化Dao

public class BaseDao{
    private Connection conn;
    private PreparedStatement stmt;
    private ResultSet resultSet;
    public void update(String sql,Object[] paramValues){
        conn = JdbcUtil.getConnection();
        try {
            stmt = conn.prepareStatement(sql);
            int parameterCount = stmt.getParameterMetaData()
                    .getParameterCount();
if(paramValues !=null&&paramValues.length>0){ for(int i = 0;i<parameterCount;i++) { stmt.setObject(i+1,paramValues[i]); } } stmt.executeUpdate(); } catch (Exception e) { throw new RuntimeException(e); }finally { JdbcUtil.close(conn,stmt); } } public <T> List<T> query(String sql,Object[] paramValues,Class<T> clazz){ try { List<T> list = new ArrayList<T>(); //要封装的对象 conn = JdbcUtil.getConnection(); stmt = conn.prepareStatement(sql); int count = stmt.getParameterMetaData().getParameterCount(); if(paramValues !=null&&paramValues.length>0){ for(int i = 0;i< count;i++) stmt.setObject(i+1,paramValues[i]); } resultSet = stmt.executeQuery(); ResultSetMetaData metaData = resultSet.getMetaData(); int columnCount = metaData.getColumnCount(); while(resultSet.next()){ T t = clazz.newInstance(); for(int i=0;i<columnCount;i++){ //获取列的名字 String columnName = metaData.getColumnName(i + 1); //获取列对应的值 Object object = resultSet.getObject(columnName); //设置到对象的属性中 BeanUtils.copyProperty(t,columnName,object); } //添加对象 list.add(t); } return list; }catch (Exception e){ throw new RuntimeException(e); }finally { JdbcUtil.close(conn,stmt); } } }

5.DbUtils组件

   commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库,它是对JDBC的简单封装,学习成本极低,并且使用dbutils能极大简化jdbc编码的工作量,同时也不会影响程序的性能。因此dbutils成为很多不喜欢hibernate的公司的首选。

  在使用DbUtils组件时,bean的属性名要和表的列名一致(大小写不敏感),否则,封装为bean对象时,相应的属性会被设置为默认值。

6.DbUtils API

DbUtils   关闭资源、加载驱动

QueryRunner   组件的核心工具类:定义了所有的与数据库操作的方法(查询、更新),这些方法会自行处理 PreparedStatement 和 ResultSet 的创建和关闭。

Int  update(Connection conn, String sql, Object…  param)               执行更新带占位符的sql

Int[]  batch(Connection conn, String sql, Object[][] params)             批处理

T  query(Connection conn ,String sql, ResultSetHandler<T> rsh, Object... params)   查询方法

注意: 如果调用DbUtils组件的操作数据库方法,没有传入连接对象,那么在实例化QueryRunner对象的时候需要传入数据源对象: QueryRunner qr = new QueryRunner(ds);

Int  update( String sql, Object…  param);

Int[]  batch( String sql, Object[][] params)      

DbUtils提供的封装结果的一些对象:

1)BeanHandler: 查询返回单个对象

2)BeanListHandler: 查询返回list集合,集合元素是指定的对象

3)  ArrayHandler, 查询返回结果记录的第一行,封装对对象数组, 即返回:Object[]

4)  ArrayListHandler, 把查询的每一行都封装为对象数组,再添加到list集合中

5)  ScalarHandler 查询返回结果记录的第一行的第一列  (在聚合函数统计的时候用)

6)  MapHandler  查询返回结果的第一条记录封装为map

        conn = JdbcUtil.getConnection();    
        QueryRunner qr = new QueryRunner();
        //使用组件提供的结果集对象封装数据
        //封装单个对象
        String sql = "select *from student_info where stuId = ?";
        Student student = qr.query(conn, sql, new BeanHandler<Student>(Student.class),2008001);

        String sql = "select *from student_info";
        //返回封装为对象的list的结果集
        List<Student> students= qr.query(conn, sql, new BeanListHandler<Student>(Student.class));

        //返回结果集的第一个结果的数组
        Object[] query = qr.query(conn, sql, new ArrayHandler());

        //返回结果集所有结果组成的list
        List<Object[]> query = qr.query(conn, sql, new ArrayListHandler());

        //返回结果集的第一个结果的列名-列值的映射
        Map<String, Object> query = qr.query(conn, sql, new MapHandler());

        //返回结果集的第一行的第一列
        Long query = qr.query(conn, sql, new ScalarHandler<Long>());

 7.使用DbUtils优化Dao

public class AdminDao implements IAdminDao {

    private Connection con;
    private QueryRunner qr = new QueryRunner();

    @Override
    public Admin findByNameAndPwd(Admin admin) {
        String sql = "select * from admin where userName=? and pwd=?";
        try{
            con = JdbcUtil.getConnection();
            Admin ad = qr.query(con, sql, 
                    new BeanHandler<Admin>(Admin.class), 
                    admin.getUserName(),
                    admin.getPwd());
            return ad;
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            JdbcUtil.closeAll(con, null, null);
        }
    }

    @Override
    public void save(Admin admin) {
        String sql = "INSERT INTO admin(userName,pwd) VALUES(?,?);";
        try {
            con = JdbcUtil.getConnection();
            // 使用DbUtils组件的方法更新
            qr.update(con, sql, admin.getUserName(),admin.getPwd());
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            JdbcUtil.closeAll(con, null, null);
        }
    }

    @Override
    public boolean userExists(String name) {
        String sql = "select id from admin where userName=?";
        try {
            con = JdbcUtil.getConnection();
            Integer in = qr.query(con, sql, new ScalarHandler<Integer>(), name);
            if (in != null){
                return true;
            }
            return false;
        } catch (SQLException e) {
            throw new RuntimeException(e);
        } finally {
            JdbcUtil.closeAll(con, null, null);
        }
    }
}

 

以上是关于元数据和DbUtils的主要内容,如果未能解决你的问题,请参考以下文章

黑马day12 DbUtils的介绍

在使用Dbutils查数据的时候出现这个错误,

数据库——DBUtils和连接池

数据库元数据MetaData

第7章WEB07- JDBC篇

DBUtils和连接池