jdbc框架{ 元数据: 数据库、表、列的定义信息在框架中才涉及到的知识 databasemetadata对象(数据库){ 获取方法: connection.getmetadata(); 使用: geturl();返回当前连接的数据库的url信息 getusername();返回当前连接的数据库的用户名 getdatabaseprod
jdbc框架{元数据:数据库、表、列的定义信息——在框架中才涉及到的知识
databasemetadata对象(数据库){
获取方法:connection.getmetadata();
使用:
geturl();——返回当前连接的数据库的url信息
getusername();——返回当前连接的数据库的用户名
getdatabaseproductname();——数据库的产品名称
getdatabaseproductversion();——数据库的版本号
getdrivername();——驱动程序的名称
getdriverversion();——驱动程序的版本号
isreadonly();——指示数据库是否只允许读的操作
...
例:
connection conn = jdbcutils.getconnection(); databasemetadata md = conn.getmetadata(); system.out.println(md.geturl());//输出:jdbc:mysql://localhost:3306/mydb system.out.println(md.getdatabaseproductname());//输出:mysql system.out.println(md.getdriverversion());//输出:mysql-connector-java-5.1.22 ( revision: ${bzr.revision-id} )
}
parametermetadata(参数){
获取方法:preparedstatement.getparametermetadata();——例如一条select * from user where name=? and password=?;这个对象就是这条sql语句参数(问号)的元数据
使用:
getparametercount();——获得指定参数的个数
getparametertype(int param);——指定参数的sql类型
...
例:
connection conn = jdbcutils.getconnection(); string sql = insert into user(id,name) values(?,?); preparedstatement st = conn.preparestatement(sql); parametermetadata md = st.getparametermetadata(); system.out.println(md.getparametercount());//输出:2// system.out.println(md.getparametertype(1));该方法由于mysql的驱动不支持,会抛异常
}
resultsetmetadata(结果集){
获取方法:resultset.getmetadata();——获得代表结果集resultset对象的元数据,告诉用户结果集的一些信息
使用:
getcolumncount();——结果集对象的列数
getcolumnname(int column);——指定列的名称
getcolumntypename(int column);——指定列的类型
...
例:
connection conn = jdbcutils.getconnection(); string sql = select * from user; preparedstatement st = conn.preparestatement(sql); resultset rs = st.executequery(); resultsetmetadata md = rs.getmetadata(); system.out.println(md.getcolumncount());//输出:一共有多少列 system.out.println(md.getcolumnname(1));//输出:第一列的列名 system.out.println(md.getcolumntype(1));//输出:第一列的类型
}
编写增删改查的框架(方法){
//增删改的工具方法,只需要将sql语句和sql中的问号对应的参数用数组形式传进方法,就可以执行成功 public static void update(string sql, object params[]) throws sqlexception {// 定义基本对象 connection conn = null; preparedstatement st = null; resultset rs = null; try { conn = jdbcutils.getconnection(); st = conn.preparestatement(sql);// 根据传进来的参数数组填充sql中的问号 for (int i = 0; i < params.length; i++) { st.setobject(i+1, params[i]); } st.executeupdate(); }finally{ jdbcutils.release(conn, st, rs); } } // 查的工具方法,还要得到一个用户想要处理结果集的类,用户只需要new一个处理类的对象进来即可 public static object query(string sql, object params[], resultsethandler handler) throws sqlexception{// 定义基本对象 connection conn = null; preparedstatement st = null; resultset rs = null; try { conn = jdbcutils.getconnection(); st = conn.preparestatement(sql);// 根据传进来的参数数组填充sql中的问号 for (int i = 0; i < params.length; i++) { st.setobject(i+1, params[i]); }// 由于这边得到的结果集有些内容都不知,可以向用户暴露一个处理接口的方法,然后直接在该程序中调用这个处理的方法。// 用户实现了这个接口并做出了想要的处理,传递到本程序中,就能返回用户想用的数据 rs = st.executequery(); return handler.handler(rs); }finally{ jdbcutils.release(conn, st, rs); } }}// 定义接口 interface resultsethandler{ public abstract object handler(resultset rs); }//实现处理单行数据的类,返回封装了结果数据的对象,如果需要处理的是多行的数据,就需要使用集合,把每行数据封装成对象,再存入集合。那么这个方法返回的就是集合对象class beanhandler implements resultsethandler{// 通过构造函数获得对象的字节码,以备将结果集存到该对象中 private class clazz = null; public beanhandler(class clazz) { super(); this.clazz = clazz; } @override public object handler(resultset rs) { try { if(rs.next()){ return null; }// 创建封装结果集的bean对象 object bean = clazz.newinstance();// 通过元数据的技术得到结果集的内容 resultsetmetadata md = rs.getmetadata(); for (int i = 0; i < md.getcolumncount(); i++) {// 获取结果集每列的名称 string columnname = md.getcolumnname(i+1);// 得到该列的值 object value = rs.getobject(columnname);// 为bean对象里的列名对应的属性赋value,使用反射技术;也可以使用beanutils库,这样就必须导入一个库,不方便 //获取bean里的属性,需要设置为私有可见 field f = bean.getclass().getdeclaredfield(columnname); f.setaccessible(true); //进行赋值 f.set(bean, value); } return bean; } catch (exception e) { throw new runtimeexception(); } }
}
开源框架dbutils{
1.commons-dbutils是apache组织提供的一个开源jdbc工具类库,他是对jdbc的简单封装,使用dbutils能极大简化jdbc编码的工作量同时也不会影响程序性能
2.使用dbutils需要查看api文档,内部主要是两个类queryrunner(用于增删改查)和resultsethandler(用于处理查询的结果集)
例:
public void add(){ try { // 使用queryrunner和resultsethandler // 创建一个queryrunner对象,将数据库的数据源作为构造函数传入 queryrunner runner = new queryrunner(jdbcutils.getdatasource()); // 定义sql语句和参数对象 string sql = insert into user(id,name) values(?,?); object params[] = {1, aaa}; // 执行更新操作,将sql和参数传入 runner.update(sql, params); } catch (exception e) { throw new runtimeexception(e); } } public void query(){ try {// 使用queryrunner和resultsethandler// 创建一个queryrunner对象,将数据库的数据源作为构造函数传入 queryrunner runner = new queryrunner(jdbcutils.getdatasource());// 定义sql语句和参数对象 string sql = select * from user;// 执行更新操作,将sql传入.并且将结果处理到list容器中 list list = runner.query(sql, new beanlisthandler(user.class)); } catch (exception e) { throw new runtimeexception(e); } }
结果集处理器(resultsethandler实现类){ arrayhandler:把结果集的第一行数据封装到一个数组内,返回数组对象。——new arrayhandler();
arraylisthandler:把结果集的每一行数据都封装到一个数组中,再将每个数组存到list集合内,返回list对象。——new arraylisthandler();
beanhandler:将结果集的第一行数据封装到一个bean对象中,需要将bean的字节码对象传入,返回bean对象。——new beanhandler(user.class);
beanlisthandler:将结果集的每一行数据封装到一个bean对象中,再存放在list集合内,同样需要传入bean的字节码对象,返回list对象。——new beanlisthandler(user.class);
columnlisthandler:将结果集的某一列的数据存放在list中,需要将列名传入,返回list对象。——new columnlisthandler(id);
keyedhandler:将结果集的每一行数据都封装到一个map(key为列名,value为该列的值)中,再将这个map存放在另一个map中(key为传入的指定列名的值,value就是map),返回map对象。——new keyedhandler(id);
maphandler:将结果集的第一行数据封装到一个map中,key为列名,value为该列的值,返回map对象。——new maphandler();
maplisthandler:将结果集的每一行数据都封装到一个map中,再存放在list中,返回list对象。——new maplisthandler();
scalarhandler:将制定的第一行的某一列(可以传入第几列或者列名)的值存放在一个对象内,返回该对象。——new scalarhandler(1);
例:
//查询总记录数 queryrunner runner = new queryrunner(jdbcutils.getdatasource()); string sql = select count(*) from user;//// 1.使用arrayhandler处理器// object result[] = runner.query(sql, new arrayhandler());//// 取出数据,取出的是long型的数据,需要进行转型// int count = ((long)result[0]).intvalue();// 2.使用scalarhandler处理器,取出第一列的值,指定了封装到long对象中,进行转型 int count = runner.query(sql, new scalarhandler(1)).intvalue();
}
}
}