5分钟立马学会使用python的pymysql库操作Mysql

一、py操作数据库流程

1. 数据库初始化连接
2. 创建游标，编写sql
3. 执行SQL

二、数据库初始化连接

def init_db():
    host = 'localhost'
    user = '你的账号'
    password = '你的密码'
    database = '***'
    try:
        db = pymysql.connect(host=host, user=user, password=password, database=database, charset='utf8')
        return db
    except:
        print('数据库连接失败！')
1
2
3
4
5
6
7
8
9
10

三、py创建表、增删改查

1、创建表

1. 创建游标
2. 编写sql
3. 执行sql

cursor = db.cursor()
SQL="省略..."
cursor.execute(SQL)
1
2
3

2、插入数据、删除数据、修改数据

1. 创建游标
2. 编写SQL
3. 执行语句，提交事务，若插入失败则回滚。

注：以插入数据为例，删除与修改数据仅差别在sql语句，流程一致。

#要插入的数据
link='hhh'
cover='test'
cursor = db.cursor()
sql = 'insert into douban_top250(details_link,film_cover)values("%s","%s")' % (link, cover)
try:
   # 执行SQL语句
   cursor.execute(sql)
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()
1
2
3
4
5
6
7
8
9
10
11
12
13

3、查找数据

1. 创建游标、编写查询SQL
2. 游标执行SQL语句
3. 通过游标获取查询到的数据

cursor = db.cursor()
#查询SQL语句
sql = "SELECT * FROM EMPLOYEE"
# 执行SQL语句
cursor.execute(sql)
#获取所有记录
results = cursor.fetchall()
1
2
3
4
5
6
7

注：

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

四、执行事务

事务提供了两个方法 commit 或 rollback。commit用于执行游标的操作，rollback用于回滚游标的操作。

# SQL删除记录语句
sql = "DELETE FROM BOOK WHERE ID=1"
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 向数据库提交
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()
1
2
3
4
5
6
7
8
9
10