利用反射及JDBC元数据编写通用查询方法

元数据:描述数据的数据,ResultSetMetaData是描述ResultSet的元数据对象,从它可以得到数据集有多少了,每一列的列名。。。

ResultSetMetaData可以通过ResultSet类的getMetaData()获得。

ResultSetMetaData中的方法:

  ->getColumnCount():获取数据集有多少列

  ->getColumnLabel(int column):获取指定列的列名,索引从1开始

步骤:

1、利用sql进行查询,得到结果集,查询时应该给出列的别名,别名要和类的对象的属性名对应;

2、利用反射创建实体类的对象;

3、获取结果集的列的别名;

4、再获取结果集中每一列的值,结合步骤3得到一个Map,键为列名,值为对应的值;

5、利用反射给实体对象的属性赋值。

 public <T> T get(Class<T> clazz, String sql,Object ... args){
T entity = null;
Connection connection = null;
PreparedStatement preparedStatement = null;
ResultSet resultSet = null; try {
//1、进行sql查询,获取resultSet对象
connection = jdbcTools.getConnection();
preparedStatement = connection.prepareStatement(sql); for(i=0;i<args.length;i++){
preparedStatement.setObject(i+1,args[i]);
}
resultSet = preparedStatement.executeQuery(); //2、获取数据集元数据,即ResultSetMetaData对象
ResultSetMetaData rsmd = resultSet.getMetaData(); //3和4,获取列名和值,创建map对象
Map<String,Object> values = new HashMap<String,Object>(); while(resultSet.next()){
for(int i = 0;i<rsmd.getColumnCount();i++){ String columnLabel = rsmd.getColumnLabel(i+1);
Object columnValue = resultSet.getObject(columnLabel);
values.put(columnLabel,columnValue); }
} //5、创建实例,并通过反射赋值
entity = clazz.newInstance(); for(Map.Entry<String,Object> entry: values.entrySet()){
String fieldName = entry.getKey();
Object fieldValue = entry.getValue();
///反射工具类需要自己实现
//ReflectUtils.setFieldValue(entity,fieldName,fieldValue);
          BeanUtils.setProperty(entity,fieldname,fieldValue);
} }catch (Exception e){
e.printStackTrace(); }finally {
jdbcTools.releaseResource(resultSet,preparedStatement,connection);
}
return entity;
}

上面的方法是返回一个对象,如果需要返回多条记录,则需要重新写一个方法

  public <T> List<T> getForList(Class<T> clazz, String sql, Object...args) throws Exception{
List<T> list = null;
Connection connection = null;
PreparedStatement preparedStatement = null;
ResultSet resultSet = null; try{
connection = jdbcTools.getConnection();
preparedStatement = connection.prepareStatement(sql);
for(int i = 0;i<args.length;i++){
preparedStatement.setObject(i+1,args[i]);
} resultSet = preparedStatement.executeQuery();
ResultSetMetaData rsmd = resultSet.getMetaData();
List<Map<String,Object>> values = new ArrayList<Map<String, Object>>(); Map<String,Object> map = null; while(resultSet.next()){
map = new HashMap<String, Object>();
for(int i = 0;i< rsmd.getColumnCount();i++){
String fieldName = rsmd.getColumnLabel(i+1);
Object object = resultSet.getObject(i+1);
map.put(fieldName,object);
}
values.add(map);
} T bean = null;
if(values != null ){
for(Map<String,Object> m: values){
for(Map.Entry<String,Object> entry : m.entrySet()) {
String fieldName = entry.getKey();
Object fieldValue = entry.getValue();
bean = clazz.newInstance();
BeanUtils.setProperty(bean,fieldName,fieldValue); }
list.add(bean);
}
} }catch (Exception e){
e.printStackTrace();
}finally {
jdbcTools.releaseResource(resultSet,preparedStatement,connection);
} return list; }
上一篇:Ubuntu16.04下安装VS Code


下一篇:VMware Workstation 12 安装mac os x 10.11