Python入门之操作MySQL数据库

PyMySQL是？

PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库，Python2中则使用mysqldb。

PyMySQL 遵循 Python 数据库 API v2.0 规范，并包含了 pure-Python MySQL 客户端库。

如何安装？

使用万能的pip命令即可

pip install PyMySQL

如何使用

简单查询例子（查询）

一个最简单的查询，使用execute()方法查询：

import pymysql

DB_HOST = '127.0.0.1'
DB_USERNAME = 'root'
DB_PASSWORD = 'root'
DB_DATABASE = 'spider'

# 创建数据库连接
db = pymysql.connect(DB_HOST, DB_USERNAME, DB_PASSWORD, DB_DATABASE)

# 创建游标对象
cursor = db.cursor()

# 使用execute方法执行
cursor.execute("SELECT * FROM huatu LIMIT 10")

# 获取数据
datas = cursor.fetchall()

for data in datas:
    print(data)

# 关闭连接
db.close()

数据库查询操作方法

Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。

• fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
• fetchall(): 接收全部的返回结果行.
• rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数。

数据添加、删除、修改

插入数据多一个commit()方法（提交事务），以及发生错误的回滚。
例子代码：

import pymysql

DB_HOST = '127.0.0.1'
DB_USERNAME = 'root'
DB_PASSWORD = 'root'
DB_DATABASE = 'flask'

# 创建数据库连接
db = pymysql.connect(DB_HOST, DB_USERNAME, DB_PASSWORD, DB_DATABASE)

# 创建游标对象
cursor = db.cursor()

sql = """INSERT INTO user(telephone, username, password)
VALUES ('123456789', 'admin', 'admin')"""



try:
    # 使用execute方法执行
    cursor.execute(sql)
    # 提交事务
    db.commit()
except:
    # 遇到错误回滚
    db.rollback()

# 关闭连接
db.close()