accountdao.java

基于jsp的固定资产管理系统,自己做的

package DAO;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.Iterator;

import VO.*;

public class AccountDAO {

	
	//返回account的Account类，如果不存在Account=null
	public Account getAnAccount(int account)
	{
		String sql="select * from account where acc_number=?";
		ConnectTo conto=new ConnectTo();
		Connection conn=conto.connect();
		PreparedStatement pstm=null;
		Account acc=null;
		if(conn!=null)
		{
			try{
				
				pstm=conn.prepareStatement(sql);
				pstm.setInt(1, account);
				ResultSet rs=pstm.executeQuery();
				if(rs.next())
				{
					acc=new Account();
					String ID=rs.getString("ID");
					int tel=rs.getInt("acc_number");
					String name=rs.getString("acc_name");
					String add=rs.getString("acc_add");
					int balance=rs.getInt("acc_balance");
					acc.setID(ID);
					acc.setAcc_number(tel);
					acc.setAcc_name(name);
					acc.setAcc_add(add);
					acc.setAcc_balance(balance);
				}
				
			}
			catch(Exception e)
			{
				e.printStackTrace();
				try
				{
					pstm.close();
					conn.close();
				}
				catch(Exception e1)
				{
					e1.printStackTrace();
				}
			}
			
		}
		return acc;
	}
	
	
	public int insertAccount(Account a)
	{
		String ID=a.getID();
		int number=a.getAcc_number();
		String add=a.getAcc_add();
		add=EncodingChange.getReadStr(add);
		int balance=a.getAcc_balance();
		String name=a.getAcc_name();
		name=EncodingChange.getReadStr(name);
		int k=-1;
		String sql="insert into account values(?,?,?,?,?)";
		ConnectTo conto=new ConnectTo();
		Connection conn=conto.connect();
		PreparedStatement pstm=null;
		if(conn!=null)
		{
			
			try{
			pstm=conn.prepareStatement(sql);
			pstm.setString(1,ID);
			pstm.setInt(2,number);
			pstm.setString(3,name);
			pstm.setString(4,add);
			pstm.setInt(5,balance);
			k=pstm.executeUpdate();
			pstm.close();
			conn.close();
			}
			catch(Exception e)
			{
				e.printStackTrace();
				try
				{
					pstm.close();
					conn.close();
					return k;
				}catch(Exception e1){e1.printStackTrace();}
			}
			
		}
		return k;
	}
	
	public int updateAccount(Account a)
	{
		int number=a.getAcc_number();
		int balance=a.getAcc_balance();
		int k=-1;
		String sql="update account set acc_balance=? where acc_number=?";
		ConnectTo conto=new ConnectTo();
		Connection conn=conto.connect();
		PreparedStatement pstm=null;
		if(conn!=null)
		{
			
			try{
			pstm=conn.prepareStatement(sql);
			pstm.setInt(1, balance);
			pstm.setInt(2,number);
			k=pstm.executeUpdate();
			pstm.close();
			conn.close();
			}
			catch(Exception e)
			{
				e.printStackTrace();
				try
				{
					pstm.close();
					conn.close();
					return k;
				}catch(Exception e1){e1.printStackTrace();}
			}
			
		}
		return k;
	}
}