python怎么安装pymysql_Python 之 PyMySQL 安装和使用
Python具有内置的SQLite支持。 在本节中，我们将学习使用MySQL的相关概念和知识。 在早期Python版本一般都使用MySQLdb模块，但这个MySQL的流行接口与Python 3不兼容。因此，在教程中将使用PyMySQL模块。
1.什么是PyMySQL？
PyMySQL是从Python连接到MySQL数据库服务器的接口。 它实现了Python数据库API v2.0，并包含一个纯Python的MySQL客户端库。 PyMySQL的目标是成为MySQLdb的替代品。
2.如何安装PyMySQL？
在使用PyMySQL之前，请确保您的机器上安装了PyMySQL。只需在Python脚本中输入以下内容即可执行它 -
#!/usr/bin/python3
import pymysql
Python
在 Windows 系统上，打开命令提示符 -
C:\Users\Administrator>python
Python 3.6.1 (v3.6.1:69c0db5, Mar 21 2017, 18:41:36) [MSC v.1900 64 bit (AMD64)] on win32
Type "help", "copyright", "credits" or "license" for more information.
>>> import PyMySQL
Traceback (most recent call last):
File "", line 1, in
ModuleNotFoundError: No module named 'PyMySQL'
>>>
Shell
如果产生如上结果，则表示PyMySQL模块尚未安装。
最后一个稳定版本可以在PyPI上使用，可以通过pip命令来安装-
:\Users\Administrator> pip install PyMySQL
Collecting PyMySQL
Downloading PyMySQL-0.7.11-py2.py3-none-any.whl (78kB)
51% |████████████████▋ |
40kB 109kB/s eta 0:0 64% |████████████████████▊
| 51kB 112kB/s eta 77% |█████████████████████████ | 61kB 135kB/s 90% |█████████████████████████████
| 71kB 152 100% |████████████████████████████████| 81kB 163kB/s
Installing collected packages: PyMySQL
Successfully installed PyMySQL-0.7.11
C:\Users\Administrator>
Shell
或者(例如，如果pip不可用)，可以从GitHub下载tarball，并按照以下方式安装：
$ # X.X is the desired PyMySQL version (e.g. 0.5 or 0.6).
$ curl -L http://github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X | tar xz
$ cd PyMySQL*
$ python setup.py install
$ # The folder PyMySQL* can be safely removed now.
Shell
注意 - 确保具有root权限来安装上述模块。
3.数据库连接
在连接到MySQL数据库之前，请确保以下几点：
已经创建了一个数据库：test。
已经在test中创建了一个表:employee。
employee表格包含:fist_name，last_name，age，sex和income字段。
MySQL用户“root”和密码“123456”可以访问：test。
Python模块PyMySQL已正确安装在您的计算机上。
已经通过MySQL教程了解MySQL基础知识。
创建表employee的语句为：
CREATE TABLE `employee` (
`id` int(10) NOT NULL AUTO_INCREMENT,
`first_name` char(20) NOT NULL,
`last_name` char(20) DEFAULT NULL,
`age` int(11) DEFAULT NULL,
`sex` char(1) DEFAULT NULL,
`income` float DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
SQL
实例
以下是Python通过PyMySQL模块接口连接MySQL数据库“test”的示例 -
注意：在 Windows 系统上，import PyMySQL 和 import pymysql 有区别。
#!/usr/bin/python3
#coding=utf-8
import pymysql
# Open database connection
db = pymysql.connect("localhost","root","123456","test" )
# prepare a cursor object using cursor() method
cursor = db.cursor()
# execute SQL query using execute() method.
cursor.execute("SELECT VERSION()")
# Fetch a single row using fetchone() method.
data = cursor.fetchone()
print ("Database version : %s " % data)
# disconnect from server
db.close()
Python
运行此脚本时，会产生以下结果 -
Database version : 5.7.14-log
Shell
如果使用数据源建立连接，则会返回连接对象并将其保存到db中以供进一步使用，否则将db设置为None。 接下来，db对象用于创建一个游标对象，用于执行SQL查询。 最后，在结果打印出来之前，它确保数据库连接关闭并释放资源。
4.创建数据库表
建立数据库连接后，可以使用创建的游标的execute方法将数据库表或记录创建到数据库表中。
示例
下面演示如何在数据库：test中创建一张数据库表：employee -
#!/usr/bin/python3
#coding=utf-8
import pymysql
# Open database connection
db = pymysql.connect("localhost","root","123456","test" )
# prepare a cursor object using cursor() method
cursor = db.cursor()
# Drop table if it already exist using execute() method.
cursor.execute("DROP TABLE IF EXISTS employee")
# Create table as per requirement
sql = """CREATE TABLE `employee` (
`id` int(10) NOT NULL AUTO_INCREMENT,
`first_name` char(20) NOT NULL,
`last_name` char(20) DEFAULT NULL,
`age` int(11) DEFAULT NULL,
`sex` char(1) DEFAULT NULL,
`income` float DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;"""
cursor.execute(sql)
print("Created table Successfull.")
# disconnect from server
db.close()
Python
运行此脚本时，会产生以下结果 -
Created table Successfull.
Shell
5.插入操作
当要将记录创建到数据库表中时，需要执行INSERT操作。
示例
以下示例执行SQL的INSERT语句以在EMPLOYEE表中创建一条(多条)记录 -
#!/usr/bin/python3
#coding=utf-8
import pymysql
# Open database connection
db = pymysql.connect("localhost","root","123456","test" )
# prepare a cursor object using cursor() method
cursor = db.cursor()
# Prepare SQL query to INSERT a record into the database.
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
LAST_NAME, AGE, SEX, INCOME)
VALUES ('Mac', 'Su', 20, 'M', 5000)"""
try:
# Execute the SQL command
cursor.execute(sql)
# Commit your changes in the database
db.commit()
except:
# Rollback in case there is any error
db.rollback()
## 再次插入一条记录
# Prepare SQL query to INSERT a record into the database.
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
LAST_NAME, AGE, SEX, INCOME)
VALUES ('Kobe', 'Bryant', 40, 'M', 8000)"""
try:
# Execute the SQL command
cursor.execute(sql)
# Commit your changes in the database
db.commit()
except:
# Rollback in case there is any error
db.rollback()
print (sql)
print('Yes, Insert Successfull.')
# disconnect from server
db.close()
Python
运行此脚本时，会产生以下结果 -
Yes, Insert Successfull.
Shell
上述插入示例可以写成如下动态创建SQL查询 -
#!/usr/bin/python3
#coding=utf-8
import pymysql
# Open database connection
db = pymysql.connect("localhost","root","123456","test" )
# prepare a cursor object using cursor() method
cursor = db.cursor()
# Prepare SQL query to INSERT a record into the database.
sql = "INSERT INTO EMPLOYEE(FIRST_NAME,\
LAST_NAME,AGE,SEX,INCOME)\
VALUES ('%s','%s','%d','%c','%d')" % \
('Max', 'Su', 25, 'F', 2800)
try:
# Execute the SQL command
cursor.execute(sql)
# Commit your changes in the database
db.commit()
except:
# Rollback in case there is any error
db.rollback()
# disconnect from server
db.close()
Python
示例
以下代码段是另一种执行方式，可以直接传递参数 -
..................................
user_id = "test123"
password = "password"
con.execute('insert into Login values("%s", "%s")' % \
(user_id, password))
..................................
Python
6.读取操作
任何数据库上的读操作表示要从数据库中读取获取一些有用的信息。
在建立数据库连接后，就可以对此数据库进行查询了。 可以使用fetchone()方法获取单条记录或fetchall()方法从数据库表中获取多个值。
fetchone() - 它获取查询结果集的下一行。 结果集是当使用游标对象来查询表时返回的对象。
fetchall() - 它获取结果集中的所有行。 如果已经从结果集中提取了一些行，则从结果集中检索剩余的行。
rowcount - 这是一个只读属性，并返回受execute()方法影响的行数。
示例
以下过程查询EMPLOYEE表中所有记录的工资超过1000员工记录信息 -
#!/usr/bin/python3
#coding=utf-8
import pymysql
# Open database connection
db = pymysql.connect("localhost","root","123456","test" )
# prepare a cursor object using cursor() method
cursor = db.cursor()
# 按字典返回
# cursor = db.cursor(pymysql.cursors.DictCursor)
# Prepare SQL query to select a record from the table.
sql = "SELECT *FROM EMPLOYEE \
WHERE INCOME >%d" % (1000)
#print (sql)
try:
# Execute the SQL command
cursor.execute(sql)
# Fetch all the rows in a list of lists.
results = cursor.fetchall()
for row in results:
#print (row)
fname = row[1]
lname = row[2]
age = row[3]
sex = row[4]
income = row[5]
# Now print fetched result
print ("name = %s %s,age = %s,sex = %s,income = %s" % \
(fname, lname, age, sex, income ))
except:
import traceback
traceback.print_exc()
print ("Error: unable to fetch data")
# disconnect from server
db.close()
Python
name = Mac Su,age = 20,sex = M,income = 5000.0
name = Kobe Bryant,age = 40,sex = M,income = 8000.0
Shell
7.更新操作
UPDATE语句可对任何数据库中的数据进行更新操作，它可用于更新数据库中已有的一个或多个记录。
以下程序将所有SEX字段的值为“M”的记录的年龄(age字段)更新为增加一年。
#!/usr/bin/python3
#coding=utf-8
import pymysql
# Open database connection
db = pymysql.connect("localhost","root","123456","test" )
# prepare a cursor object using cursor() method
#cursor = db.cursor()
cursor = db.cursor(pymysql.cursors.DictCursor)
# prepare a cursor object using cursor() method
cursor = db.cursor()
# Prepare SQL query to UPDATE required records
sql = "UPDATE EMPLOYEE SET AGE =AGE +1\
WHERE SEX ='%c'" % ('M')
try:
# Execute the SQL command
cursor.execute(sql)
# Commit your changes in the database
db.commit()
except:
# Rollback in case there is any error
db.rollback()
# disconnect from server
db.close()
Python
8.删除操作
当要从数据库中删除一些记录时，那么可以执行DELETE操作。 以下是删除EMPLOYEE中AGE超过40的所有记录的程序 -
#!/usr/bin/python3
#coding=utf-8
import pymysql
# Open database connection
db = pymysql.connect("localhost","root","123456","test" )
# prepare a cursor object using cursor() method
cursor = db.cursor()
# Prepare SQL query to DELETE required records
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (40)
try:
# Execute the SQL command
cursor.execute(sql)
# Commit your changes in the database
db.commit()
except:
# Rollback in case there is any error
db.rollback()
# disconnect from server
db.close()
Python
9.执行事务
事务是确保数据一致性的一种机制。事务具有以下四个属性 -
原子性 - 事务要么完成，要么完全没有发生。
一致性 - 事务必须以一致的状态开始，并使系统保持一致状态。
隔离性 - 事务的中间结果在当前事务外部不可见。
持久性 - 当提交了一个事务，即使系统出现故障，效果也是持久的。
Python DB API 2.0提供了两种提交或回滚事务的方法。
示例
已经知道如何执行事务。 这是一个类似的例子 -
# Prepare SQL query to DELETE required records
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
# Execute the SQL command
cursor.execute(sql)
# Commit your changes in the database
db.commit()
except:
# Rollback in case there is any error
db.rollback()
Python
9.1.COMMIT操作
提交是一种操作，它向数据库发出信号以完成更改，并且在此操作之后，不会更改任何更改。
下面是一个简单的例子演示如何调用commit()方法。
db.commit()
Python
9.2.回滚操作
如果您对一个或多个更改不满意，并且要完全还原这些更改，请使用rollback()方法。
下面是一个简单的例子演示如何调用rollback()方法。
db.rollback()
Python
10.断开数据库连接
要断开数据库连接，请使用close()方法。
db.close()
Python
如果用户使用close()方法关闭与数据库的连接，则任何未完成的事务都将被数据库回滚。 但是，您的应用程序不会依赖于数据级别的实现细节，而是明确地调用提交或回滚。
11.处理错误
错误有很多来源。一些示例是执行的SQL语句中的语法错误，连接失败或为已取消或已完成语句句柄调用fetch方法等等。
DB API定义了每个数据库模块中必须存在的许多错误。下表列出了这些异常和错误 -
编号异常描述
1
Warning
用于非致命问题，是StandardError的子类。
2
Error
错误的基类，是StandardError的子类。
3
InterfaceError
用于数据库模块中的错误，但不是数据库本身，是Error的子类。
4
DatabaseError
用于数据库中的错误，是Error的子类。
5
DataError
DatabaseError的子类引用数据中的错误。
6
OperationalError
DatabaseError的子类，涉及如丢失与数据库的连接等错误。 这些错误通常不在Python脚本程序的控制之内。
7
IntegrityError
DatabaseError 子类错误，可能会损害关系完整性，例如唯一性约束和外键。
8
InternalError
DatabaseError的子类，指的是数据库模块内部的错误，例如游标不再活动。
9
ProgrammingError
DatabaseError的子类，它引用错误，如错误的表名和其他安全。
10
NotSupportedError
DatabaseError的子类，用于尝试调用不支持的功能。
Python脚本应该处理这些错误，但在使用任何上述异常之前，请确保您的PyMySQL支持该异常。 可以通过阅读DB API 2.0规范获得更多关于它们的信息。
python怎么安装pymysql_Python 之 PyMySQL 安装和使用相关推荐
- ubuntu下pymysql安装及python操作
用pymysql代替MySQLdb 在我刚开始学python的时候,用的是python2.7,那时候连接mysql用的库是MySQLdb(很诡异的大小写,初学者经常因为记不住大小写导致"No ...
- python3安装pymysql_python安装PyMySQL
官网操作教程:http://www.runoob.com/python3/python3-mysql.html 1.简介 PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的 ...
- python 2.7上安装pymssql和pymysql
现在服务器上python的默认安装不包括pymysql和pymssql,有时偶尔跑一个导出导入数据的脚本,就需要安装pymysql和pymmsql之类的. 如果是python 3,可以简单的用 pip ...
- python怎么安装各种模块_Python2.7安装和常用模块安装
a.傻瓜安装下一步就行 b.把python.exe所在目录就是安装python路径和Scripts文件夹路径即F:\Python\Scripts添加到环境变量中 使用cmd命令easy_install ...
- python pymysql_python使用pymysql实现操作mysql
pymsql是Python中操作MySQL的模块,其使用方法和MySQLdb几乎相同.但目前pymysql支持python3.x而后者不支持3.x版本. 适用环境 python版本 >=2.6或 ...
- python模块下载失败_pycharm自动安装模块失败了怎么办
pycharm自动安装模块失败了的解决方法:1.执行[pip -V]命令查看是否安装了pip:2.如果没有安装pip,则执行[python get-pip.py]命令进行安装:3.执行[pip ins ...
- 【Python】模块详解/如何安装模块的方法
什么是模块 一.模块.包 ①模块 Python 模块(Module) 实质上就是一个python集成文件.它是用来组织代码的,包含了 Python 对象定义和Python语句,意思就是把python代 ...
- pymysql安装过程
1.打开cmd 2.输入conda list查看anaconde下有无pymysql库 没有--> 3.直接输入pip install pymysql安装pymysql库 4.cmd下输入pyt ...
- linux pymysql 安装_Python进阶知识全篇-MySQL（PyMySQL）
什么是 PyMySQL? PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库,Python2中则使用mysqldb. PyMySQL 遵循 Python 数据库 AP ...
最新文章
- 微软开源: 老旧照片修复的AI算法
- jquery easy ui 1.3.4 数据表格(DataGrid)（8）
- 编译与解释实践（1）－flex and bison 配置安装
- 我算是优秀的程序员吗？
- 施一公谈自己35岁和53岁的区别
- Android笔记 codeUI与html UI
- 判断年月日是否正确及获取当前天的前一天或前一个月
- android studio没有logcat窗口_区块链研究实验室｜从Android调用区块链智能合约
- WinCE6.0 BootloaderMain源码分析之DownloadImage
- 如何设计一个完美的权限管理模块
- 图解Python编程：从入门到精通系列教程（附全套速查表）
- coding部署博客 + 腾讯云 cdn 踩坑日记
- 工业互联网是什么？发展有多厉害？
- 研究生自然辩证法试题题库及答案
- SSD、Retinanet、RefineDet、CornerNet、ExtremeNet、CenterNet、FSAF、FCOS、FoveaBox相对于yolo的区别
- 微信开发--IOS微信端confirm以及alert去掉网址的方法
- 学习《软件工程》心得
- Win10下用Anaconda安装TensorFlow
- 页面可视化搭建工具业界的轮子
- 无限流量与5G要来，我们距淘汰Wi-Fi还有多远？