一、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 dbexcept:print('数据库连接失败！')

三、py创建表、增删改查

1、创建表

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

cursor = db.cursor()
SQL="省略..."
cursor.execute(SQL)

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()

3、查找数据

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

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

注：

• 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()