accountmanagedao.java

这是我们做的一个网上购物系统,包手用户和管理员两大功能模块,采用jsp+servlet+java bean技术.

package com.qyg.shop.account;

import java.util.ArrayList;
import java.util.List;
import java.sql.*;

import com.qyg.database.DbOperatorHandle;
import com.qyg.shop.user.*;

import com.sun.corba.se.impl.ior.NewObjectKeyTemplateBase;

public class AccountManageDAO implements AccountDAO {
	private DbOperatorHandle doh=null;
	public AccountManageDAO(){
		doh=new DbOperatorHandle();
	}
	
	public void add(Account ac) {
		// TODO Auto-generated method stub
		try {
			PreparedStatement ps=doh.getCon().prepareStatement("insert account values(null,?,?)");
			ps.setInt(1, ac.getAccount_userId());
			ps.setDouble(2, ac.getAccount_money());
			ps.execute();
			ps.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			System.out.print("充值申请失败");
			e.printStackTrace();
		}
		finally{
			doh.closeCon();
		}
	}
	/**
	 * 冲值完后，根据申请号，删除申请
	 */
	public void delete(int account_id) {
		try{
			Statement st=doh.getCon().createStatement();
			String sql="select * from account where account_id="+account_id;
			ResultSet rs=st.executeQuery(sql);
			if(rs.next()){
				new UserManageDAO().addMoneyById(rs.getInt(2), rs.getDouble(3));
			}
			rs.close();
			sql="delete from account where account_id="+account_id;
			st.execute(sql);
			st.close();
		}
		catch (Exception e) {
			// TODO: handle exception
			System.out.print("冲值完后，根据申请号，删除申请");
			e.printStackTrace();
		}
		finally{
			doh.closeCon();
		}
	}
	
	/**
	 * 得到所有的冲值申请
	 */
	public List<Account> getAllAccounts() {
		List<Account> accounts=null;
		try{
			accounts=new ArrayList<Account>();
			Statement st=doh.getCon().createStatement();
			//System.out.print("rs.getInt(1)");
			ResultSet rs=st.executeQuery("select * from account");
			while(rs.next())
			{
				Account account=this.getAccountByRs(rs);
				accounts.add(account);
			}
			rs.close();
			st.close();
		}
		catch (Exception e) {
			// TODO: handle exception
			System.out.println("得到所有冲值申请wrong");
		}
		finally{
			doh.closeCon();
		}
		// TODO Auto-generated method stub	y
		return accounts;
	}

	/**
	 * 根据rs得到具体冲值信息
	 */
	public Account getAccountByRs(ResultSet rs) {
		// TODO Auto-generated method stub
		Account account=null;
		try{
			account=new Account();
			account.setAccount_id(rs.getInt(1));
			account.setAccount_userId(rs.getInt(2));
			account.setAccount_money(rs.getDouble(3));
		}
		catch (Exception e) {
			// TODO: handle exception
			System.out.println("根据rs得到具体冲值信息");
		}
		return account;
	}
	//得到冲值记录数
	public int getTotalOfAccounts() {
		// TODO Auto-generated method stub
		int totalNumber=0;
		try{
			Statement st=doh.getCon().createStatement();
			ResultSet rs=st.executeQuery("select count(*) as total from account");
			while(rs.next())
			{
				totalNumber=rs.getInt(1);
			}
			rs.close();
			st.close();
		}
		catch (Exception e) {
			// TODO: handle exception
			System.out.println("");
		}
		finally{
			doh.closeCon();
		}
		return totalNumber;
	}

	public List<Account> getIndexOfPageAccounts(int pageSize, int currentPage) {
		// TODO Auto-generated method stub
		return null;
	}
	public static void main(String[] args){
		AccountManageDAO dao=new AccountManageDAO();
//		List<Account> l=dao.getAllAccounts();
//		for(int i=0;i<l.size();i++){
//			Account a=l.get(i);
//			System.out.print(a.getAccount_money());
//		}
//		System.out.print("112");
		Account ac = new Account();
		ac.setAccount_userId(12);
		ac.setAccount_money(3333.0);
		dao.add(ac);
	}
}