gettraderecord.java

个人网上银行系统

/*
 * Created on 2005-7-26
 *
 */
package banksystem.business;

/**
 * @author 曲本盛
 *
 * TODO Struts 项目实践
 */
import java.util.*;
import java.sql.*;
import javax.sql.*;
import banksystem.Constants;
import org.apache.commons.beanutils.RowSetDynaClass;
public class GetTradeRecord {
    /**
	 * @param dataSource 数据源.
	 * @param gene 查询语句生成器.
	 * @return List 返回查询结果List。
	 */
	public List getTrades(DataSource dataSource,SearchGene gene) throws SQLException{
		Connection con = null;
		PreparedStatement stat = null;
		try{
			con = dataSource.getConnection();
			stat = con.prepareStatement(Constants.SQL_TRADE_SELECT+gene.getTradeWhereStr());
			ResultSet result = stat.executeQuery();
			//用该类封装ResultSet
			RowSetDynaClass warpper = new RowSetDynaClass(result);
			//调用getRows方法返回一个List对象
			return warpper.getRows();
		}
		catch(SQLException e){
			throw new SQLException(e.getMessage());	
		}
		finally{
			try{
			
				if(con!=null){
					con.close();
				}
				if(stat!=null){
					stat.close();
				}
			}
			catch(Exception e){
				throw new SQLException(e.getMessage());	
			}
		}
	}
}