Mysql__(二)

Mysql数据存储

1、Mysql数据库安装

网上很多
1、单独下载MYSQL数据库https://jingyan.baidu.com/article/363872ec2e27076e4ba16fc3.html
2、ASMServ包含了Apache+PHP+Msql+Asp集成安装,图形界面启动服务。
3、navicat for mysql,破解游戏的大佬最喜欢用的包含图形界面。
我选择的一,不臃肿。

2、Mysql链接数据库

我们首先尝试链接数据库,数据库在本地运行,用户名:root,密码:root,运行端口:3306。我们利用包PyMySQL链接数据库,然后创建一个新的数据库spider,代码如下

import pymysql

# 打开数据库链接
db = pymysql.connect(host='localhost', user='root', password='root', port=3306)

# 使用cursor()方法创建一个游标对象cursor
cursor = db.cursor()

# 使用execute() 方法执行SQL查询
cursor.execute('SELECT VERSION()')

# 使用fetchone() 方法获取单条数据。
data = cursor.fetchone()

print('Database version: %s' % data)
# cursor.execute('CREATE DATABASE spiders DEFAULT CHARACTER SET utf8')

# 关闭数据库
db.close()

代码中提到了游标,什么是游标呢?
游标:MySQL的游标(cursor)是一个重要的概念,通过查找资料与自己的理解,主要得出以下几点关于自己的理解。

有数据缓冲的思想:游标的设计是一种数据缓冲区的思想,用来存放SQL语句执行的结果。 先有数据基础:游标是在先从数据表中检索出数据之后才能继续灵活操作的技术。 类似于指针:游标类似于指向数据结构堆栈中的指针,用来pop出所指向的数据,并且只能每次取一个。
在创建新数控库spiders失败,想起是昨天已经创立过


查询数据库

3、创建表

代码如下

# 链接数据库
db = pymysql.connect(host='localhost', user='root', password='root', db='spiders')
# 创建游标对象
cursor = db.cursor()
sql = 'CREATE TABLE IF NOT EXISTS students (id VARCHAR(255)NOT NULL ,name VARCHAR (255)NOT NULL , age INT NOT NULL ,' \
      'PRIMARY KEY(id))'

cursor.execute(sql)
db.close()
查询表

表结构

简单的创建了几个字段

4、插入数据

我们将数据解析出来后的下一步就是向数据库中插入数据了,例如在这里我们爬取了一个的学生信息,学号为2018.5.16,名字为 Bob,年龄为 20,那么如何将该条数据插入数据库呢,实例代码如下:
完整代码如下:

id = '2018.5.16'
name = 'BOB'
age = 20
db = pymysql.connect(host='localhost', user='root', password='root', db='spiders')
cursor = db.cursor()
sql = 'INSERT INTO students(id, name, age)values(%s,%s,%s)'
try:
    cursor.execute(sql, (id, name, age))
    db.commit()
except:
    db.rollback()
db.close()
插入的数据

在这里我们首先构造了一个 SQL 语句,其 Value 值我们没有用字符串拼接的方式来构造,如:

sql = 'INSERT INTO students(id, name, age) values(' + id + ', ' + name + ', ' + age + ')'

这样的写法繁琐而且不直观,所以我们选择直接用格式化符 %s 来实现,有几个 Value 写几个 %s,我们只需要在 execute() 方法的第一个参数传入该 SQL 语句,Value 值用统一的元组传过来就好了。
这样的写法有既可以避免字符串拼接的麻烦,又可以避免引号冲突的问题。
之后值得注意的是,需要执行 db 对象的 commit() 方法才可实现数据插入,这个方法才是真正将语句提交到数据库执行的方法,对于数据插入、更新、删除操作都需要调用该方法才能生效。
接下来我们加了一层异常处理,如果执行失败,则调用rollback() 执行数据回滚,相当于什么都没有发生过一样。
在这里就涉及一个事务的问题,事务机制可以确保数据的一致性,也就是这件事要么发生了,要么没有发生,比如插入一条数据,不会存在插入一半的情况,要么全部插入,要么整个一条都不插入,这就是事务的原子性,另外事务还有另外三个属性,一致性、隔离性、持久性,通常成为 ACID 特性。+

归纳如下:


ACID特性

插入、更新、删除操作都是对数据库进行更改的操作,更改操作都必须为一个事务,所以对于这些操作的标准写法就是:

try:
  cursor = db.cursor()
  db.commit()
except:
  db.roollback()

这样我们便可以保证数据的一致性,在这里的 commit() 和 rollback() 方法就是为事务的实现提供了支持。
好,在上面我们了解了数据插入的操作,是通过构造一个 SQL 语句来实现的,但是很明显,这里有一个及其不方便的地方,比如又加了一个性别 gender,假如突然增加了一个字段,那么我们构造的 SQL 语句就需要改成:

INSERT INTO students(id, name, age,gender)values(%s, %s, %s,%s)

相应的元组参数则需要改成:

(id, name, age, gender)

这显然不是我们想要的,在很多情况下,我们要达到的效果是插入方法无需改动,做成一个通用方法,只需要传入一个动态变化的字典给就好了。比如我们构造这样一个字典:

{
    'id': '20120001',
    'name': 'Bob',
    'age': 20
}

然后 SQL 语句会根据字典动态构造,元组也动态构造,这样才能实现通用的插入方法。所以在这里我们需要将插入方法改写一下:


data = {
    'id': '20120001',
    'name': 'Bob',
    'age': 20
}
table = 'students'
keys = ', '.join(data.keys())
values = ', '.join(['%s'] * len(data))
sql = 'INSERT INTO {table}({keys}) VALUES ({values})'.format(table=table, keys=keys, values=values)
try:
   if cursor.execute(sql, tuple(data.values())):
       print('Successful')
       db.commit()
except:
    print('Failed')
    db.rollback()
db.close()

Python join()方法
Python join() 方法用于将序列中的元素以指定的字符连接生成一个新的字符串
在这里我们传入的数据是字典的形式,定义为 data 变量,表名也定义成变量 table。接下来我们就需要构造一个动态的 SQL 语句了。

首先我们需要构造插入的字段,id、name 和 age,在这里只需要将data的键名拿过来,然后用逗号分隔即可。所以 ', '.join(data.keys()) 的结果就是 id, name, age,然后我们需要构造多个 %s 当作占位符,有几个字段构造几个,比如在这里有两个字段,就需要构造 %s, %s, %s ,所以在这里首先定义了长度为 1 的数组 ['%s'] ,然后用乘法将其扩充为 ['%s', '%s', '%s'],再调用 join() 方法,最终变成 %s, %s, %s。所以我们再利用字符串的 format() 方法将表名,字段名,占位符构造出来,最终sql语句就被动态构造成了

INSERT INTO students(id, name, age) VALUES (%s, %s, %s)

最后再 execute() 方法的第一个参数传入 sql 变量,第二个参数传入 data 的键值构造的元组,就可以成功插入数据了。
如此以来,我们便实现了传入一个字典来插入数据的方法,不需要再去修改 SQL 语句和插入操作了。


插入数据

5、更新数据

数据更新操作实际上也是执行 SQL 语句,最简单的方式就是构造一个 SQL 语句然后执行:

db = pymysql.connect(host='localhost', user='root', password='root', db='spiders')
cursor = db.cursor()
sql = 'UPDATE students SET age = %s WHERE name = %s'
try:
    cursor.execute(sql, (25, 'AA'))
    db.commit()
except:
    db.rollback()
db.close()
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 216,142评论 6 498
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,298评论 3 392
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 162,068评论 0 351
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,081评论 1 291
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,099评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,071评论 1 295
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,990评论 3 417
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,832评论 0 273
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,274评论 1 310
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,488评论 2 331
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,649评论 1 347
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,378评论 5 343
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,979评论 3 325
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,625评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,796评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,643评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,545评论 2 352

推荐阅读更多精彩内容