第十三章 Python操作数据库-CSDN博客

---

pymysql模块准备与基本使用

pymysql模块

pymysql是python中操作MySQL的模块其使用方法和MySQLdb几乎相同但目前pymysql支持python3.x而后者不支持3.x版本
pymysql是第三方模块需要单独安装首选通过pip安装PyMySQL

pip3 install pymysql

基本使用

先创建库以及表

# 创建库
create database test;
创建表
use test;
create table user(id int primary key not null auto_increment,username varchar(50) not null,password varchar(50) not null);
查看表
show tables;
查看表类型
describe user;

from unittest import result
import pymysql
conn = pymysql.connect(host='127.0.0.1',
                        port=3306,
                        user='root',
                        password='123.com',
                        db='test',
                        charset='utf8',
                        cursorclass=pymysql.cursors.DictCursor
                        )
# 创建游标
cursor = conn.cursor()
# 向user表插入数据id是自增不需要插入
sql = "insert into user(username,password) values('root','123.com')"
cursor.execute(sql)
# 向数据库提交进行写入
conn.commit()
sql = "select * from user"
cursor.execute(sql)
result = cursor.fetchone()
print(result)

connect()函数常用参数

方法	描述
host	数据库主机地址
user	数据库账户
passwd	账户密码
db	使用的数据库
port	数据库主机端口默认3306
connect_timeout	连接超时时间默认10单位秒
charset	使用的字符集
cursorclass	自定义游标使用的类,上面实例用的是字典类,以字典形式返回结果,默认是元组形式

连接对象常用方法

方法	描述
commit()	提交事务,对支持事务的数据库和表,如果提交修改操作,不适用这个方法,则不会写到数据库中
rollback()	失误回滚对支持事务的数据库和表如果执行此方法则回滚当前事务在没有commit()前提下
cursor([cursorclass])	创建一个游标对象所有的sql语句的执行都要再游标对象下进行mysql本身不支持游标mysqldb模块对其游标进行了方针

游标对象常用方法

方法	描述
close()	关闭游标
excute(sql)	执行sql语句
executemany(sql)	执行多条sql语句
fetchone()	从运行结果中取第一条记录返回字典
fetchmany(n)	从运行结果中取n条记录返回列表
fetchall()	从运行结果中取所有记录返回列表

from unittest import result
import pymysql
conn = pymysql.connect(host='127.0.0.1',
                        port=3306,
                        user='root',
                        password='123.com',
                        db='test',
                        charset='utf8',
                        cursorclass=pymysql.cursors.DictCursor
                        )
try:
    with conn.cursor() as cursor:
        # 创建一条记录
        sql = "insert into user(username,password) values('wang','123.com')"
        cursor.execute(sql)
    # 写入到数据库
    conn.commit()

    with conn.cursor() as cursor:
        # 读取一条记录
        sql = "select id,username,password from user"
        cursor.execute(sql)
        result = cursor.fetchall()
        print(result)
finally: # 不管try有没有执行都执行这个进行关闭数据库
    conn.close()

数据库增删改查

from sqlite3 import Cursor
from unittest import result
import pymysql
conn = pymysql.connect(host='127.0.0.1',
                        port=3306,
                        user='root',
                        password='123.com',
                        db='test',
                        charset='utf8',
                        cursorclass=pymysql.cursors.DictCursor
                        )
cursor = conn.cursor()
# 增
sql = "insert into user(username,password) values(%s,%s)"
args = [('张三','123.com'),('李四','123.com'),('王五','123.com')]
cursor.executemany(sql,args)
conn.commit()
# 删
sql = "delete from user  where id='7'"
cursor.execute(sql)
conn.commit()
# 改
sql = "update user set password='66666'  where id='6'"
cursor.execute(sql)
conn.commit()
# 查
sql = "select * from user"
cursor.execute(sql)
print('获取第一条记录:',cursor.fetchone())
print('获取指定多少条记录:',cursor.fetchmany(3))
print('获取所有记录:',cursor.fetchall())

案例查询数据库并格式化输出

import pymysql
conn = pymysql.connect(host='127.0.0.1',
                        port=3306,
                        user='root',
                        password='123.com',
                        db='test',
                        charset='utf8',
                        cursorclass=pymysql.cursors.DictCursor
                        )
try:
    with conn.cursor() as cursor:
        # 读取一条记录
        sql = "select * from user"
        cursor.execute(sql)
        result = cursor.fetchall()
        for d in result:
            print(f"ID:{d['id']},用户名{d['username']},密码{d['password']}")
finally: # 不管try有没有执行都执行这个进行关闭数据库
    conn.close()

---

总结

以上就是今天要讲的内容本文仅仅简单学习了python操作数据库针对数据库做增删改查。