accountdaojdbcimpl.java

加拿大达内科技有限公司配需java程序员的上课时的代码

package com.sd0709.bank.persistent;

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

import com.sd0709.bank.biz.entity.Account;
import com.sd0709.bank.util.JdbcUtil;

public class AccountDAOJdbcImpl implements IAccountDAO {

	public void delete(String actNo)throws DataException  {
		Connection con = null;
		PreparedStatement ps = null;
		String sql = "delete from t_sd0709_acct " +
				" where actNo=?";
		try {
			con = JdbcUtil.getConnection();
			con.setAutoCommit(false);
			ps = con.prepareStatement(sql);
			ps.setString(1, actNo);
			ps.executeUpdate();
			con.commit();
		} catch (SQLException e) {
			e.printStackTrace();
			if (con != null) {
				try {
					con.rollback();
				} catch (SQLException e1) {
					// TODO Auto-generated catch block
					e1.printStackTrace();
				}
			}
			throw new DataException();
		}finally{
			JdbcUtil.release(null, ps, con);
		}

	}

	public Account findByActNo(String actNo)throws DataException  {
		Account act = null;
		Connection con = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		String sql = "select * from t_sd0709_acct" +
				" where actNo=?"; 
		try {
			con = JdbcUtil.getConnection();
			con.setAutoCommit(false);
			ps = con.prepareStatement(sql);
			ps.setString(1, actNo);
			rs = ps.executeQuery();
			if(rs!=null){
			  rs.next();
			  act = new Account(rs.getString(1)
					  ,rs.getDouble(2));
			}
			con.commit();
		} catch (SQLException e) {
			e.printStackTrace();
			if (con != null) {
				try {
					con.rollback();
				} catch (SQLException e1) {
					// TODO Auto-generated catch block
					e1.printStackTrace();
				}
			}
			throw new DataException();
		}finally{
			JdbcUtil.release(rs, ps, con);
		}

		return act;
	}

	public void insert(Account act) throws DataException {
		Connection con = null;
		PreparedStatement ps = null;
		String sql = "insert into t_sd0709_acct "
			+ " values(?,?)";
		try {
			con = JdbcUtil.getConnection();
			con.setAutoCommit(false);
			ps = con.prepareStatement(sql);
			ps.setString(1, act.getActNo());
			ps.setDouble(2, act.getBal());
			ps.executeUpdate();
			con.commit();
		} catch (SQLException e) {
			e.printStackTrace();
			if (con != null) {
				try {
					con.rollback();
				} catch (SQLException e1) {
					// TODO Auto-generated catch block
					e1.printStackTrace();
				}
			}
			throw new DataException();
		}finally{
			JdbcUtil.release(null, ps, con);
		}
	}

	public void update(Account act)throws DataException  {
		Connection con = null;
		PreparedStatement ps = null;
		String sql = "update t_sd0709_acct " 
			+ " set actNo=? , bal=? where actNo=?";
		try {
			con = JdbcUtil.getConnection();
			con.setAutoCommit(false);
			ps = con.prepareStatement(sql);
			ps.setString(1, act.getActNo());
			ps.setDouble(2, act.getBal());
			ps.setString(3, act.getActNo());
			ps.executeUpdate();
			con.commit();
		} catch (SQLException e) {
			e.printStackTrace();
			if (con != null) {
				try {
					con.rollback();
				} catch (SQLException e1) {
					// TODO Auto-generated catch block
					e1.printStackTrace();
				}
			}
			throw new DataException();
		}finally{
			JdbcUtil.release(null, ps, con);
		}

	}

}