#coding=utf-8 import sys import MySQLdb ''''' python操作MySQL数据库，模拟银行转账 ''' class Trans_for_Money(object): #初始化 类 def __init__(self,conn): self.conn = conn #### 1、检查所输入的账号是否存在 #### def check_acct_available(self,source_acctid): #使用与数据库的链接并返回游标 cursor=self.conn.cursor() try: #数据库命令 sql="select * from tr_money where acctid=%s" %source_acctid #执行命令 cursor.execute(sql) #为方便观察执行过程 print "check_acct_available:" + sql #讲结果集放入变量result中，若result不等于1，则没有这个账号，输出异常 result=cursor.fetchall() if len(result)!=1: raise Exception("账号%s不存在" %source_acctid) finally: #若过程出现问题，仍需要关闭游标对象 cursor.close() #### 2、检查减款人余额是否充足，方法与上一个函数一样，只是多加了一个money参数 ### def has_enough_money(self,source_acctid,money): cursor=self.conn.cursor() try: sql="select * from tr_money where acctid=%s and money>%s" %(source_acctid,money) cursor.execute(sql) print "has_enough_money:" + sql result=cursor.fetchall() if len(result)!=1: raise Exception("账号%s余额不足" %source_acctid) finally: cursor.close() #### 3、减款操作 ### def reduce_money(self,source_acctid,money): cursor=self.conn.cursor() try: #数据库命令，减去对应减款人的金额数 sql="update tr_money set money=money-%s where acctid=%s" %(money,source_acctid) cursor.execute(sql) print "reduce_money:" + sql #操作的execute()数据行数不等于1则减款失败 if cursor.rowcount!=1: raise Exception("账号%s减款失败" %source_acctid) finally: cursor.close() #### 4、收款操作，与减款方法相同 ### def add_money(self,target_acctid,money): cursor=self.conn.cursor() try: sql="update tr_money set money=money+%s where acctid =%s" %(money,target_acctid) cursor.execute(sql) print "add_money:" + sql if cursor.rowcount!=1: raise Exception("账号%s收款失败" %target_acctid) finally: cursor.close() #### 5、分别传入参数，代入上方函数，执行操作 ### def trans_for(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测试数据mit() 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 = MySQLdb.Connect( host='127.0.0.1', port=3306, user='root', passwd='12345678', db='tt', charset='utf8' ) #手动输入减款人、收款人、转款数 source_acctid=raw_input("请输入减款人： ") target_acctid=raw_input("请输入收款人： ") money=raw_input("请输入转款数： ") #将参数传入类中 tr_money=Trans_for_Money(conn) try: tr_money.trans_for(source_acctid,target_acctid,money) except Exception as e: print"出现问题："+str(e) finally: conn.close() #关闭链接
三、问题解决
1、sys.argv[ ]
因为教学视频中用的IDE是MyEclipse，最后用run.Configuration 输入参数，而我用的是pycharm，表示笨的找不到还是其实它没有！
所以选择用raw_input() 在执行过程中输入参数
其实有去了解sys.argv[ ]，但还是懂不太清楚。
2、 mysql_exceptions.IntegrityError: (1062, "Duplicate entry '7' for key 'PRIMARY'")
这个错误表示你所要插入的数据已经存在，最好去观察一下数据库的数据与自己的程序操作是否有矛盾
3、MySql 建表或输入数值时出错：1170-BLOB/TEXT column‘name'used in key specification without a key length
错误信息为BLOB或者TEXT字段使用了未指定键值长度的键
解决方法：设置其他为主键 或 将数据形式改为varchar
具体解释网址：http://myhblog1989.blog.163测试数据/blog/static/183225376201110875818884/
4、TypeError: 'post' is an invalid keyword argument for this function
错误原因：TypeError: “post”是这个函数的无效参数
这个问题错的很无语，一时脑子进水把 “port”=3306 写成了“post”=‘3306'
5、1054, "Unknown column 'acctid' in 'where clause'
错误原因：在where子句中找不到“acctid”列
呵呵，上个错误脑子进的水没排出来，把表头写错了…………
6、另外，还有一个错误是手动输入的减款，收款人设为字母或汉字时找不到
可能是我代码或数据库建表时的设定问题，表示在字符转换和数据库这方面还是小白一枚，继续奋斗吧！
7、MySQL数据库的启动
计算机 → 右键 → 管理 → 服务和应用程序 → 服务 → 找到MySQL → 右键启动
四、具体执行显示
1、数据库 tr_money 表的初始状态
2、代码执行，输入减款人，收款人，转款数额
3、执行，结果出现代码中特意 print 的操作进程显示
4、数据库 tr_money 表执行后状态
总结
以上就是python操作MySQL模拟银行转账操作的简单实例的详细内容，更多请关注Gxl网其它相关文章！
查看更多关于python操作MySQL模拟银行转账操作的简单实例的详细内容...