python操作MySQL 模拟简单银行转账操作
作者:幸福清风 发布时间:2024-01-17 19:15:47
一、基础知识
1、MySQL-python的安装
下载,然后 pip install 安装包
2、python编写通用数据库程序的API规范
(1)、数据库连接对象 connection,建立python客户端与数据库的网络连接,创建方法为 MySQLdb.Connect(参数)
参数有六个: host(MySQL服务器地址,一般本地为127.0.0.1)
port(MySQL服务器端口号)
user(用户名)
passwd(密码)
db(数据库名称)
charset(连接编码)
connection的方法: cursor()使用该连接并返回游标
commit()提交当前事务
rollback()回滚当前事务
close()关闭连接
(2)、数据库游标对象cursor,用于执行查询和获取结果
方法:execute(op[,args])执行一个数据库查询 和 命令
fetchone()取得结果集的下一行
fetchmany(size)获取结果集的下几行
fetchall()获取结果集中剩下的所有行
rowcount 最近一次execute返回数据的行数或影响行数
close()关闭游标对象
connection与cursor:connection相当于python与MySQL之间的路,而cursor相当于路上的运输车来传送命令与结果。
3、简单命令:
select 查询数据:sql="select * from 表名 所查项目"
insert 插入数据:sql=“insert into 表名 所插项目”
update 更改数据: sql=“updata 表名 set 所改项目 ”
delete 删除数据: sql=“delete from 表名 所删项目”
where也是sql命令的关键存在,通常是 where 表头=列名 来定位那一列
4、事务
访问和更新数据库的一个程序执行单元,所执行的命令,都可以称为事务
具有原子性,一致性,隔离性,持久性
事务执行:
conn.commit() 正常结束事务
conn.rollback() 异常结束事务,对事务进行回滚,若程序执行单元中的连续的操作在进行中出错,之前的操作还原。
简单操作过程: 开始 → 创建connection →获取cursor → 程序执行单元 → 关闭cursor → 关闭connection → 结束
二、模拟银行转账系统代码
#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.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 = 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.com/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 模拟银行转账网站的支持!
来源:http://blog.csdn.net/xun527/article/details/78109605
猜你喜欢
- 在Linux上有个常用的命令 curl(非常好用),支持curl的就是大名鼎鼎的libcurl库;libcurl是功能强大的,而且是非常高效
- 本文实例讲述了Python实现的视频播放器功能。分享给大家供大家参考,具体如下:# -*- coding:utf-8 -*-#! pytho
- php数组中元素的存在方式是以键值对的方式('key'=>'value'),有时候我们需要根据键删除数
- 一、背景希望根据企业名称查询其经纬度,所在的省份、城市等信息。直接将企业名称传给百度地图提供的API,得到的经纬度是非常不准确的,因此希望获
- 前言针对于一维数组的存储方式,即(n,)存储为列向量一、创建一个array使用np.arange()创建一个一维数组,或者np.array(
- 前言日志是对于软件执行所发生的事件的一种追踪记录方式。日常使用过程中对代码执行的错误和问题会进行查看日志来分析定位问题所在。平常编写代码以及
- 之前使用smarty的时候,通常是在php程序端读取数据(一般从数据库),然后assign给模板的变量,才可以在前端使用这个变量。这样不是不
- python脚本性能分析首先使用cd进入需要测试的脚本文件对应的目录,然后再使用如下代码完成对脚本的性能测试。# enter the dir
- 1.file--->settings:2.搜索temlates,点击File and Code Templates,点击右侧的Pyth
- 网上广泛流传的取 object 的绝对位置的做法是:var getAbsPos = function(pTar
- 我们在使用selenium库调用Chromedriver.exe时需要很多的配置参数下面列出了常用参数chrome_options.add_
- 如何最准确地统计在线用户数?我们推荐的这个程序据说是目前最好的在线用户数量统计程序。代码如下:'首先要设置好global.asa&n
- python以下是个人学习 python 研究判断ip连通性方法的集合。 缺点可能有办法解决,如有错误,欢迎矫正。方法一import osr
- 最近在公司做了微信支付的接入,这里总结下开发的一些经验注意,我使用的是微信开放平台的支付,与手机app相关,而与公众账号无关。微信支付的主要
- 本文实例讲述了python中查看变量内存地址的方法。分享给大家供大家参考。具体实现方法如下:这里可以使用id>>> pri
- 写在前面:从昨晚的梦里回忆起数据管理的作业:实现一个自己的选题----毕业生信息管理系统,实现学生个人信息基本的增删改查,我想了想前段时间刚
- 学生表:create table student( id number(8) primary key, name var
- 可实现类似于sql中的dateadd、datesub的功能两种获取日期的方式z=datetime.datetime(2016,12,5)z=
- insert into testtable(recordnumber,currentdate) values (i,sysdate); pr
- python窃取摄像头照片源码+获取授权码方法+py打包成exe教你用python做一个属于自己的窃取摄像头照片的软件。需要安装python