daorowmapper.java

项目支付宝批量打款,采用httpclient+spring +quarz实现.

package com.szhelper.pay.sql.util;

import java.sql.ResultSet;
import java.sql.SQLException;

import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.support.rowset.ResultSetWrappingSqlRowSetMetaData;
/**
 * 
 * @author fangxiang 
 * @date 2007-5-3
 * @version 1.0
 */

public class DaoRowMapper implements RowMapper {
	private Class rowObjectClass;
	
	public DaoRowMapper(Class rowObjectClass){
		this.rowObjectClass = rowObjectClass;
	}
	
    public Object mapRow(ResultSet rs, int index) throws SQLException {
        Object object;
		try {
			object = rowObjectClass.newInstance();
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
		
		ResultSetWrappingSqlRowSetMetaData wapping = new ResultSetWrappingSqlRowSetMetaData(rs.getMetaData());
		for(int i=1;i<=wapping.getColumnCount();i++){
			String name = wapping.getColumnName(i);
			Object value = rs.getObject(i);
			ReflectionUtils.setFieldVlaue(object, name, value);
		}

        return object;
    }
    
    public static Object mapRow(Class modelClass,ResultSet rs) throws SQLException {
        Object object;
		try {
			object = modelClass.newInstance();
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
		
		ResultSetWrappingSqlRowSetMetaData wapping = new ResultSetWrappingSqlRowSetMetaData(rs.getMetaData());
		for(int i=1;i<=wapping.getColumnCount();i++){
			String name = wapping.getColumnName(i);
			Object value = rs.getObject(i);
			ReflectionUtils.setFieldVlaue(object, name, value);
		}

        return object;
    }

}