accountdao.java

新东方软件开发项目

package com.mobile.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.mobile.bean.TAccount;


public class AccountDAO {
	
	
	
	public TAccount checkAccountDAO(int num){
		
		Connection con=null;
		 TAccount ta=null;
		 Statement pstmt =null;
		 ResultSet rs =null;
		 try {
			con=ConnectionMgr.getConnection();
			pstmt =con.createStatement();
			String s = "select * from TAccount where Account_ID="+num;
			System.out.println(s);
		 rs = pstmt.executeQuery(s);
			while(rs.next()){
				 ta = new TAccount();
				 ta.setAccount_ID(rs.getInt(1));
				 ta.setContactPerson(rs.getString(2));
				 ta.setContactAddress(rs.getString(3));
				 ta.setAccountBalance(rs.getInt(4));
				 System.out.println("Ta = " + ta.getAccount_ID());
			}
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			ConnectionMgr.closeResource(con, pstmt, rs);
		}
		System.out.println(ta);
		return ta;
		
	}
	
	
	
	
	
	public int addAccount(TAccount account)
	{
		int ret = 0;
		Connection con=null;
		PreparedStatement pstmt;
		
			
			try {
				con=ConnectionMgr.getConnection();
				pstmt = con.prepareStatement("insert into TAccount(Account_ID,contact_person,contact_address,account_balance) values("+account.getAccount_ID()+",?,?,?)");
				
				pstmt.setString(1, account.getContactPerson());
				pstmt.setString(2, account.getContactAddress());
				pstmt.setFloat(3, account.getAccountBalance());
				ret = pstmt.executeUpdate();
			} catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
			
	
	
		return ret;
	}
}