利用Python3操作MySQL

1、主要使用的python包为pymysql，具体API见链接pymysql

2、本地数据库
主机：localhost
用户名：root
密码：123456

3、具体流程
连接——建库——建表——创建游标——基本操作（增-查-改-删）——事物回滚——表头输出

4、主要字符
数据库：conn
游标：cur
执行（单条数据）：execute
执行（多条数据）：executemany
查询（单条）：fetchone
查询（多条）：fetchmany
查询（全部）：fetchall
事务回滚：rollback
表头：description

1、导入第三方库

#导入pymysql包
import pymysql

2、建立本地连接

#连接数据库
conn=pymysql.connect("localhost","root","123456")
#connect中三个参数：主机名，用户名，密码

3、创建游标

python对mysql的操作都基于“游标”，因此需要创建cur

#创建游标
cur=conn.cursor()

4、创建数据库

#创建一个新的数据库NEW_test
cur.execute("CREATE DATABASE NEW_test DEFAULT CHARSET utf8 COLLATE utf8_general_ci")

5、创建数据表

①需要先选择一个数据库

#选择一个数据库
conn.select_db("NEW_test")

②创建数据表

#创建一个新的数据表NEW_table
sql="""CREATE TABLE `NEW_test`(`ID` int(11) NOT NULL AUTO_INCREMENT,`NAME` varchar(255) NOT NULL,`AGE` int(11) NOT NULL,PRIMARY KEY (`ID`))ENGINE=InnoDB  DEFAULT CHARSET=utf8 AUTO_INCREMENT=0"""
cur.execute(sql)

注意：创建数据表时的语句，最外层必须用"""包围，中间语句中“表名”，“列名”等都需要用`包围，否则报错

6、插入数据

①调用两个其他的库

import string,random
#一个字符串，一个随机库

②编写sql语句带入到execute/execute

#增——插入数据
sql="INSERT INTO NEW_test VALUES(%s,%s,%s)"
#这里利用字符串传入的方式，也可以直接将数据放在VALUES()里面#随机生成50组数据
words=list(string.ascii_letters)
for i in range(50):random.shuffle(words)#循环插入数据cur.execute(sql,(i+1,"".join(words[:3]),random.randint(0,100)))
#利用字符串的方式传入数据的方式是：execute(语句，具体的数据)#执行操作
conn.commit()

7、查询数据

①先定位要查询的数据表

cur.execute("SELECT * FROM NEW_test")

②利用fetchone(),fetchmany(),fetchall()对数据进行查找

#查询一行
cur.execute("SELECT * FROM NEW_test")
result=cur.fetchone()
print(result)
************
#查询n=3行
cur.execute("SELECT * FROM NEW_test")
result=cur.fetchmany(3)
for i in result:print(i)
************
#查询全部行
cur.execute("SELECT * FROM NEW_test")
result=cur.fetchall()
for i in result:print(i)

8、更新数据

①编写sql语句
②使用execute/executemany执行sql语句
③使用commit执行操作

#更新数据库——一条数据execute
sql="UPDATE NEW_test SET AGE=%s WHERE ID=%s"
cur.execute(sql,(99,1))
#必须要执行更新的操作
conn.commit()
************
#更新数据库——多条数据executemany
sql="UPDATE NEW_test SET AGE=%s WHERE ID=%s"
cur.executemany(sql,[(99,1),(98,2),(97,3)])
#执行更新操作
conn.commit()

9、删除数据

①编写sql语句
②使用execute/executemany执行sql语句
③使用commit执行操作

#删除操作——一条数据execute
sql="DELETE FROM NEW_test WHERE AGE=%s"
cur.execute(sql,(99))
#必须执行删除操作才行
conn.commit()
************
#删除操作——多条数据executemany
sql="DELETE FROM NEW_test WHERE AGE=%s"
cur.executemany(sql,(98,97))
#必须执行删除操作才行
conn.commit()

10、事务回滚

#事物回滚rollback-必须建立在conn.commit()之前，否则执行完就无法回滚
#未修改前前三行数据
cur.execute("SELECT * FROM NEW_test")
result=cur.fetchmany(3)
for i in result:print(i)
print("*"*20)#对前三行的数据进行修改
sql="UPDATE NEW_test SET AGE=%s WHERE ID=%s"
cur.executemany(sql,[(1,4),(2,5),(3,6)])
#输出修改结果
cur.execute("SELECT * FROM NEW_test")
result=cur.fetchmany(3)
for i in result:print(i)
print("*"*20)#利用rollback进行事务回滚
conn.rollback()
#输出事务回滚的结果
cur.execute("SELECT * FROM NEW_test")
result=cur.fetchmany(3)
for i in result:print(i)#必须要执行操作
conn.commit()

11、输出表头

conn=pymysql.connect("localhost","root","123456")
conn.select_db('NEW_test')
cur=conn.cursor()
#输出表头 cur.description
cur.execute("SELECT * FROM NEW_test")
result=cur.fetchall()#设置表头的输出
title=[]
des=cur.description
for i in des:title.append(i[0])
print(title)
for j in result:print(j)

未完待续：
明天会将自己整理的思维导图放在博客中

本文主要参考博客为：