python使用pymysql模块操作MySQL

介绍

pymysql是python编程语言的一种数据库操作模块。它提供了一个python语言中的数据库API。它支持MySQL协议版本；这个模块替代了MySQLdb模块，可以作为MySQLdb的替代品，支持Python3。本文将详细讲解使用pymysql模块操作MySQL。

步骤

第一步：安装pymysql

可以通过pip命令来安装pymysql模块。请使用以下命令：

pip install pymysql

第二步：建立连接

使用pymysql操作mysql数据库之前，需要首先建立连接。需要提供MySQL服务器IP地址、用户名、密码和要连接的数据库。

import pymysql

db = pymysql.connect(
    host='127.0.0.1',
    user='root',
    password='root',
    db='test',
    charset='utf8'
)

第三步：创建游标

要执行sql语句，必须首先创建一个游标。

cursor = db.cursor()

第四步：操作MySQL

使用游标执行sql语句。

例如，创建一个名为blog_article的表：

create_table_sql = """
    create table blog_article (
        id int unsigned not null auto_increment,
        title varchar(200),
        content text,
        primary key (id)
    )
"""
cursor.execute(create_table_sql)

插入一条数据：

insert_sql = """
    insert into blog_article (title, content) values (%s, %s)
"""
cursor.execute(insert_sql, ('Python使用pymysql模块', '这是一篇使用pymysql创建的文章'))
db.commit() # 提交操作

查询：

select_sql = """
    select * from blog_article
"""
cursor.execute(select_sql)
result = cursor.fetchall() # 获取全部结果
for row in result:
    print(row)

注意：必须通过commit()方法提交对数据库的操作，否则数据不会保存。

第五步：关闭连接

使用完后必须关闭数据库连接。

db.close()

示例

下面的例子是一个完整的使用pymysql操作MySQL的示例。

import pymysql

db = pymysql.connect(
    host='127.0.0.1',
    user='root',
    password='root',
    db='test',
    charset='utf8'
)

# 创建表
create_table_sql = """
    create table blog_article (
        id int unsigned not null auto_increment,
        title varchar(200),
        content text,
        primary key (id)
    )
"""
cursor = db.cursor()
cursor.execute(create_table_sql)

# 插入数据
insert_sql = """
    insert into blog_article (title, content) values (%s, %s)
"""
cursor.execute(insert_sql, ('Python使用pymysql模块', '这是一篇使用pymysql创建的文章'))
db.commit() # 提交操作

# 查询数据
select_sql = """
    select * from blog_article
"""
cursor.execute(select_sql)
result = cursor.fetchall() # 获取全部结果
for row in result:
    print(row)

db.close()

总结

使用pymysql操作MySQL数据库非常简单，只需要安装模块，建立连接执行sql语句即可。本文介绍了使用pymysql的基本步骤，并提供了示例来说明如何使用这个模块操作MySQL。