Python은 간단한 은행 송금 작업 방법을 구현합니다.

머리말

애플리케이션 시스템을 개발하는 과정에서는 일반적으로 위에서 아래로 클라이언트 - 비즈니스 로직 계층 - 데이터 액세스 계층 - 데이터베이스의 네 가지 구성 요소가 필요합니다. 데이터 액세스 계층은 최하위 계층이자 핵심 기술입니다. 그리고 실제 개발에서는 데이터베이스의 동작, 즉 데이터 접근 계층이 다른 언어에 내포되어 있는데, 이것이 프로그래밍의 핵심이다. 이 글은 Python 언어, 즉 Python을 통해 데이터베이스를 운영하여 간단한 은행 송금 작업을 구현하는 것을 지향합니다.

도구

파이썬은 데이터베이스 운영을 통일하고 데이터베이스에 접근하기 위한 인터페이스를 표준화하기 위해 파이썬 DB API를 제공한다. 매우 혼란스러웠습니다. 데이터베이스마다 다른 운영 인터페이스가 필요하므로 이 인터페이스는 매우 편리합니다. 특정 작업 중에 데이터베이스 및 기타 논리적 Python 코드, 연결을 설정하기 위한 데이터베이스 연결 개체 연결, 데이터를 "전송"하기 위한 데이터베이스 상호 작용 개체 커서를 작동해야 합니다. 데이터베이스 예외 클래스 예외에는 견고한 시스템이 필수입니다. 전체 데이터베이스 접속 과정은 아래와 같습니다.

다음으로 두 가지 주요 객체를 각각 소개합니다.

connection: 데이터베이스 연결 객체, Python 클라이언트 구축 및 데이터베이스 네트워크 연결.
생성 방법: MySQLdb.connect(), 기본 멤버 방법 포함:
cursor(): 연결을 사용하여 커서를 만들고 반환합니다.
commit(): 현재 트랜잭션 제출
rollback() : Return 현재 트랜잭션을
close()하여 연결을 닫습니다.
cursor: 쿼리를 실행하고 결과를 얻는 데 사용되는 커서 개체가 지원하는 주요 메서드는 다음과 같습니다.
execute() : SQL 문을 실행하고 데이터베이스에서 결과를 전송 클라이언트로 가져오기
fetchone(): 결과 집합의 다음 행 가져오기
fetchmany(size): 결과 집합의 다음 크기 행 가져오기
fetchall(): 결과 집합의 나머지 행을 모두 가져옵니다
rowcount: 가장 최근 실행에서 반환된 데이터 행 수
close(): 커서 개체 닫기
핵심 용어가 언급되어 있습니다. 위의 방법: 거래란 무엇입니까? 데이터에 액세스하고 업데이트하는 프로그램 실행 단위이며 많은 작업의 집합이며 다음 네 가지 특성을 갖습니다.

원자성: 사물에 포함된 모든 작업은 수행되거나 아무것도 수행되지 않습니다.
일관되게. 지속성: 트랜잭션은 데이터베이스를 일관된 상태에서 다른 일관성 상태로 변경해야 합니다.
격리 유형: 트랜잭션 실행은 다른 트랜잭션의 방해를 받지 않습니다.
지속성: 트랜잭션이 커밋되면 데이터베이스에 변경 사항이 적용됩니다. 내구성
거래의 위 특성은 은행 송금 작업을 완료하는 데 핵심입니다.

특정 구현

개발 시 트랜잭션을 어떻게 사용하나요?

자동 커밋() 끄기
거래 정상 종료: conn.commit(),
거래 비정상 종료: conn.rollback()
은행 이체 시스템에서는 다음과 같습니다. 요구 사항을 고려해야 합니다. 예를 들어 A가 B에게 돈을 이체할 때 A의 계좌에서 M개의 돈이 줄어들면 A의 계좌에 M개의 돈이 추가되어야 합니다. 그러나 B는 추가되지 않으며 B도 추가될 수 없습니다. A는 물론, 계좌가 유효해야 하며, M의 금액이 A의 계좌 금액보다 커야 합니다. 따라서 특정 설계에서는 A 계좌의 자금 감소와 B 계좌의 자금 증가를 하나의 거래로 처리해야 하며, 이는 동시에 성공하거나 함께 실패합니다. 이 요구 사항에 따라 코드를 작성합니다. 코드 사본과 데이터베이스는 각각 110과 10인 두 개의 계정이 있습니다. 코드를 실행하면 (source_acctid, target_acctid, transfer_money)를 매개변수 열에 입력하세요.

전체 코드의 논리는 다음과 같습니다. 먼저 데이터베이스에 연결한 다음 논리를 실행하고 데이터베이스에서 연결을 끊습니다. 이체 쌍방의 계좌가 유효한지, 이체 금액이 유효한지 여부가 양도인의 계좌 잔액보다 많은 경우, 이체 쌍방에게 지급되는 계좌 금액이 변경됩니다. 트랜잭션이 정상적으로 종료되면 수정 사항을 데이터베이스에 커밋하고, 그렇지 않으면 롤백합니다.

#coding:utf-8
import sys
import MySQLdb
class TransferMoney():
def __init__(self, conn):
self.conn = conn
def transfer(self, src, target, money):
try:
self.check_acct_available(src)
self.check_acct_available(target)
self.has_enough_money(src, money)
self.reduce_money(src, money)
self.add_money(target, money)
self.conn.commit()
except Exception as e:
print e
self.conn.rollback()
def reduce_money(self, src, money):
cursor = self.conn.cursor()
try:
sql = "update account set money = money - %s where acctid = %s" %(money, src)
cursor.execute(sql)
print "reduce_money: " + sql
#rs = cursor.fetchall()
if cursor.rowcount != 1:
raise Exception("the account reduce money fail")
finally:
cursor.close()
def add_money(self, target, money):
cursor = self.conn.cursor()
try:
sql = "update account set money = money + %s where acctid = %s" %(money, target)
cursor.execute(sql)
print "add_money: " + sql
#rs = cursor.fetchall()
if cursor.rowcount != 1:
raise Exception("the account add money fail")
finally:
cursor.close()
def check_acct_available(self, accit):
cursor = self.conn.cursor()
try:
sql = "select * from account where acctid = %s" %accit
cursor.execute(sql)
print "check_acct_available: " + sql
rs = cursor.fetchall()
if len(rs) != 1:
raise Exception("the account %s is not exist" %accit)
finally:
cursor.close()
def has_enough_money(self, src, money):
cursor = self.conn.cursor()
try:
sql = "select * from account where acctid = %s and money >= %s " %(src, money)
cursor.execute(sql)
print "has_enough_money: " + sql
rs = cursor.fetchall()
if len(rs) != 1:
raise Exception("the account does not have enough money")
finally:
cursor.close()
if __name__ == "__main__":
source_acctid = sys.argv[1]
target_acctid = sys.argv[2]
money = sys.argv[3]
conn = MySQLdb.connect(
host = "127.0.0.1", user = '******', passwd = '******', port = 3306, db = '******'
)
tr_money = TransferMoney(conn)
try:
tr_money.transfer(source_acctid, target_acctid, money)
except Exception as e:
print e
finally:
conn.close()

요약

데이터베이스를 운영하여 간단한 계좌이체 시스템을 구현할 수 있으므로 시스템에서 언제 개발을 진행하면서 우리는 전체 시스템을 단순히 여러 구성 요소를 접합하는 것이 아니라 1+1>2를 달성하도록 최선을 다해야 합니다.

Python에서 간단한 은행 송금 작업을 구현하는 방법에 대한 더 많은 관련 기사를 보려면 PHP 중국어 웹사이트를 주목하세요!