getcustomerrecord.java

基于Struts的电子银行系统

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

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.sql.*;
import java.util.List;
import org.apache.commons.beanutils.RowSetDynaClass;
import banksystem.PO.Customer;
import banksystem.*;

/**
 * @author 曲本盛
 *
 * TODO Struts 项目实践
 */
public class GetCustomerRecord {
    
    /**
	 * @param dataSource 数据源.
	 * @param accountID 存储帐号ID.
	 * @return Customer 返回对应帐号的用户信息。
	 */
	public Customer getCustomer(DataSource dataSource,String accountID) throws SQLException{
		Connection con = null;
		PreparedStatement stat = null;
		ResultSet result = null;
		try{
			con = dataSource.getConnection();
			stat = con.prepareStatement(Constants.SQL_CUSTOMER_SELECT+" Where AccountID=?");
			stat.setString(1,accountID);
			System.out.println(accountID);
			result = stat.executeQuery();
			if(result.next()){
			return new Customer(result.getString(1),result.getString(2),result.getString(3),
					result.getString(4),result.getString(5),
					result.getString(6),result.getString(7),
					result.getString(8),result.getString(9),
					Double.valueOf(result.getDouble(10)),result.getString(11));
			}
			else{
				throw new SQLException(Constants.ERRORS_NO_RECORD_EXCEPTION);
			}
		}
		catch(SQLException e){
			e.printStackTrace();
			//e.fillInStackTrace();
			throw e;
		}
		finally{
			try{
				if(con!=null){
					con.close();
				}
				if(stat!=null){
					stat.close();
				}
			}
			catch(SQLException e){
				throw e;
			}
		}
	}
	public List getCustomers(DataSource dataSource,SearchGene gene)throws SQLException{
		Connection con = null;
		PreparedStatement stat = null;
		try{
			con = dataSource.getConnection();
			stat = con.prepareStatement(Constants.SQL_CUSTOMER_SELECT+gene.getCustomerWhereStr());
			ResultSet result = stat.executeQuery();
			//用该类封装ResultSet
			RowSetDynaClass warpper = new RowSetDynaClass(result);
			//调用getRows方法返回一个List对象
			return warpper.getRows();
		}
		catch(SQLException e){
			e.fillInStackTrace();
			throw e;
		}
		finally{
			try{	
				if(con!=null){
					con.close();
				}
				if(stat!=null){
					stat.close();
				}
			}
			catch(SQLException e){
				e.fillInStackTrace();
				throw e;
			}
		}
	}
}