Python3 MySQL 数据库连接 - PyMySQL 驱动

Python3 MySQL 数据库连接 - PyMySQL 驱动本文我们为大家介绍 Python3 使用 PyMySQL 连接数据库，并实现简单的增删改查。什么是 PyMySQL？PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库，Python2中则使用mysqldb。PyMySQL 遵循 Python 数据库 API v2.0 规范，并包含了 pure-Python MySQL 客户端库。PyMySQL 安装在使用 PyMySQL 之前，我们需要确保 PyMySQL 已安装。PyMySQL 下载地址：https:


//github.com/PyMySQL/PyMySQL。如果还未安装，我们可以使用以下命令安装最新版的 PyMySQL：$ pip3 install PyMySQL如果你的系统不支持 pip 命令，可以使用以下方式安装：1、使用 git 命令下载安装包安装(你也可以手动下载)：$ git clone https:


//github.com/PyMySQL/PyMySQL$ cd PyMySQL/$ python3 setup.py install2、如果需要制定版本号，可以使用 curl 命令来安装：$


# X.X 为 PyMySQL 的版本号$ curl -L https:


//github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X | tar xz$ cd PyMySQL*$ python3 setup.py install$


# 现在你可以删除 PyMySQL* 目录注意：请确保您有root权限来安装上述模块。安装的过程中可能会出现"ImportError:


No module named setuptools"的错误提示，意思是你没有安装setuptools，你可以访问https:


//pypi.python.org/pypi/setuptools 找到各个系统的安装方法。Linux 系统安装实例：$ wget https:


//bootstrap.pypa.io/ez_setup.py$ python3 ez_setup.py数据库连接连接数据库前，请先确认以下事项：您已经创建了数据库 TESTDB.在TESTDB数据库中您已经创建了表 EMPLOYEEEMPLOYEE表字段为 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。连接数据库TESTDB使用的用户名为 "testuser" ，密码为 "test123",你可以可以自己设定或者直接使用root用户名及其密码，Mysql数据库用户授权请使用Grant命令。在你的机子上已经安装了 Python MySQLdb 模块。如果您对sql语句不熟悉，可以访问我们的 SQL基础教程实例：以下实例链接 Mysql 的 TESTDB 数据库：实例(Python 3.0+)


#!/usr/bin/python3import pymysql


# 打开数据库连接db = pymysql.connect("localhost","testuser","test123","TESTDB" )


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


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


# 使用 fetchone() 方法获取单条数据.data = cursor.fetchone()print ("Database version :


%s " % data)


# 关闭数据库连接db.close()执行以上脚本输出结果如下：Database version :


5.5.20-log创建数据库表如果数据库连接存在我们可以使用execute()方法来为数据库创建表，如下所示创建表EMPLOYEE：实例(Python 3.0+)


#!/usr/bin/python3import pymysql


# 打开数据库连接db = pymysql.connect("localhost","testuser","test123","TESTDB" )


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


# 使用 execute() 方法执行 SQL，如果表存在则删除cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")


# 使用预处理语句创建表sql = """CREATE TABLE EMPLOYEE (FIRST_NAME CHAR(20) NOT NULL,LAST_NAME CHAR(20),AGE INT,SEX CHAR(1),INCOME FLOAT )"""cursor.execute(sql)


# 关闭数据库连接db.close()数据库插入操作以下实例使用执行 SQL INSERT 语句向表 EMPLOYEE 插入记录：实例(Python 3.0+)


#!/usr/bin/python3import pymysql


# 打开数据库连接db = pymysql.connect("localhost","testuser","test123","TESTDB" )


# 使用cursor()方法获取操作游标 cursor = db.cursor()


# SQL 插入语句sql = """INSERT INTO EMPLOYEE(FIRST_NAME,LAST_NAME, AGE, SEX, INCOME)VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""try:





# 执行sql语句cursor.execute(sql)


# 提交到数据库执行db.commit()except:





# 如果发生错误则回滚db.rollback()


# 关闭数据库连接db.close()以上例子也可以写成如下形式：实例(Python 3.0+)


#!/usr/bin/python3import pymysql


# 打开数据库连接db = pymysql.connect("localhost","testuser","test123","TESTDB" )


# 使用cursor()方法获取操作游标 cursor = db.cursor()


# SQL 插入语句sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \LAST_NAME, AGE, SEX, INCOME) \VALUES (%s, %s, %s, %s, %s )" % \('Mac', 'Mohan', 20, 'M', 2000)try:





# 执行sql语句cursor.execute(sql)


# 执行sql语句db.commit()except:





# 发生错误时回滚db.rollback()


# 关闭数据库连接db.close()以下代码使用变量向SQL语句中传递参数:


..................................user_id = "test123"password = "password"con.execute('insert into Login values( %s, %s)' % \ (user_id, password))..................................数据库查询操作Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。 fetchone():


该方法获取下一个查询结果集。结果集是一个对象 fetchall():


接收全部的返回结果行. rowcount:


这是一个只读属性，并返回执行execute()方法后影响的行数。 实例：查询EMPLOYEE表中salary（工资）字段大于1000的所有数据：实例(Python 3.0+)


#!/usr/bin/python3import pymysql


# 打开数据库连接db = pymysql.connect("localhost","testuser","test123","TESTDB" )


# 使用cursor()方法获取操作游标 cursor = db.cursor()


# SQL 查询语句sql = "SELECT * FROM EMPLOYEE \WHERE INCOME > %s" % (1000)try:





# 执行SQL语句cursor.execute(sql)


# 获取所有记录列表results = cursor.fetchall()for row in results:


fname = row[0]lname = row[1]age = row[2]sex = row[3]income = row[4]


# 打印结果print ("fname=%s,lname=%s,age=%s,sex=%s,income=%s" % \(fname, lname, age, sex, income ))except:


print ("Error:


unable to fetch data")


# 关闭数据库连接db.close()以上脚本执行结果如下：fname=Mac, lname=Mohan, age=20, sex=M, income=2000数据库更新操作更新操作用于更新数据表的的数据，以下实例将 TESTDB 表中 SEX 为 'M' 的 AGE 字段递增 1：实例(Python 3.0+)


#!/usr/bin/python3import pymysql


# 打开数据库连接db = pymysql.connect("localhost","testuser","test123","TESTDB" )


# 使用curs