當前位置：首頁 > 运维知识 > windows >内容正文

windows

银行账务转账系统(事务处理)

發布時間：2023/12/1 windows 37 豆豆

生活随笔收集整理的這篇文章主要介紹了银行账务转账系统(事务处理) 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

流程如下：

創建項目工程如下：

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();//不用穿參數//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();//不用穿參數//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) {//創建dao層對象TransferDao dao = new TransferDao();boolean isTransferSuccess = true;Connection conn = null;try {//進行事務控制，開啟事務conn = DataSourceUtils.getConnection();//不自動開啟事務，也就是手動開啟事務conn.setAutoCommit(false);//調用dao層的轉出錢的方法,只需要知道轉錢的人是誰跟錢數就行dao.out(conn,out,money);//調用dao層的轉入錢的方法,只需要知道轉給誰跟錢數就行dao.in(conn,in,money);} catch (SQLException e) {isTransferSuccess = false;try {//當出現事務錯誤，進行事務的回滾；回滾本身內部不包含提交的功能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 {//接收轉賬的參數String out = request.getParameter("out");String in = request.getParameter("in");String moneyStr = request.getParameter("money");double money=Double.parseDouble(moneyStr);//進行將轉賬金額強轉//調用業務層的轉賬方法TransferService service = new TransferService();boolean isTransferSuccess = service.transfer(out,in,money);//解決亂碼問題response.setContentType("text/html;charset=UTF-8");if(isTransferSuccess){response.getWriter().write("轉賬成功！！！");}else{response.getWriter().write("轉賬失敗！！！");}}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/>轉轉金額:<input type="text" name="money"><br/><input type="submit" value="確認轉賬"><br/></form> </body> </html>

數據庫創建如下：

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=utf8

dbutils包下代碼如下：

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) {//通過jdbc去控制事務Connection conn = null;try {//1,注冊驅動 Class.forName("com.mysql.jdbc.Driver");//2,獲得connectionconn = DriverManager.getConnection("jdbc:mysql:///web19","root","wsq");//三個///代表本地一個端口//手動開啟事務conn.setAutoCommit(false);//是否自動提交false，代表不自動提交也就是手動提交//3，獲得操作數據庫對象(執行平臺)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'");//提交事務conn.commit();stmt.close();conn.close();} catch (Exception e) {try {conn.rollback();} catch (SQLException e1) {e1.printStackTrace();}e.printStackTrace();}} }

jdbc包下代碼如下：

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>();// 直接可以獲取一個連接池public static DataSource getDataSource() {return dataSource;}public static Connection getConnection() throws SQLException{return dataSource.getConnection();}// 獲取連接對象public static Connection getCuruentConnection() throws SQLException {Connection con = tl.get();if (con == null) {con = dataSource.getConnection();tl.set(con);}return con;}// 開啟事務public static void startTransaction() throws SQLException {Connection con = getCuruentConnection();if (con != null) {con.setAutoCommit(false);}}// 事務回滾public static void rollback() throws SQLException {Connection con = getCuruentConnection();if (con != null) {con.rollback();}}// 提交并且關閉資源及從ThreadLocall中釋放public static void commitAndRelease() throws SQLException {Connection con = getCuruentConnection();if (con != null) {con.commit(); // 事務提交con.close();// 關閉資源tl.remove();// 從線程綁定中移除}}// 關閉資源方法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包如下：

總結

以上是生活随笔為你收集整理的银行账务转账系统(事务处理)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。