元数据和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&¶mValues.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&¶mValues.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的主要内容,如果未能解决你的问题,请参考以下文章