大师网-带你快速走向大师之路 解决你在学习过程中的疑惑,带你快速进入大师之门。节省时间,提升效率

专栏:008:MySQLdb及其银行模拟转账

用理工科思维看待这个世界

系列爬虫专栏

崇尚的学习思维是:输入,输出平衡,且平衡点不断攀升。

曾经有大神告诫说:没事别瞎写文章;所以,很认真的写的是能力范围内的,看客要是看不懂,不是你的问题,问题在我,得持续输入,再输出。

今天的主题是:MySQLdb及其银行模拟转账

1:框架

序号 内容 说明
01 概念及其工具介绍 --
02 SQL语句 --
03 实例演示数据库操作 --
04 银行转账操作演示 --
05 参考及其说明 --

2:概念,工具介绍

  • MySQL:关系型数据库
    MySQL(官方发音为英语发音:/ma skjul/“My S-Q-L”[1],但也经常读作英语发音:/ma sikwl/“My Sequel”)原本是一个开放源代码的关系数据库管理系统,原开发者为瑞典的MySQL AB公司,该公司于2008年被昇阳微系统(Sun Microsystems)收购。2009年,甲骨文公司(Oracle)收购昇阳微系统公司,MySQL成为Oracle旗下产品。

  • MySQL 服务器的 下载:官网

  • python MySQL 驱动 安装: 下载安装

  • python MySQL 开发环境

01:Python 集成开发环境编写SQL语句
02:python客户端 + python MySQL 驱动
03:MySQL 服务器:MySQL客户端工具

本地需要先开启MySQL服务,python编写SQL语句,驱动完成python和MySQL之间的联系。这样就可以实现数据库数据的增删改查。


3:SQL语句

  • SQL语句
    SQL是用于访问和处理数据库的标准的计算机语言:
    教程w3school
    基本操作:增删改查

  • 查:
    SELECT 列名称 FROM 表名称
    一个名为"Persons"的表:提取LastName列:select LastName from Persons


001.png


结果:


002.png
  • 改:
    UPDATE 表名称 SET 列名称 = 新值 WHERE 列名称 = 某值

  • 增:
    01:INSERT INTO table_name (列1, 列2,...) VALUES (值1, 值2,....) 02:INSERT INTO 表名称 VALUES (值1, 值2,....)

  • 删:
    DELETE FROM 表名称 WHERE 列名称 = 值

还有好些高级的用法....点这里

这里主要讲解在python中的使用。


4:代码演示

  • MySQLdb

01: 创建连接对象

序号 方法 使用说明
01 MySQLdb.connet() 创建数据库连接对象
参数 类型 说明
host 字符串 MySQL服务器地址,本地:localhost
port 数字 MySQL服务器端口号
user 字符串 用户名,默认root
passwd 字符串 密码,默认空
db 字符串 数据库名称
charset 字符串 连接编码

02:连接对象支持的方法

方法名 说明
cursor() 游标对象:用于查询和获取结果
commit() 提交当前事务
rollback() 回滚当前事务
close() 关闭连接

03:游标对象 所支持的方法

方法 说明
execute() 执行一个数据库查询和命令
fetchone() 取结果集的下一个
fetchmany(size) 获取结果集下几行
fetchall() 获取剩下的所有
rowcount 最近一次execute影响的行数
close() 关闭游标对象

04:使用MySQLdb的方法流程

  • connection:建立数据库连接
  • cursor: 执行SQL,获取数据库数据
  • 提交事务或者回滚操作
  • 关闭cursor,关闭connection连接对象

数据库可视化工具:SQLyog (有好些,看你自己喜好了)
在本地已经手工创建了一个db = exercise的数据库,表名为:persons如图:

Id LastName FirstName Address City
1 Adams John Oxford Street London
2 Bush George Fifth Avenue New York
3 Carter Thomas Changan Street Beijing
# 获取第一行
import MySQLdb
connector = MySQLdb.connect(
    user="root",
    host="localhost",
    port=3306,
    passwd="123456",
    db="exercise",
    charset="utf8")  # 创建连接对象
cur = connector.cursor()  # 创建游标对象
sql = 'select * from persons WHERE id =1' # 编写的Sql语句
cur.execute(sql) # 使用游标对象的执行方法 
print(cur.fetchone()) # 使用右边对象的获取方法
# output
(1, 'Adams', 'John', 'Oxford Street', 'London')
# 第一行的FirstName 更改成 'xiexiaolu'
sql2 = "UPDATE persons SET FirstName = 'xiexiaolu' WHERE id = 1"
cur.execute(sql2)

# 表数据变成
(1, 'Adams', 'xiexiaolu', 'Oxford Street', 'London')
(2, 'Bush', 'George', 'Fifth Avenue', 'New York')
(3, 'Carter', 'Thomas', 'Changan Street', 'Beijing')
# 增加一条数据
sql3 ="INSERT INTO persons(Id, LastName,FirstName,Address,City)VALUES (4, 'xiaolu', 'xie','zhabei','shanghai')"

# output
(1, 'Adams', 'John', 'Oxford Street', 'London')
(2, 'Bush', 'George', 'Fifth Avenue', 'New York')
(3, 'Carter', 'Thomas', 'Changan Street', 'Beijing')
(4, 'xiaolu', 'xie', 'zhabei', 'shanghai')

更多操作


5:银行转账操作演示

模拟银行两个账户之间的资金流动:
流程:

  • 检查账户是否存在
  • 检查账户是否存在足够的资金
  • A账户 - 资金
  • B账户 + 资金

表名为:bank:完成zhangsanlisi转账100元

id money
zhangsan 110
lisi 10
# 检查账户
def check_account(self, account_id):
    cur =  self.con.cursor()
    sql = 'select * from bank WHERE id ="%s"' % (str(account_id))
    cur.execute(sql)
    if cur.rowcount == 1:
        print("%s existes."%(account_id))
    else:
        print("%s is wrong" % account_id)
# 检查是否有足够的钱
def check_money(self, values, account_id):
    cur = self.con.cursor()
    sql = 'select * from bank WHERE id="%s" AND money>%s' % (account_id, values)
    cur.execute(sql)
    print(cur.rowcount)
    if cur.rowcount == 1:
        print("Enough money!")
        return True
    else:
        print("No enough money!")
        return False
# 减款操作
def subtract(self, accout_id, tranfer_money, Flag):
    cur = self.con.cursor()
    if Flag:
        try:
            sql = 'update bank SET money = money - %s where id = "%s"' % (tranfer_money, accout_id)
            cur.execute(sql)
            print(cur.rowcount)
            if cur.rowcount == 1:
                print(u"减款成功")
        finally:
            cur.close()
    else:
        print(u"操作不成功.")
#加款操作
def add(self, accout_id, tranfer_money, Flag):
    cur = self.con.cursor()
    if Flag:
        try:
            sql = 'update bank SET money = money + %s WHERE id = "%s"' % (tranfer_money, accout_id)
            cur.execute(sql)
            print(cur.rowcount)
            if cur.rowcount ==1:
                print(u"加款成功")
        finally:
            cur.close()
    else:
        print(u"操作不成功.")

效果显示:


005.png

执行后:


006.png
zhangsan existes.
lisi existes.
Enough money!
减款成功
加款成功

第二次执行的初始状态:


006.png
zhangsan existes.
lisi existes.
0
No enough money!
操作不成功.
操作不成功.

完整版代码:完整代码
数据库的学习是为了完成爬虫数据的储存。


6:参考及其说明

参考列表:
01: 参考1
02: 参考2
03:参考:慕课网

Github:github

关于本人:

国内小硕,半路出家的IT学习者。
兴趣领域:爬虫 , 数据科学
本人正在构建一个共同成长爬虫小型社群。有兴趣私信。
文档及代码托管在Github上。

下期预告:爬取豆瓣电影,并存储在数据库中...(为啥都爬豆瓣来着)