JDBC 查询 Map转对象

虽然项目中都夹杂了Hibernate的支持，但是团队开发中，很多人为了编写特殊查询的代码时都使用了JDBC进行查询。JDBC查询后返回的是一个List集合，List中组装的是Map，一个Map就是一个对应的对象。但是接口不能直接返回Map，都是返回的对象，以方便自己和其他人使用，为了转换这个Map，往往写这样的代码：

@SuppressWarnings("unchecked")
public static MS_Mont analyzeMapToMS_Mont(Map map){
	MS_Mont obj = new MS_Mont();
	if(null != map.get("montNo")) obj.setMontNo(Integer.parseInt(map.get("montNo").toString()));
	if(null != map.get("montName")) obj.setMontName(map.get("montName").toString());
	if(null != map.get("montType")) obj.setMontType(Integer.parseInt(map.get("montType").toString()));
	if(null != map.get("montLength")) obj.setMontLength(Integer.parseInt(map.get("montLength").toString()));
	if(null != map.get("montDesc")) obj.setMontDesc(map.get("montDesc").toString());
	if(null != map.get("bigType")) obj.setBigType(Integer.parseInt(map.get("bigType").toString()));
	if(null != map.get("bigTypeName")) obj.setBigTypeName(map.get("bigTypeName").toString());
	if(null != map.get("littleType")) obj.setLittleType(Integer.parseInt(map.get("littleType").toString()));
	if(null != map.get("littleTypeName")) obj.setLittleTypeName(map.get("littleTypeName").toString());
	if(null != map.get("insertTime")) obj.setInsertTime(map.get("insertTime").toString());
	if(null != map.get("updateTime")) obj.setUpdateTime(map.get("updateTime").toString());
	if(null != map.get("userNoRe")) obj.setUserNoRe(Integer.parseInt(map.get("userNoRe").toString()));
	if(null != map.get("userNoLast")) obj.setUserNoLast(Integer.parseInt(map.get("userNoLast").toString()));
	return obj;
}

 

很麻烦，很多，很枯燥。
为了解决这个问题，我列出一个解决方法，写一个方法，传入要赋值的对象和Map，然后根据列的属性名称从Map中获得响应的值，然后赋值给这个对象的属性。
例如，这里写了一个简单的查询：

 

public CM_Line getObjectBean(int lineNo) {
	try {
		String sql = "select * from cm_line where lineNo=?";
		Object[] obj = new Object[]{ lineNo };
		List rows = jdbcTemplate.queryForList( sql, obj );
		if(null != rows && rows.size() > 0) {
			CM_Line line = new CM_Line();
			return (CM_Line) line.analyzeMap((Map)rows.get(0));
		} else {
			return null;
		}
	} catch (Exception e) {
		logger.error(e);
	}
	return null;
}

 

然后我们调用了他的analyzeMap方法，这个方法把当前对象当作要赋值的对象，然后调用公用方法进行组装：

public Object analyzeMap(Map<String, Object> para){
	Object obj = this;
	ObjectUtil.setValToObj(obj, para);
	return obj;
}

 

公用方法：

public synchronized static void setValToObj(Object entityName, Map<String, Object> para){
	try {
		Class c = entityName.getClass();
		// 获得对象属性   
        Field field[] = c.getDeclaredFields();
        for (Field f : field) { 
        	try {
        		PropertyDescriptor pd = new PropertyDescriptor(f.getName(), c);  
                Method writeMethod = pd.getWriteMethod();
                if(!CommonCheck.isNullOrEmpty(para.get(f.getName())))
                	writeMethod.invoke(entityName, para.get(f.getName()));
			} catch (Exception e) {
			}
        }
	} catch (Exception e) {
	}
}

 

下面就有人说了，那根据对象获得这个对象的Map怎么搞，这个之前已经写过了，不这里仍然把代码放一下：

/**    
 * 返回一个对象的属性和属性值
 */     
public synchronized static LinkedHashMap<String,String> getProAndValMap(Object entityName) {    
	LinkedHashMap<String,String> map = new LinkedHashMap<String, String>();   
    try {   
        Class c = entityName.getClass();   
        // 获得对象属性   
        Field field[] = c.getDeclaredFields();      
        for (Field f : field) {
            Object v = invokeMethod(entityName, f.getName(), null);   
            if(null != v) map.put(f.getName(), v.toString());
            else  map.put(f.getName(), "");
        }   
    } catch (Exception e) {   
        map = null;   
    }   
    return map;   
}
/**
 * 获得对象属性的值
 */
private synchronized static Object invokeMethod(Object owner, String methodName,
		Object[] args) throws Exception {
	Class ownerClass = owner.getClass();
	methodName = methodName.substring(0, 1).toUpperCase() + methodName.substring(1);
	Method method = null;
	try {
		method = ownerClass.getMethod("get" + methodName);
	} catch (Exception e) {
	}
	return method.invoke(owner);
}

 

请您到ITEYE网站看原创，谢谢！

http://cuisuqiang.iteye.com/ ！ 

自建博客地址：http://www.javacui.com/ ，内容与ITEYE同步！

评论

21 楼 cuisuqiang 2013-08-23  

zhuchao_ko 写道

QueryRunner runner = new QueryRunner();//1
Connection connection = 得到连接;
List<Object> list = new ArrayList<Object>();
List<Map<String, Object>> result = runner.query(connection,
"select 字段 from 表", new MapListHandler(),
list.toArray());//2
connection.close();//关闭


就1,2两行。如果不喜欢ORM框架用这个是非常好的。封装成对象也影响效率。

谢谢

20 楼 zhuchao_ko 2013-08-23  

QueryRunner runner = new QueryRunner();//1
Connection connection = 得到连接;
List<Object> list = new ArrayList<Object>();
List<Map<String, Object>> result = runner.query(connection,
"select 字段 from 表", new MapListHandler(),
list.toArray());//2
connection.close();//关闭


就1,2两行。如果不喜欢ORM框架用这个是非常好的。封装成对象也影响效率。

19 楼 cuisuqiang 2013-08-23  

zhuchao_ko 写道

APACHE.ORG上有个 common-dbutil 轮子，
你的轮子圆还是这个轮子圆？

谢谢

18 楼 zhuchao_ko 2013-08-23  

APACHE.ORG上有个 common-dbutil 轮子，
你的轮子圆还是这个轮子圆？

17 楼 cuisuqiang 2013-08-21  

shanlingyunjavafuns 写道

楼主的这个解决方式，是用了java的反射机制，注入值的。

是的

16 楼 cuisuqiang 2013-08-21  

55757353 写道

Object 转换Map：org.apache.commons.beanutils.BeanMap
Map转换Object： org.apache.commons.beanutils.BeanUtils

非常感谢

15 楼 55757353 2013-08-21  

Object 转换Map：org.apache.commons.beanutils.BeanMap
Map转换Object： org.apache.commons.beanutils.BeanUtils

14 楼 shanlingyunjavafuns 2013-08-20  

楼主的这个解决方式，是用了java的反射机制，注入值的。

13 楼 cuisuqiang 2013-08-19  

eric023 写道

既然你都说Map就是一个对应的对象，为嘛还要转换为对象呢？

Map里有各个key对应表的各个列

12 楼 eric023 2013-08-19  

既然你都说Map就是一个对应的对象，为嘛还要转换为对象呢？

11 楼 cuisuqiang 2013-08-19  

forcer521 写道

spring 3.2

BeanPropertyRowMapper<YourBeanClass> mapper = new BeanPropertyRowMapper<YourBeanClass>(YourBeanClass.class);

SqlParameterSource sqlParam = new BeanPropertySqlParameterSource(keyword);

//NamedParameterJdbcTemplate template = 设置好的自动注入的;

List<YourBeanClass> taskList = template.query(sqlString,sqlParam,mapper);


返回对象和map的list都是可以的，干嘛自己写那么多呢。。

会用，也要会写

10 楼 forcer521 2013-08-19  

spring 3.2

BeanPropertyRowMapper<YourBeanClass> mapper = new BeanPropertyRowMapper<YourBeanClass>(YourBeanClass.class);

SqlParameterSource sqlParam = new BeanPropertySqlParameterSource(keyword);

//NamedParameterJdbcTemplate template = 设置好的自动注入的;

List<YourBeanClass> taskList = template.query(sqlString,sqlParam,mapper);


返回对象和map的list都是可以的，干嘛自己写那么多呢。。

9 楼 cuisuqiang 2013-08-19  

leonayx123 写道

cuisuqiang 写道

leonayx123 写道

试试spring jdbcTemplate的 queryForList()

我用的就是带参数的queryForList，他是不返回对象的

你说他返回的都是map<String,Object>?你想拿到具体的对象而不是Object么？
可以写一个RowMapper。然后用query(sql,RowMapper)

多谢指导

8 楼 cuisuqiang 2013-08-19  

pharaohsprince 写道

另外：
Common Dbutils 组件也有更简单的方法：
QueryRunner(dataSource).queryForOList(sql, null, Object.class);     

非常感谢分享

7 楼 pharaohsprince 2013-08-19  

另外：
Common Dbutils 组件也有更简单的方法：
QueryRunner(dataSource).queryForOList(sql, null, Object.class);     

6 楼 pharaohsprince 2013-08-19  

http://blog.csdn.net/rainier001/article/details/6947968

近日系统有一个打印采购单的功能，发现连续打印多张后，主机宕机，看了下service和dao层的实现，很繁杂，估计原因主要出在组页面资料的时候，循环套循环导致效能下降，然后想想有什么办法可以减少组资料时的一些对象转换，dao层取回来的是map，然后还要转换成vo，然后又循环组资料，google下资料，发现jdbctemplate查询还有个query方法，可以直接在查好后返回你需要的vo，改好上线，不知道对效能有没有帮助，不过这个做法感觉不错，特把文章贴在blog里面，以备后用，呵呵


   
在内部建立内联类实现RowMapper接口
package hysteria.contact.dao.impl;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import java.util.List;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import hysteria.contact.dao.ItemDAO;
import hysteria.contact.domain.Item;
public class ItemDAOImpl implements ItemDAO {
private JdbcTemplate jdbcTemplate;
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
  this.jdbcTemplate = jdbcTemplate;
}
public Item insert(Item item) {
  String sql = "INSERT INTO items(user_id,name,phone,email) VALUES(?,?,?,?)";
  Object[] params = new Object[]{item.getUserId(),item.getName(),item.getPhone(),item.getEmail()};
  int[] types = new int[]{Types.INTEGER,Types.VARCHAR,Types.CHAR,Types.VARCHAR};
  jdbcTemplate.update(sql,params,types);
  return item;
}
public Item update(Item item) {
  String sql = "UPDATE items SET name = ?, phone = ?, email = ? WHERE id = ?";
  Object[] params = new Object[] {item.getName(),item.getPhone(),item.getEmail(),item.getId()};
  int[] types = new int[] {Types.VARCHAR,Types.CHAR,Types.VARCHAR,Types.VARCHAR,Types.INTEGER};
  jdbcTemplate.update(sql,params,types);
  return item;
}
public void delete(Item item) {
  String sql = "DELETE FROM items WHERE id = ?";
  Object[] params = new Object[] {item.getId()};
  int[] types = new int[]{Types.INTEGER};
  jdbcTemplate.update(sql,params,types);
}
public Item findById(int id) {
  String sql = "SELECT * FROM items WHERE id = ?";
  Object[] params = new Object[] {id};
  int[] types = new int[] {Types.INTEGER};
  List items = jdbcTemplate.query(sql,params,types,new ItemMapper());
  if(items.isEmpty()){
   return null;
  }
  return (Item)items.get(0);
}
public List<Item> findAll() {
  String sql = "SELECT * FROM items";
  return jdbcTemplate.query(sql,new ItemMapper());
}
public List<Item> findAllByUser(int user_id) {
  String sql = "SELECT * FROM items WHERE user_id = ?";
  Object[] params = new Object[]{user_id};
  int[] types = new int[]{Types.INTEGER};
  List items = jdbcTemplate.query(sql,params,types,new ItemMapper());
  return items;
}
protected class ItemMapper implements RowMapper {
  public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
   Item item = new Item();
   item.setId(rs.getInt("id"));
   item.setUserId(rs.getInt("user_id"));
   item.setName(rs.getString("name"));
   item.setPhone(rs.getString("phone"));
   item.setEmail(rs.getString("email"));
   return item;
  }
}
}

5 楼 leonayx123 2013-08-19  

cuisuqiang 写道

leonayx123 写道

试试spring jdbcTemplate的 queryForList()

我用的就是带参数的queryForList，他是不返回对象的

你说他返回的都是map<String,Object>?你想拿到具体的对象而不是Object么？
可以写一个RowMapper。然后用query(sql,RowMapper)

4 楼 cuisuqiang 2013-08-19  

leonayx123 写道

试试spring jdbcTemplate的 queryForList()

我用的就是带参数的queryForList，他是不返回对象的

3 楼 leonayx123 2013-08-19  

试试spring jdbcTemplate的 queryForList()

2 楼 cuisuqiang 2013-08-19  

pharaohsprince 写道

jdbcTemplate 里早就提供了类似的方法：
jdbcTemplate.queryForObject(sql, rowMapper)

如果查询返回的是List？