Python之PyMySQL模块
PyMySQL 是在 Python3.x 版本下使用的一个可以直接使用 Python 标准数据库 API 进行连接和操作 MySQL 数据库的库。
以下是一些使用 PyMySQL 的基本方法:
- 安装 PyMySQL 模块
你可以使用 pip 命令来安装 PyMySQL 模块:
pip install pymysql
- 连接到数据库
使用 pymysql 的 connect() 函数来创建一个数据库连接:
import pymysql
conn = pymysql.connect(host='localhost', user='user', password='passwd', db='db', charset='utf8')
cur = conn.cursor()
cur.execute('SELECT VERSION()')
data = cur.fetchone()
print ("Database version : %s " % data)
cur.close()
conn.close()
- 执行 SQL 查询
使用 cursor() 方法创建一个游标对象,使用它的 execute() 方法来执行 SQL 查询:
import pymysql
conn = pymysql.connect(host='localhost', user='user', password='passwd', db='db', charset='utf8')
cur = conn.cursor()
cur.execute('SELECT VERSION()')
data = cur.fetchone()
print ("Database version : %s " % data)
cur.close()
conn.close()
- 插入数据
使用 cursor() 方法创建一个游标对象,使用它的 execute() 方法来执行 SQL 插入语句:
import pymysql
conn = pymysql.connect(host='localhost', user='user', password='passwd', db='db', charset='utf8')
cur = conn.cursor()
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, LAST_NAME, AGE, GENDER, INCOME) VALUES ('%s', '%s', '%d', '%c', '%d')" % ('Mac', 'Mohan', 20, 'M', 2000)
try:
cur.execute(sql)
conn.commit()
except:
conn.rollback()
cur.close()
conn.close()
- 关闭数据库连接
使用 close() 方法来关闭游标对象和数据库连接:
import pymysql
conn = pymysql.connect(host='localhost', user='user', password='passwd', db='db', charset='utf8')
cur = conn.cursor()
# 其他数据库操作
cur.close()
conn.close()
以上就是一些使用 PyMySQL 的基本方法,具体使用哪种方法,取决于你的具体需求。
评论已关闭