java/jdbc简单的ebank电子银行系统

package com.ds07.ebank.biz; import java.sql.Connection; import java.sql.SQLException; import java.util.List; import com.ds07.ebank.entity.Account; import com.ds07.ebank.persist.AccountDAO; import com.ds07.ebank.persist.AccountDAOFactory; import com.ds07.ebank.util.JdbcUtil; /** * 业务层实现。 * 1）调用持久层的相关方法去实现业务逻辑； * 2）对事务进行控制，通过con对象的相关方法可以实现。 * a. 关闭自动提交：con.setAutoCommit(false); * b.提交事务：con.commit(); * c.回滚事务：con.rollback(); * @author Administrator * */ public class AccountServiceJdbcImpl implements AccountService { //从持久层工厂类获得dao private AccountDAO dao = AccountDAOFactory.getDAO(); public void createAccount(Account act) { Connection con = null; try { //获得数据库连接，用于事务管理。 con = JdbcUtil.getConnection(); //关闭自动提交 con.setAutoCommit(false); //开始事务 dao.insert(act); //提交事务 con.commit(); System.out.println("恭喜，开户成功！"); } catch (Exception e) { // TODO Auto-generated catch block try { //回滚事务 con.rollback(); } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } e.printStackTrace(); }finally{ //释放连接 JdbcUtil.close(con); } } public void deposite(String actNo, double amount) { // Connection con = null; try { con = JdbcUtil.getConnection(); con.setAutoCommit(false); //开始事务处理 //1)根据账户号查询账户 Account act = dao.selectByActNo(actNo); //2)给账户存款 act.deposite(amount); //3)更新账户 dao.update(act); con.commit(); } catch (Exception e) { try { con.rollback(); } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } e.printStackTrace(); }finally{ JdbcUtil.close(con); } } public double getBalance(String actNo) { // Account act = null; Connection con = null; try { con = JdbcUtil.getConnection(); con.setAutoCommit(false); //开始事务处理 //1)根据账户号查询账户 act = dao.selectByActNo(actNo); con.commit(); } catch (Exception e) { try { con.rollback(); } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } e.printStackTrace(); }finally{ JdbcUtil.close(con); } return act==null ? 0 : act.getBalance() ; } public void removeAccount(String actNo) { // Connection con = null; try { con = JdbcUtil.getConnection(); con.setAutoCommit(false); // dao.delete(actNo); con.commit(); } catch (Exception e) { try { con.rollback(); } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } e.printStackTrace(); }finally{ JdbcUtil.close(con); } } public void withdraw(String actNo, double amount) { // Connection con = null; try { con = JdbcUtil.getConnection(); con.setAutoCommit(false); //开始事务处理 //1)根据账户号查询账户 Account act = dao.selectByActNo(actNo); //2)给账户存款 act.withdraw(amount); //3)更新账户 dao.update(act); con.commit(); } catch (Exception e) { try { con.rollback(); } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } e.printStackTrace(); }finally{ JdbcUtil.close(con); } } public List<Account> queryAll() { List<Account> acts = null; // Connection con = null; try { con = JdbcUtil.getConnection(); con.setAutoCommit(false); //开始事务处理 acts = dao.selectAll(); con.commit(); } catch (Exception e) { try { con.rollback(); } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } e.printStackTrace(); }finally{ JdbcUtil.close(con); } return acts; } public Account queryByActNo(String actNo) { Account act = null; // Connection con = null; try { con = JdbcUtil.getConnection(); con.setAutoCommit(false); //开始事务处理 act = dao.selectByActNo(actNo); con.commit(); } catch (Exception e) { try { con.rollback(); } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } e.printStackTrace(); }finally{ JdbcUtil.close(con); } return act; } public void transfer(String from, String to, double amount) { Connection con = null; try { con = JdbcUtil.getConnection(); con.setAutoCommit(false); //开始事务 Account act = dao.selectByActNo(from); act.withdraw(amount); dao.update(act); act = dao.selectByActNo(to); act.deposite(amount); dao.update(act); //提交事务 con.commit(); } catch (Exception e) { // 回滚事务 try { con.rollback(); } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } e.printStackTrace(); }finally{ JdbcUtil.close(con); } } }