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

2016-05-02 本文已影响308人谢小路

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

系列爬虫专栏

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

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

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

1：框架

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

2：概念，工具介绍

MySQL：关系型数据库
MySQL（官方发音为英语发音：/maɪ ˌɛskjuːˈɛl/“My S-Q-L”[1]，但也经常读作英语发音：/maɪ ˈsiːkwəl/“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:完成zhangsan向lisi转账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上。

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