银行账务转账系统(事务处理)
生活随笔
收集整理的這篇文章主要介紹了
银行账务转账系统(事务处理)
小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
流程如下：
創(chuàng)建項(xiàng)目工程如下：
transfer包下的代碼如下：
package beyond.transfer.dao;import java.sql.Connection; import java.sql.SQLException;import org.apache.commons.dbutils.QueryRunner;import beyond.utils.DataSourceUtils;public class TransferDao {public void out(Connection conn,String out, double money) throws SQLException {QueryRunner runner = new QueryRunner();//不用穿參數(shù)//Connection conn = DataSourceUtils.getConnection();String sql = "update account set money= money-? where name=?";runner.update(conn, sql, money,out);}public void in(Connection conn,String in, double money) throws SQLException {QueryRunner runner = new QueryRunner();//不用穿參數(shù)//Connection conn = DataSourceUtils.getConnection();String sql = "update account set money= money+? where name=?";runner.update(conn, sql, money,in);}} package beyond.transfer.service;import java.sql.Connection; import java.sql.SQLException;import beyond.transfer.dao.TransferDao; import beyond.utils.DataSourceUtils;public class TransferService {public boolean transfer(String out, String in, double money) {//創(chuàng)建dao層對(duì)象TransferDao dao = new TransferDao();boolean isTransferSuccess = true;Connection conn = null;try {//進(jìn)行事務(wù)控制，開(kāi)啟事務(wù)conn = DataSourceUtils.getConnection();//不自動(dòng)開(kāi)啟事務(wù)，也就是手動(dòng)開(kāi)啟事務(wù)conn.setAutoCommit(false);//調(diào)用dao層的轉(zhuǎn)出錢的方法,只需要知道 轉(zhuǎn)錢的人是誰(shuí) 跟 錢數(shù) 就行dao.out(conn,out,money);//調(diào)用dao層的轉(zhuǎn)入錢的方法,只需要知道 轉(zhuǎn)給誰(shuí) 跟 錢數(shù) 就行dao.in(conn,in,money);} catch (SQLException e) {isTransferSuccess = false;try {//當(dāng)出現(xiàn)事務(wù)錯(cuò)誤，進(jìn)行事務(wù)的回滾；回滾本身內(nèi)部不包含提交的功能conn.rollback();} catch (SQLException e1) {e1.printStackTrace();}e.printStackTrace();}finally{try {conn.commit();} catch (SQLException e) {e.printStackTrace();}}return isTransferSuccess;}} package beyond.transfer.web;import java.io.IOException; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse;import beyond.transfer.service.TransferService;public class TransferServlet extends HttpServlet {public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {//接收轉(zhuǎn)賬的參數(shù)String out = request.getParameter("out");String in = request.getParameter("in");String moneyStr = request.getParameter("money");double money=Double.parseDouble(moneyStr);//進(jìn)行將轉(zhuǎn)賬金額強(qiáng)轉(zhuǎn)//調(diào)用業(yè)務(wù)層的轉(zhuǎn)賬方法TransferService service = new TransferService();boolean isTransferSuccess = service.transfer(out,in,money);//解決亂碼問(wèn)題response.setContentType("text/html;charset=UTF-8");if(isTransferSuccess){response.getWriter().write("轉(zhuǎn)賬成功！！！");}else{response.getWriter().write("轉(zhuǎn)賬失敗！！！");}}public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {doGet(request, response);} }transfer.jsp代碼如下：
<%@ page language="java" contentType="text/html; charset=UTF-8"pageEncoding="UTF-8"%> <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> <html> <head> <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> <title>Insert title here</title> </head> <body><form action="${pageContext.request.contextPath}/transfer" method="post">傳出賬戶:<input type="text" name="out"><br/>傳入賬戶:<input type="text" name="in"><br/>轉(zhuǎn)轉(zhuǎn)金額:<input type="text" name="money"><br/><input type="submit" value="確認(rèn)轉(zhuǎn)賬"><br/></form> </body> </html>數(shù)據(jù)庫(kù)創(chuàng)建如下：
CREATE TABLE `account` (`id` int(11) NOT NULL AUTO_INCREMENT,`name` varchar(30) DEFAULT NULL,`money` double DEFAULT NULL,UNIQUE KEY `id` (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8dbutils包下代碼如下：
package beyond.jdbc;import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement;public class JDBCDemo {public static void main(String[] args) {//通過(guò)jdbc去控制事務(wù)Connection conn = null;try {//1,注冊(cè)驅(qū)動(dòng) Class.forName("com.mysql.jdbc.Driver");//2,獲得connectionconn = DriverManager.getConnection("jdbc:mysql:///web19","root","wsq");//三個(gè)///代表本地一個(gè)端口//手動(dòng)開(kāi)啟事務(wù)conn.setAutoCommit(false);//是否自動(dòng)提交false，代表不自動(dòng)提交也就是手動(dòng)提交//3，獲得操作數(shù)據(jù)庫(kù)對(duì)象(執(zhí)行平臺(tái))Statement stmt = conn.createStatement();//4,操作sql//stmt.executeUpdate("insert into account values(null,'zhangsan',3000)");int executeUpdate = stmt.executeUpdate("update account set money=5000 where name='sq'");//提交事務(wù)conn.commit();stmt.close();conn.close();} catch (Exception e) {try {conn.rollback();} catch (SQLException e1) {e1.printStackTrace();}e.printStackTrace();}} }jdbc包下代碼如下：
package beyond.jdbc;import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement;public class JDBCDemo {public static void main(String[] args) {//通過(guò)jdbc去控制事務(wù)Connection conn = null;try {//1,注冊(cè)驅(qū)動(dòng) Class.forName("com.mysql.jdbc.Driver");//2,獲得connectionconn = DriverManager.getConnection("jdbc:mysql:///web19","root","wsq");//三個(gè)///代表本地一個(gè)端口//手動(dòng)開(kāi)啟事務(wù)conn.setAutoCommit(false);//是否自動(dòng)提交false，代表不自動(dòng)提交也就是手動(dòng)提交//3，獲得操作數(shù)據(jù)庫(kù)對(duì)象(執(zhí)行平臺(tái))Statement stmt = conn.createStatement();//4,操作sql//stmt.executeUpdate("insert into account values(null,'zhangsan',3000)");int executeUpdate = stmt.executeUpdate("update account set money=5000 where name='sq'");//提交事務(wù)conn.commit();stmt.close();conn.close();} catch (Exception e) {try {conn.rollback();} catch (SQLException e1) {e1.printStackTrace();}e.printStackTrace();}} }utils包下代碼如下：
package beyond.utils;import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement;import javax.sql.DataSource;import com.mchange.v2.c3p0.ComboPooledDataSource;public class DataSourceUtils {private static DataSource dataSource = new ComboPooledDataSource();private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();// 直接可以獲取一個(gè)連接池public static DataSource getDataSource() {return dataSource;}public static Connection getConnection() throws SQLException{return dataSource.getConnection();}// 獲取連接對(duì)象public static Connection getCuruentConnection() throws SQLException {Connection con = tl.get();if (con == null) {con = dataSource.getConnection();tl.set(con);}return con;}// 開(kāi)啟事務(wù)public static void startTransaction() throws SQLException {Connection con = getCuruentConnection();if (con != null) {con.setAutoCommit(false);}}// 事務(wù)回滾public static void rollback() throws SQLException {Connection con = getCuruentConnection();if (con != null) {con.rollback();}}// 提交并且 關(guān)閉資源及從ThreadLocall中釋放public static void commitAndRelease() throws SQLException {Connection con = getCuruentConnection();if (con != null) {con.commit(); // 事務(wù)提交con.close();// 關(guān)閉資源tl.remove();// 從線程綁定中移除}}// 關(guān)閉資源方法public static void closeConnection() throws SQLException {Connection con = getCuruentConnection();if (con != null) {con.close();}}public static void closeStatement(Statement st) throws SQLException {if (st != null) {st.close();}}public static void closeResultSet(ResultSet rs) throws SQLException {if (rs != null) {rs.close();}}}c3p0-config.xml代碼如下：
<?xml version="1.0" encoding="UTF-8"?> <c3p0-config><default-config><property name="user">root</property><property name="password">wsq</property><property name="driverClass">com.mysql.jdbc.Driver</property><property name="jdbcUrl">jdbc:mysql:///web19</property></default-config> </c3p0-config>需要的一系列的jar包如下：
總結(jié)
以上是生活随笔為你收集整理的银行账务转账系统(事务处理)的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： javaEE的开发模式
- 下一篇： 第1章 数据库系统概述