JDBC(5)—DatabaseMetaData

  • 1.简介:

    使用元数据已实现通用的查询方法。元数据介绍:使用jdbc获得连接之后,得到一个Connection对象,可以通过这个对象获得DataBaseMetaData对象,该对象可以获得有关数据库管理系统的各种信息,包括数据库中的各个表,表中的各个列,数据类型触发器,存储过程等各方面的信息,根据这些信息JDBC可以访问一个事先并不了解的的数据库。

    ** 这样通过这种方法,可以让即使只知道类名、SQL语句,也可以数据表中的字段和类成员变量联系到一起。从而查询出结果来。可以把查询出来的数据与成员变量联系到一块,可以把成员变量的名作为数据表列别名写道SQL语句中,通过DataBaseMateData对象获取列别名和列值存储到Map中,在通过反射创建对象,通过反射根据Map中取出的列别名获取指定的成员变量,再把列值赋给成员变量。

    //首先通过反射获取指定名称的变量。

    Field Name = entity.getClass().getDeclaredField(fieldName);

    //设置私有的变量允许访问。

    Name.setAccessible(true);

    //Name调用set(对象,值)方法,为获取到的变量赋值

    Name.set(entity, fieldValue);

    为什么要这样麻烦呢?其目的就是为了降低耦合性、提高可重用性。 **

  • 2.方法:

    获取这些信息都是在DataBaseMateData类的对象上实现的,而DataBaseMateData对象是在Connection对象上获得的。具体使用时使用ResultSetMateData类。

    *可用于获取ResultSet对象(结果集)中列的类型和属性信息的对象:

    *常用方法方法:

    • getColumnName(int column):获取指定列的名称
    • getColumnCount():返回当前ResultSet对象中的列数
    • getColumnTypeName(int column):检索指定列的数据库特定的类型名称。
    • getColumnDisplaySize(int column):指示指定列的最大标准宽度,以字符为单位。
    • isNullable(int column):指示指定列中的值是否可以为null。
    • isAutoIncrement(int column):指示是否为指定列进行编号,这样这些列仍然是只读的。

      *

      *具体使用时是使用ResultSetMetaData类

      *该类方法:

      *int getColumn():SQL 语句中包含哪些列

      *String getColumnLabel(int column):获取指定类别名,其中索引从1开始。
  • 3.步骤:

    • ①.得到ResultSetMetaData对象,该对象通过ResultSet对象调用getMetaData()来得到,且该对象包含所查询的数据表的所有信息。
    • ②.创建一个Map < String, Object>对象,键:列别名 值:列的值
    • ③.处理结果集,利用ResultSetMetaData填充3对应的Map对象,ResultSetMetaData对象调用getColumnLabel(int) 获取键:列别名ResultSet对象调用getObject()方法获取值:列中值。把键值对存到Map中去。
    • ④.若Map不为空集,利用反射创建clazz对应的对象。 类名.class.newInstance()。
    • ⑤.遍历Map对象,利用反射为Class对象的对应的属性赋值
  • 4.why:

    为什么要使用这个类,因为查询时方法类似,很多代码雷同,重复的代码太多。

  • 5.what:

    通用的查询方法,可以根据传入的SQL、SQL是占位符的值、Class对象返回SQL对应的记录的对象。
    • ①方法签名:public T ResultSetMetaData(Class clazz,String sql,Object … args)
  • 6.how:

    • ①:根据连接(connection)创建PreparedStatement对象。
    • ②:设置sql语句的占位符的值。
    • ③:通过PreparedStatement对象执行查询得到ResultSet对象(结果集)。
    • ④:ResultSet对象调用getMetaData获得ResultSetMetaData对象,该对象包含所查询的数据表的信息。
    • ⑤:创建一个Map < String, Object>对象,键:列别名 值:列的值。
    • ⑥:处理结果集,利用ResultSetMetaData填充3对应的Map对象,处理多个列。
    • ⑦:若Map不为空集,利用反射创建clazz对应的对象。
    • ⑧:遍历Map对象,利用反射为Class对象的对应的属性赋值。
    • ⑨:关闭链接。
  • 总结:使用反射获取到列别名和列值,存到集合中,再把集合中的数据赋给类成员变量

  • 实例:

public class DataBaseMetaData_5 {

    /**
* 1.DataBaseMetaData是描述数据库的元数据对象,测试DataBaseMetaData类的一些基本方法。
* 了解
*/
@Test
public void testDataBaseMetaData(){
Connection conn = null;
DatabaseMetaData dbmd = null;
ResultSet rs = null;
try {
conn = TestTools.getConnection();
dbmd = conn.getMetaData();
//获取驱动连接
System.out.println("驱动:"+dbmd.getURL());
//查看数据库版本号
System.out.println("版本号:"+dbmd.getDatabaseMajorVersion());
//查看MySql中有哪些数据库
rs = dbmd.getCatalogs();
while(rs.next()){
System.out.println("数据库:"+rs.getString(1));
} //.... } catch (Exception e) {
e.printStackTrace();
}finally{
TestTools.release(null, conn);
}
}
/**
* 2.ResultSetMetaData是描述结果集的元数据对象
*可以得到结果集的基本信息,比如结果集中有那些列、列名、别名、列值
*掌握
*/
@Test
public void ResultSetMetaData(){
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conn = TestTools.getConnection();
String sql = "select id, name, age, birth, address from customers";
ps = conn.prepareStatement(sql);
rs = ps.executeQuery();
//1.得到ResultSetMetaData对象
ResultSetMetaData rsmd = rs.getMetaData();
//2.获得列个数
System.out.println("列数:"+rsmd.getColumnCount());
//3.获得列名
for(int i = 0; i < rsmd.getColumnCount(); i++){
System.out.println("第"+(i+1)+"列别名:"+rsmd.getColumnLabel(i + 1));
}
//4.获得列别名
for(int i = 0; i < rsmd.getColumnCount(); i++){
System.out.println("第"+(i+1)+"列名:"+rsmd.getColumnName(i + 1));
}
} catch (Exception e) {
e.printStackTrace();
}finally{
TestTools.release(rs, ps, conn);
}
} /**
* 3.获取Student对象对应的数据表中的根据SQL语句查询到的记录信息。
* 获取ResultSetMetaData对象,并且调用getMetaData()方法,获取所有列的信息(主要是列名)
*把得到的列名存到集合HashMap()中。
*/
@Test
public void testResultSetMetaData(){
Student student = null;
Connection conn = null;
Statement state = null;
ResultSet rs = null;
try {
conn = TestTools.getConnection();
state = conn.createStatement();
String sql = "select * from examStudent";
rs = state.executeQuery(sql); //1.得到ResultSetMetaData对象,该对象包含了数据库表的一些信息
ResultSetMetaData rsmd = rs.getMetaData();
//2.创建一个Map<String, Object>对象,键:列别名 值:列的值
Map<String, Object> values = new HashMap<String, Object>();
//3.处理结果集,利用ResultSetMetaData填充3对应的Map对象
while(rs.next()){//若有多个对象,则处理多个对象
//处理多个列
for(int i = 0; i < rsmd.getColumnCount(); i++){
String columnLabel = rsmd.getColumnLabel(i + 1);//列从1开始
Object columnValues = rs.getObject(columnLabel);
values.put(columnLabel, columnValues);
}
//System.out.println(values);
} //4.若Map不为空集,利用反射创建clazz对应的对象。
Class clazz = Student.class;
student = (Student)clazz.newInstance(); //5.遍历Map对象,利用反射为Class对象的对应的属性赋值
for(Map.Entry<String, Object> entry : values.entrySet()){
String fieldName = entry.getKey();
Object fieldValue = entry.getValue();
//把存到Map集合中的元素赋值给Student对象的成员属性
TestTools.setFieldValue(student, fieldName, fieldValue);
}
//6.查看结果
//System.out.println(student.toString()); } catch (SQLException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}finally{
//5.关闭连接
TestTools.release(rs, state, conn);
}
System.out.println(student);
} /**
* 4.对以上方法进行了修改,以增加通用性,以上方法只能获取Student的对象的,则该方法可以获取根据传入的Class来返回
*任意的对象。
*/
public <T> T ResultSetMetaData(Class<T> clazz,String sql,Object ... args){
T entity = null;
Connection conn = null;
PreparedStatement preparedstatement = null;
ResultSet rs = null;
//System.out.println(clazz+"--"+sql+"--"+args);
try {
conn = TestTools.getConnection();
preparedstatement = conn.prepareStatement(sql);
for(int i = 0;i < args.length; i++){
preparedstatement.setObject(i+1, args[i]);
}
rs = preparedstatement.executeQuery(); //1.得到ResultSetMetaData对象,该对象包含了数据库表的一些信息
ResultSetMetaData rsmd = rs.getMetaData();
//2.创建一个Map<String, Object>对象,键:列别名 值:列的值
Map<String, Object> values = new HashMap<String, Object>();
//3.处理结果集,利用ResultSetMetaData填充3对应的Map对象
while(rs.next()){//若有多个对象,则处理多个对象
//处理多个列
for(int i = 0; i < rsmd.getColumnCount(); i++){
String columnLabel = rsmd.getColumnLabel(i + 1);//列从1开始
Object columnValues = rs.getObject(columnLabel);
values.put(columnLabel, columnValues);
}
//System.out.println(values);
} //4.若Map不为空集,利用反射创建clazz对应的对象。
if(values.size() > 0){
entity = clazz.newInstance();
//5.遍历Map对象,利用反射为Class对象的对应的属性赋值
for(Map.Entry<String, Object> entry : values.entrySet()){
String fieldName = entry.getKey();
Object fieldValue = entry.getValue();
TestTools.setFieldValue(entity,fieldName,fieldValue);
//System.out.println(fieldName +":"+fieldValue);
}
}
} catch (SQLException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}finally{
//5.关闭连接
TestTools.release(rs, preparedstatement, conn);
}
return entity;
} /**
* 5.测试以上方法:只需要传入Class对象、sql语句、占位符即可
*/ @Test
public void test(){
String sql = "select * from examStudent where FlowID = ?";
Student student = ResultSetMetaData(Student.class,sql,33);
System.out.println(student);
}
}
上一篇:linux系统中不同颜色的文件夹及根目录介绍


下一篇:基于FPGA视频时序生成中的库文件