Python implementiert eine einfache Banküberweisungsoperationsmethode

Vorwort

Bei der Entwicklung eines Anwendungssystems sind im Allgemeinen von oben nach unten vier Komponenten erforderlich: Client - Geschäftslogikschicht - Datenzugriffsschicht - Datenbank, wobei die Datenzugriffsschicht eine unterste Schicht und Kerntechnologie ist. Und in der tatsächlichen Entwicklung ist der Betrieb der Datenbank, also der Datenzugriffsschicht, in anderen Sprachen verschachtelt, was den Kern der Programmierung darstellt. Dieser Artikel konzentriert sich auf die Python-Sprache, dh auf den Betrieb der Datenbank über Python, um einfache Banküberweisungsvorgänge zu implementieren.

Tools

Python stellt die Python-DB-API bereit, um den Betrieb der Datenbank zu vereinheitlichen und die Schnittstelle für den Zugriff auf die Datenbank zu standardisieren war sehr verwirrend. Unterschiedliche Datenbanken erfordern unterschiedliche Bedienoberflächen, daher bietet diese Schnittstelle großen Komfort. Während bestimmter Vorgänge müssen wir die Datenbank und andere logische Python-Codes, die Datenbankverbindungsobjektverbindung zum Herstellen der Verbindung und den Datenbankinteraktionsobjektcursor zum „Transportieren“ von Daten betreiben. Für die Datenbankausnahmeklasse Exceptions ist ein robustes System unverzichtbar. Der gesamte Prozess des Zugriffs auf die Datenbank ist wie folgt:

Als nächstes stellen wir die beiden Hauptobjekte vor:

Verbindung: Datenbankverbindungsobjekt, herstellen Python-Client und Datenbank-Netzwerkverbindung.
Erstellungsmethode: MySQLdb.connect(), einschließlich Hauptmitgliedsmethoden:
cursor(): Verwenden Sie die Verbindung, um einen Cursor zu erstellen und zurückzugeben
commit(): Senden Sie die aktuelle Transaktion
rollback() : Zurück Rollen Sie die aktuelle Transaktion
close(), um die Verbindung zu schließen
cursor: Cursorobjekt, das zum Ausführen von Abfragen und zum Erhalten von Ergebnissen verwendet wird. Die wichtigsten vom Cursorobjekt unterstützten Methoden sind wie folgt:
execute(). : SQL-Anweisungen ausführen und die Ergebnisse aus der Datenbank abrufen. Zum Client gelangen
fetchone(): Die nächste Zeile der Ergebnismenge abrufen
fetchmany(size): Die nächste Zeile der Ergebnismenge abrufen
fetchall(): Alle verbleibenden Zeilen in der Ergebnismenge abrufen
rowcount: Die Anzahl der Datenzeilen, die von der letzten Ausführung zurückgegeben wurden
close(): Das Cursorobjekt schließen
Ein Schlüsselbegriff wird in erwähnt die obige Methode: Transaktion Was ist eine Transaktion? Es handelt sich um eine Programmausführungseinheit, die auf Daten zugreift und diese aktualisiert. Sie ist eine Sammlung vieler Vorgänge und weist vier Merkmale auf:

Atomizität: Alle in den Dingen enthaltenen Vorgänge werden entweder ausgeführt oder keine davon wird konsistent ausgeführt Persistenz: Eine Transaktion muss die Datenbank von einem konsistenten Zustand in einen anderen Konsistenzzustand ändern.
Isolationstyp: Die Ausführung einer Transaktion wird nicht durch andere Transaktionen beeinträchtigt.
Persistenz: Sobald eine Transaktion festgeschrieben wird, werden ihre Änderungen in der Datenbank vorgenommen sind dauerhaft Die oben genannten Merkmale der
-Transaktion sind für uns der Schlüssel zum Abschluss des Banküberweisungsvorgangs.

Spezifische Umsetzung

Wie nutzen wir Transaktionen in der Entwicklung?

Automatisches Commit ausschalten()

Transaktion normal beenden: conn.commit(),
Transaktion abnormal beenden: conn.rollback()
Im Banküberweisungssystem Folgendes Anforderungen müssen berücksichtigt werden: Wenn A beispielsweise Geld an B überweist und M-Geld vom Konto von A abgezogen wird, muss M-Geld auf das Konto von B hinzugefügt werden. Es kann nicht sein, dass A Geld abgezogen hat, aber B es nicht hinzugefügt hat Dass B Geld hinzugefügt und A es nicht reduziert hat, muss natürlich gültig sein, der Geldbetrag von M muss größer sein als der Betrag auf dem Konto von A. Daher müssen im spezifischen Entwurf die Reduzierung des Geldbetrags auf Konto A und die Erhöhung des Geldbetrags auf Konto B als eine Transaktion behandelt werden, die entweder gleichzeitig erfolgreich ist oder gemeinsam fehlschlägt. Schreiben Sie den Code entsprechend dieser Anforderung. Die Codekopie und die Datenbank lauten wie folgt. Geben Sie beim Ausführen des Codes 1, 2.100 ein. transfer_money) in der Parameterspalte.

Die Logik des gesamten Codes lautet wie folgt: Stellen Sie zuerst eine Verbindung zur Datenbank her, führen Sie dann die Logik aus und trennen Sie dann die Datenbankverbindung. Die ausgeführte Logik umfasst die Überprüfung, ob die Konten beider Übertragungsparteien gültig sind und ob der Überweisungsbetrag gültig ist. Wenn der Kontostand des Übertragenden übersteigt, ändern sich die Kontobeträge beider Übertragungsparteien. Wenn die Transaktion normal endet, übertragen Sie die Änderung in die Datenbank, andernfalls setzen Sie sie zurück.

#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()

Zusammenfassung

Ein einfaches Banküberweisungssystem kann durch den Betrieb der Datenbank implementiert werden, also bei der Entwicklung Wir sollten unser Bestes geben, um das gesamte System nicht nur aus mehreren Komponenten zusammenzufügen, sondern um 1+1>2 zu erreichen.

Weitere verwandte Artikel zur Implementierung einer einfachen Banküberweisungsmethode in Python finden Sie auf der chinesischen PHP-Website!