Python与MySQL的交互操作
安装mysql模块
# pip install -i https://pypi.doubanio.com/simple/ python-mysql # 支持 2.x版本 pip install -i https://pypi.doubanio.com/simple/ mysql-connector # 3.x
在文件中引入模块
import mysql.connector
关于Connection对象与Cursor对象
Connection对象
用于建立与数据库的连接
创建对象：调用connect()方法
conn=connect(参数列表)
参数host：连接的mysql主机，如果本机是'localhost'
参数port：连接的mysql主机的端口，默认是3306
参数db：数据库的名称
参数user：连接的用户名
参数password：连接的密码
参数charset：通信采用的编码方式，默认是'gb2312'，
要求与数据库创建时指定的编码一致，否则中文会乱码
对象的方法
close()关闭连接
commit()事务，所有任务需要提交才会生效
rollback()事务，放弃之前的操作
cursor()返回Cursor对象，用于执行sql语句并获得结果
Cursor 对象
执行sql语句
创建对象：调用Connection对象的cursor()方法
cursor1=conn.cursor()
对象的方法
close()关闭
execute(operation [, parameters ])执行语句，返回受影响的行数
fetchone()执行查询语句时，获取查询结果集的第一个行数据，返回一个元组
next()执行查询语句时，获取当前行的下一行
fetchall()执行查询时，获取结果集的所有行，一行构成一个元组，再将这些元组装入一个元组返回
scroll(value[,mode])将行指针移动到某个位置
mode表示移动的方式
mode的默认值为relative，表示基于当前行移动到value，value为正则向下移动， value为负则向上移动
mode的值为absolute，表示基于第一条数据的位置，第一条数据的位置为0
对象的属性
rowcount只读属性，表示最近一次execute()执行后受影响的行数
connection获得当前连接对象
连接 数据库
import mysql.connector mydb = mysql.connector.connect( host = "localhost" , # 数据库主机名 port = "3306" , user = "root" , # 数据库用户名 passwd = "123456" , # 数据库密码 ) print(mydb)
创建数据库 - CREATE DATABASE
# 创建一个名为 student_db 的数据库 mycursor = mydb.cursor() mycursor.execute("CREATE DATABASE student_db") # 查看数据库是否创建成功 mycursor.execute("SHOW DATABASES") for x in mycursor: print(x)
创建数据表 -- CREATE TABLE
# 创建数据表前，需要确保数据库已存在 import mysql.connector mydb = mysql.connector.connect( host = "localhost" , # 数据库主机名 port = "3306" , user = "root" , # 数据库用户名 passwd = "123456" , # 数据库密码 database = "student_db" # 数据库 ) mycursor = mydb.cursor() mycursor.execute("CREATE TABLE student (id INT(11),name VARCHAR(25),sex VARCHAR(10))") # 查看数据表是否创建成功 mycursor.execute("SHOW TABLES") for x in mycursor: print(x)
主键设置 -- INT AUTO_INCREMENT PRIMARY KEY
"""创建表的时候我们一般都会设置一个主键（PRIMARY KEY）， 我们可以使用 "INT AUTO_INCREMENT PRIMARY KEY" 语句来创建一个主键， 主键起始值为 1，逐步递增。 如果我们的表已经创建，我们需要使用 ALTER TABLE 来给表添加主键：""" mycursor.execute("ALTER TABLE student MODIFY COLUMN id INT AUTO_INCREMENT PRIMARY KEY") mycursor.execute("DESC student") for x in mycursor: print(x)
插入数据 -- INSERT INTO
## 单条数据的插入
import mysql.connector mydb = mysql.connector.connect( host = "localhost" , # 数据库主机名 port = "3306" , user = "root" , # 数据库用户名 passwd = "123456" , # 数据库密码 database = "student_db" # 数据库 ) mycursor = mydb.cursor() sql = "INSERT INTO student (id,name,sex) VALUES (%s,%s,%s)" val = (2020001,"Tom","male") mycursor.execute(sql, val) mydb.commit() # 数据表内容有更新，必须使用到该语句 print(mycursor.rowcount, "记录插入成功。")
## 批量数据的插入
sql = "INSERT INTO student (id,name,sex) VALUES (%s,%s,%s)"
val2 = (2020002,"Tony","male")
val3 = (2020003,"Alice","female")
val4 = (2020004,"Jim","male")
val5 = (2020005,"Eric","female")
val6 = (2020006,"Smish","male")
val7 = (2020007,"Candy","male")
val8 = (2020008,"Bonnie","female")
val9 = (2020009,"Pluto","female")
val10 = (2020010,"Clinton","female")
vals = (val2,val3,val4,val5,val6,val7,val8,val9,val10)
mycursor.executemany(sql, vals)
mydb.commit() # 数据表内容有更新，必须使用到该语句
print(mycursor.rowcount, "记录插入成功。")
数据查询 selimport mysql.connector
mydb = mysql.connector.connect( host = "localhost" , # 数据库主机名 port = "3306" , user = "root" , # 数据库用户名 passwd = "123456" , # 数据库密码 database = "student_db" # 数据库 ) mycursor = mydb.cursor()
###
# fetchall() 获取所有记录
mycursor.execute("SELECT * FROM student") results = mycursor.fetchall() for result in results: print(result)
### 读取指定的字段数据
mycursor.execute("SELECT name, sex FROM student")
results = mycursor.fetchall()
for result in results:
print(result)
### 如果我们只想读取一条数据，可以使用 fetchone() 方法
mycursor.execute("SELECT name, sex FROM student")
result = mycursor.fetchone()
print(result)
where 条件语句
import mysql.connector mydb = mysql.connector.connect( host = "localhost" , # 数据库主机名 port = "3306" , user = "root" , # 数据库用户名 passwd = "123456" , # 数据库密码 database = "student_db" # 数据库 ) mycursor = mydb.cursor() # 插入单行数据 sql = "INSERT INTO student (id,name,sex) VALUES (%s,%s,%s)" val = (2020011,"Tom","female") mycursor.execute(sql, val) mydb.commit() # 数据表内容有更新，必须使用到该语句 # 数据查询 mycursor.execute("SELECT * FROM student WHERE name='Tom'") results = mycursor.fetchall() for result in results: print(result)
使用通配符 %
import mysql.connector mydb = mysql.connector.connect( host = "localhost" , # 数据库主机名 port = "3306" , user = "root" , # 数据库用户名 passwd = "123456" , # 数据库密码 database = "student_db" # 数据库 ) mycursor = mydb.cursor() # 数据查询 mycursor.execute("SELECT * FROM student WHERE sex LIKE 'fe%'") results = mycursor.fetchall() for result in results: print(result)
排序 orderBy
排序 -- ORDER BY """ 查询结果排序可以使用 ORDER BY 语句，默认的排序方式为升序， 关键字为 ASC，如果要设置降序排序，可以设置关键字 DESC。 """ import mysql.connector mydb = mysql.connector.connect( host = "localhost" , # 数据库主机名 port = "3306" , user = "root" , # 数据库用户名 passwd = "123456" , # 数据库密码 database = "student_db" # 数据库 ) mycursor = mydb.cursor() # 数据排序 -- 默认升序 ASC # mycursor.execute("SELECT * FROM student ORDER BY name") mycursor.execute("SELECT * FROM student ORDER BY name DESC") # 降序排序 results = mycursor.fetchall() for result in results: print(result)
设置查询的数据量与位置-- LIMIT vs OFFSET
# 如果我们要设置查询的数据量，可以通过 "LIMIT" 语句来指定 import mysql.connector mydb = mysql.connector.connect( host = "localhost" , # 数据库主机名 port = "3306" , user = "root" , # 数据库用户名 passwd = "123456" , # 数据库密码 database = "student_db" # 数据库 ) mycursor = mydb.cursor() mycursor.execute("SELECT * FROM student LIMIT 4") results = mycursor.fetchall() for result in results: print(result)
指定起始位置 - OFFSET
# 0 为 第一条，1 为第二条，以此类推
mycursor.execute("SELECT * FROM student LIMIT 4 OFFSET 3")
results = mycursor.fetchall()
for result in results:
print(result)
数据删除
# 删除记录使用 "DELETE FROM" 语句 import mysql.connector mydb = mysql.connector.connect( host = "localhost" , # 数据库主机名 port = "3306" , user = "root" , # 数据库用户名 passwd = "123456" , # 数据库密码 database = "student_db" # 数据库 ) # 插入单行数据 mycursor = mydb.cursor() sql = "INSERT INTO student (id,name,sex) VALUES (%s,%s,%s)" val = (2020011,"Tom","female") mycursor.execute(sql, val) mydb.commit() # 数据表内容有更新，必须使用到该语句 # 删除单行数据 mycursor = mydb.cursor() sql = "DELETE FROM student WHERE id='2020011'" mycursor.execute(sql) mydb.commit() print(mycursor.rowcount, " 条记录删除") """注意： 要慎重使用删除语句，删除语句要确保指定了 WHERE 条件语句， 否则会导致整表数据被删除。 为了防止数据库查询发生 SQL 注入的攻击， 我们可以使用 %s 占位符来转义删除语句的条件：""" import mysql.connector mydb = mysql.connector.connect( host = "localhost" , # 数据库主机名 port = "3306" , user = "root" , # 数据库用户名 passwd = "123456" , # 数据库密码 database = "student_db" # 数据库 ) # 删除单行数据 mycursor = mydb.cursor() sql = "DELETE FROM student WHERE id= %s" value = ("2020007",) # 元组模式传递 mycursor.execute(sql,value) mydb.commit() print(mycursor.rowcount, " 条记录删除")
更新数据 update
import mysql.connector mydb = mysql.connector.connect( host = "localhost" , # 数据库主机名 port = "3306" , user = "root" , # 数据库用户名 passwd = "123456" , # 数据库密码 database = "student_db" # 数据库 ) # 删除单行数据 mycursor = mydb.cursor() sql = "UPDATE student SET name= %s WHERE name= %s" value = ("Choocelate","Smish") # 元组模式传递 mycursor.execute(sql,value) mydb.commit() print(mycursor.rowcount, " 条记录被修改")
数据库与数据表的删除 -- drop
# 删除表 -- DROP TABLE """ 删除表使用 "DROP TABLE" 语句， IF EXISTS 关键字是用于判断表是否存在， 只有在存在的情况才删除：""" import mysql.connector mydb = mysql.connector.connect( host = "localhost" , # 数据库主机名 port = "3306" , user = "root" , # 数据库用户名 passwd = "123456" , # 数据库密码 database = "student_db" # 数据库 ) mycursor = mydb.cursor() sql = "DROP TABLE IF EXISTS student" # 删除数据表 student mycursor.execute(sql) # 查看数据库是否被删除 mydb = mysql.connector.connect( host = "localhost" , # 数据库主机名 port = "3306" , user = "root" , # 数据库用户名 passwd = "123456" , # 数据库密码 database = "student_db" # 数据库 ) mycursor = mydb.cursor() mycursor.execute("SHOW TABLES") for x in mycursor: print(x)