easyui table 如何只展示一条_如何使用MySQL，这些操作你得明白!

MySQL数据库是基于关系模型的数据库，而关系模型是通过二维表来保存的，所以它的储存方式就是行列组成的表，每一列是一个字段，每一行是一条记录。今天我们主要介绍Python3下使用PyMySQL操作MySQL数据库的方法。

1.准备工作

在开始之前，我们需要安装好PyMySQL库，安装方法仍然是我们老生常谈的方法，用pip安装，命令如下：

pip3 install pymysql

执行完命令后即可完成安装。

2.连接数据库

假设当前的MySQL运行在本地，用户名为root，密码为123456，运行端口为3306。然后用PyMySQL先连接MySQL，创建了一个新的数据库，命名为spiders，代码如下：

import pymysqldb = pymysql.connect(host='localhost',user='root',password='123456',port=3306)
cursor = db.cursor()
cursor.execute('SELECT VERSION()')
data = cursor.fetchone()
print('Database version:',data)
cursor.execute("CREATE DATABASE spiders DEFAULT CHARACTER SET utf8")
db.close()

运行结果如下：

Database version: ('5.7.23',)

连接成功后，需要调用cursor（）方法获得MySQL的操作游标，利用游标来执行SQL语句。这里我们执行了两句SQL，直接用execute（）方法即可。第一句SQL用于获得MySQL的当前版本，然后调用fetchone（）方法获得第一条数据，也就得到了版本号。

第二句SQL执行创建数据库的操作，数据库命名为spiders，默认编码为UTF-8。

3.创建表

一般来说，创建数据库的操作只需执行一次就好。当然，我们也可以手动创建数据库。以后我们的操作都在spiders数据库上执行。创建数据库后，在连接时需要额外指定一个参数db。

例如，我们创建一个数据包students，此时执行创建表的SQL语句即可。这里指定3个字段（id、name、age），创建该表的示例代码如下：

import pymysql
db = pymysql.connect(host='localhost',user='root',password='123456',port=3306,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()

运行之后，我们便创建了一个名为students的数据表。

4.插入数据

例如，这里爬取了一个学生信息，学号为20120001，名字为Bob，年龄20，那么如何将该条数据插入数据库呢？示例代码如下：

import pymysql
id = '20120001'
user = 'Bob'
age = 20
db = pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='spiders')
cursor = db.cursor()
sql = 'INSERT INTO student(id,name,age) values(%s,%s,%s)'
try:cursor.execute(sql,(id,user,age))db.commit()
except:db.rollback()
db.close()

这里首先构造了一个SQL语句，其Value值没有用字符串拼接的方式来构造，选择直接用格式化符%s来实现，有几个Value写几个%s，我们只需在execute（）方法的第一个参数传入SQL语句，Value值用统一的元组传过来就好了。

之后值得注意的是，需要执行db对象的commit（）方法才可实现数据插入，这个方法才是真正将语句提交到数据库执行的方法。对于数据插入、更新、删除操作，都需要调用该方法才能生效。

接下来，我们加一层异常处理，如果执行失败，则调用rollback（）执行数据回滚，相当于什么都没发生过。

上面数据插入的操作是通过构造SQL语句实现的，但有一个极其不方便的地方，比如突然增加了性别字段gender，此时SQL语句就需要改成：

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

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

(id,name,age,gender)

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

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

import pymysql
db = pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='spiders')
cursor = db.cursor()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()

如此以来，我们便实现了传入一个字典来插入数据的方法，不需要再去修改SQL语句和插入操作了。

5.更新数据

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

sql = 'UPDATE students SET age =%s WHERE name = %s'
try:cursor.execute(sql,(25,'Bob'))db.commit()
except:db.rollback()
db.close()

在实际的数据抓取过程中，大部分情况下需要插入数据，但我们关心的是会不会出现重复数据，如果出现了，我们希望更新数据而不是重复保存一次。因此，这里可以再实现一种去重的方法，如果数据存在，则更新数据；如果数据不存在，则插入数据。示例如下：

import pymysql
db = pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='spiders')
cursor = db.cursor()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)
update = ', '.join(["{key} = %s".format(key=key) for key in data])
sql += update
try:if cursor.execute(sql,tuple(data.values())*2):print('Successful')db.commit()
except:print('Failed')db.rollback()
db.close()

这里构造的SQL语句其实是插入语句，但我们在后面加了ON DUPLICATE KEYUPDATE。这行代码的意思是如果主键已经存在，就执行更新操作。

比如，我们传入的数据id仍然为20120001，但是年龄有所变化，由20变成了21，此时这条数据不会被插入，而是直接更新id为20120001的数据。

6.删除数据

删除操作先对简单，直接使用DELETE语句即可，只是需要指定要删除的目标表名和删除条件，而且仍然需要使用db的commit（）方法才能生效。示例如下：

table = 'students'
condition = 'age > 20'
sql = 'DELETE FROM {table} WHERE {condition}'.format(table=table,condition=condition)
try:cursor.execute(sql)db.commit()
except:db.rollback()db.close()

7.查询数据

查询会用到SELECT语句，示例如下：

sql = 'SELECT * FROM students WHERE age >=20'try:cursor.execute(sql)print('Count:',cursor.rowcount)one = cursor.fetchone()print('One:',one)results = cursor.fetchall()print('Results:',results)print('Results Type:',type(results))for row in results:print(row)
except:print('Error')

运行结果如下：

Count:4
One:('20120001','Bob',25)
Results:(('20120011','Mary',21),('20120012','Mike',20),('20120013','James',22)
Results Type:<class 'tuple'>
('20120011','Mary',21)
('20120012','Mike',20)
('20120013','James',22)

这里我们构造了一条SQL语句，将年龄20岁及以上的学生查询出来，然后将其给excute（）方法。注意，这里不需要db的commit（）方法。接着，调用cursor的rowcount属性获取查询结果的条数，当前示例中是4条。

但是这里需要注意一个问题，这里显示的是3条数据而不是4条，fetchall（）方法不是获取所有数据吗？这个问题留给大家思考，下一篇公布答案。

总结

今天我们介绍了如何使用PyMySQL操作MySQL数据库的方法，主要包括：插入、更新、删除、查询数据，后面我会给大家找一些经典的实战案例，让大家在实战中熟悉运用这些操作来储存数据。

easyui table 如何只展示一条_如何使用MySQL，这些操作你得明白!相关推荐

使用 el-table 实现树形数据懒加载、点击行展开、每次只展示一条数据（大类）以及自定义表格合计值
1. 使用 el-table 实现树形数据懒加载实现必需条件: lazy :load="loadNode" :tree-props="{ children: 'chil ...
mysql数据库实战_主题：MySQL数据库操作实战
昨天项目发布,要做数据移行,要实现的功能很变态,时间很紧迫,基本上是使出了全身解数,才能有快又准地完成工作,期间发现很多小技巧串联起来使用,效果的确非常好. 武器: 1 mysqldump+mysql ...
mysql去重操作哪个最快_如何将 MySQL 去重操作优化到极致？| CSDN 博文精选
作者 | wzy0623 责编 | 屠敏出品 | CSDN 博客前言问题提出源表t_source结构如下: item_id int, created_time datetime, modifi ...
mysql db模块下载_易语言MySql数据库操作类V1.0模块源码
易语言MySql数据库操作类V1.0模块源码易语言MySql数据库操作类V1.0模块源码系统结构:MySql数据库连接类_测试子程序,置连接选项,连接,关闭,是否已连接,取连接句柄,置连接句柄,执 ...
mysql从挂了数据怎么恢复_详解MySQL误操作后怎样进行数据恢复
一.开启binlog. 首先查看binlog是否开启 mysql> show variables like "log_bin"; +---------------+----- ...
sql重复数据只保留一条_一条SQL完成跨数据库实例Join查询
背景随着业务复杂程度的提高.数据规模的增长,越来越多的公司选择对其在线业务数据库进行垂直或水平拆分,甚至选择不同的数据库类型以满足其业务需求.原本在同一数据库实例里就能实现的SQL查询,现在需要跨多 ...
activemq 发两条只收到一条_浅谈ActiveMQ与使用
更多大数据架构.实战经验,欢迎关注[大数据每日哔哔],期待与你一起成长! 本文将介绍一下 ActiveMQ 的安装.原理和简单实战. 一.什么是消息中间件消息中间件顾名思义实现的就是在两个系统或两个 ...
mysql删除重复数据只保留一条_【SQL】mysql删除重复数据只保留一条
清洗数据的时候,发现有重复数据. 之前多用EXCEL处理数据,一键就可以delete了.这次因为数据量相对较大换了mysql. 按照百度搜到的一个高票代码,运行了半天都不对. 一直报错: 即按照mys ...
mysql操作数据库语句大全_常用的Mysql数据库操作语句大全整理
一.用户管理: 1.新建用户: >create user name identified by 'ssapdrow'; 2.更改密码: >set password for name=pas ...

easyui table 如何只展示一条_如何使用MySQL，这些操作你得明白!

easyui table 如何只展示一条_如何使用MySQL，这些操作你得明白!相关推荐

最新文章

热门文章