本文共 2852 字，大约阅读时间需要 9 分钟。

PyMySQL 安装与使用指南

PyMySQL 安装

在 Windows 上安装

在 Python 3.6 中，自带 pip3，所以可以直接使用 pip3 安装所需模块：

pip3 install pymysql -i https://pypi.douban.com/simple

在 Linux 上安装

1.下载并解压 tar 包：

wget https://pypi.python.org/packages/29/f8/919a28976bf0557b7819fd6935bfd839118aff913407ca58346e14fa6c86/PyMySQL-0.7.11.tar.gz#md5=167f28514f4c20cbc6b1ddf831ade772
tar xf PyMySQL-0.7.11.tar.gz

2.使用 python3.6 安装：

[root@localhost PyMySQL-0.7.11]# python3.6 setup.py install

数据库连接

创建数据库和表

create database dbforpymysql;
create table userinfo (
    id int not null auto_increment primary key,
    username varchar(10),
    passwd varchar(10)
) engine=innodb default charset=utf8;
insert into userinfo values ('frank', '123'), ('rose', '321'), ('jeff', '666');

连接数据库

import pymysql
db = pymysql.connect(
    host="127.0.0.1",
    user="root",
    password="LBLB1212@@",
    database="dbforpymysql",
    charset='cp936'
)
cursor = db.cursor()
sql = 'SELECT * FROM userinfo'
cursor.execute(sql.encode('cp936'))
data = cursor.fetchall()
print(data)

数据库操作

增删改

在进行增删改操作时，记得使用 commits：

import pymysql
config = {
    "host": "127.0.0.1",
    "user": "root",
    "password": "LBLB1212@@",
    "database": "dbforpymysql"
}
db = pymysql.connect(**config)
cursor = db.cursor()
sql = "INSERT INTO userinfo (username, passwd) VALUES (%s, %s)"
cursor.execute(sql, ("jack", "123"))
db.commit()
cursor.close()
db.close()

查询操作

使用 fetchone()：

import pymysql
config = {
    "host": "127.0.0.1",
    "user": "root",
    "password": "LBLB1212@@",
    "database": "dbforpymysql"
}
db = pymysql.connect(**config)
cursor = db.cursor()
sql = "SELECT * FROM userinfo"
cursor.execute(sql)
res = cursor.fetchone()
print(res)
cursor.close()
db.close()

使用 fetchall()：

import pymysql
config = {
    "host": "127.0.0.1",
    "user": "root",
    "password": "LBLB1212@@",
    "database": "dbforpymysql"
}
db = pymysql.connect(**config)
cursor = db.cursor()
sql = "SELECT * FROM userinfo"
cursor.execute(sql)
res = cursor.fetchall()
print(res)
cursor.close()
db.close()

返回字典

为了更方便处理结果，可以使用 DictCursor：

import pymysql
config = {
    "host": "127.0.0.1",
    "user": "root",
    "password": "LBLB1212@@",
    "database": "dbforpymysql"
}
db = pymysql.connect(**config)
cursor = db.cursor(cursor=pymysql.cursors.DictCursor)
sql = "SELECT * FROM userinfo"
cursor.execute(sql)
res = cursor.fetchall()
print(res)
cursor.close()
db.close()

上下文管理器

使用 with 语句简化代码：

import pymysql
config = {
    "host": "127.0.0.1",
    "user": "root",
    "password": "LBLB1212@@",
    "database": "dbforpymysql"
}
db = pymysql.connect(**config)
with db.cursor(cursor=pymysql.cursors.DictCursor) as cursor:
    sql = "SELECT * FROM userinfo"
    cursor.execute(sql)
    res = cursor.fetchone()
    print(res)
    cursor.scroll(2, mode='relative')
    res = cursor.fetchone()
    print(res)
    cursor.close()
db.close()

以上方法可以帮助您更高效地与 MySQL 数据库进行交互。