Python3连接MySQL(pymysql)模拟转账实现代码
更新时间:2016年05月24日 16:11:32 作者:沙拉虎
这篇文章主要介绍了Python3连接MySQL(pymysql)模拟转账实现代码,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
本文实例为大家分享了Python3连接MySQL模拟转账的具体实现代码,供大家参考,具体内容如下
# coding:utf8 import sys import pymysql class TransferMoney(object): def __init__(self,conn): self.conn=conn def check_acct_available(self,acctid): cursor = self.conn.cursor() try: sql="select * from account where acctid=%s" % acctid cursor.execute(sql) print ("check_acct_available:" + sql) rs = cursor.fetchall() if len(rs) ! = 1: raise Exception("账号%s不存在"% acctid) finally: cursor.close() def has_enough_money(self,acctid,money): cursor = self.conn.cursor() try: sql="select * from account where acctid=%s and money>%s" % (acctid,money) cursor.execute(sql) print ("has_enough_money:"+sql) rs = cursor.fetchall() if len(rs) ! = 1: raise Exception("账号%s余额不足"% acctid) finally: cursor.close() def reduce_money(self,acctid,money): cursor = self.conn.cursor() try: sql = "update account set money=money-%s where acctid=%s" % (money,acctid) cursor.execute(sql) print ("reduce_money:"+sql) if cursor.rowcount ! = 1: raise Exception("账号%s减款失败" % acctid) finally: cursor.close() def add_money(self,acctid,money): cursor = self.conn.cursor() try: sql="update account set money=money+%s where acctid=%s" % (money,acctid) cursor.execute(sql) print ("add_money:"+sql) if cursor.rowcount ! = 1: raise Exception("账号%s加款失败" % acctid) finally: cursor.close() def transfer(self,source_acctid,target_acctid,money): try: self.check_acct_available(source_acctid) self.check_acct_available(target_acctid) self.has_enough_money(source_acctid,money) self.reduce_money(source_acctid,money) self.add_money(target_acctid,money) self.conn.commit() except Exception as e: self.conn.rollback() raise e if __name__ == "__main__": source_acctid = sys.argv[1] target_acctid = sys.argv[2] money = sys.argv[3] conn = pymysql.Connect( host = 'localhost', unix_socket = "..mysql/mysql.sock", port = 3306, user = 'root', passwd = '', db = 'python_db', ) tr_money = TransferMoney(conn) try: tr_money.transfer(source_acctid,target_acctid,money) except Exception as e: print ("出现问题" + str(e)) finally: conn.close()
以上就是本文的全部内容,希望对大家学习python程序设计有所帮助。
您可能感兴趣的文章:
- Python中操作mysql的pymysql模块详解
- Python MySQL数据库连接池组件pymysqlpool详解
- Python中模块pymysql查询结果后如何获取字段列表
- python使用pymysql实现操作mysql
- 详解使用pymysql在python中对mysql的增删改查操作(综合)
- Python 3.x 连接数据库示例(pymysql 方式)
- Python使用pymysql从MySQL数据库中读出数据的方法
- python 3.6 +pyMysql 操作mysql数据库(实例讲解)
- Python使用pymysql小技巧
- python3.6使用pymysql连接Mysql数据库
- python和mysql交互操作实例详解【基于pymysql库】
相关文章
对Python2与Python3中__bool__方法的差异详解
今天小编就为大家分享一篇对Python2与Python3中__bool__方法的差异详解,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧2018-11-11
最新评论