官网文档链接：https://pymysql.readthedocs.io/en/latest/
1.PyMySQL 安装
1 pip install pymysql
2.数据库连接
注：MySQL数据库已创建数据库TESTDB，在TESTDB数据库中您已经创建了表 EMPLOYEE
1 # -*- coding:utf-8 -*- 2 import pymysql 3 4 # 打开数据库连接 5 connection = pymysql.connect( 6 host='localhost', # IP，MySQL数据库服务器IP地址 7 port=3306, # 端口，默认3306，可以不输入 8 user='root', # 数据库用户名 9 password='yxh1990', # 数据库登录密码 10 database='testdb', # 要连接的数据库 11 charset='utf8' # 字符集，注意不是'utf-8' 12 ) 13 14 # 使用cursor()方法创建一个游标对象cursor 15 cursor = connection.cursor() 16 17 # 使用execute()方法执行SQL查询 18 sql = 'SELECT VERSION()' 19 cursor.execute(sql) 20 21 # 使用fetchone()获取单条数据 22 data = cursor.fetchone() 23 print("数据库版本：%s" % data) 24 25 # 关闭数据库 26 connection.close()
执行后的结果：
数据库版本：5.7.21-log
2.创建数据库表
1 # -*- coding:utf-8 -*- 2 import pymysql 3 4 # 打开数据库连接 5 connection = pymysql.connect( 6 host='localhost', # IP，MySQL数据库服务器IP地址 7 port=3306, # 端口，默认3306，可以不输入 8 user='root', # 数据库用户名 9 password='yxh1990', # 数据库登录密码 10 database='testdb', # 要连接的数据库 11 charset='utf8' # 字符集，注意不是'utf-8' 12 ) 13 14 # 使用cursor()方法创建一个游标对象cursor 15 cursor = connection.cursor() 16 17 # 使用execute()方法执行SQL,如果表存在则删除 18 sql = 'DROP TABLE IF EXISTS EMPLOYEE' 19 cursor.execute(sql) 20 21 # 创建表 22 create_table_sql = """CREATE TABLE EMPLOYEE ( 23 ID INT(12) NOT NULL PRIMARY KEY AUTO_INCREMENT, 24 FIRST_NAME CHAR(20) NOT NULL, 25 LAST_NAME CHAR(20), 26 AGE INT, 27 SEX CHAR(1), 28 SALARY FLOAT)""" 29 cursor.execute(create_table_sql) 30 31 # 关闭数据库 32 connection.close()
3.数据库插入操作
1 # -*- coding:utf-8 -*- 2 import pymysql 3 4 # 打开数据库连接 5 connection = pymysql.connect( 6 host='localhost', # IP，MySQL数据库服务器IP地址 7 port=3306, # 端口，默认3306，可以不输入 8 user='root', # 数据库用户名 9 password='yxh1990', # 数据库登录密码 10 database='testdb', # 要连接的数据库 11 charset='utf8' # 字符集，注意不是'utf-8' 12 ) 13 14 # 使用cursor()方法创建一个游标对象cursor 15 cursor = connection.cursor() 16 17 # SQL插入语句 18 insert_sql = "INSERT INTO EMPLOYEE(FIRST_NAME, LAST_NAME, AGE, SEX, SALARY) 19 VALUES ('%s','%s', %s, '%s', %s)" 20 % ('Mac', 'Mohan', 20, 'M', 2000.00) 21 try: 22 # 执行sql语句 23 cursor.execute(insert_sql) 24 # 提交 25 connection.commit() 26 except: 27 # 发生错误时回滚 28 connection.rollback() 29 30 # 关闭数据库 31 connection.close()
批量插入：
1 # -*- coding:utf-8 -*- 2 import pymysql 3 4 # 打开数据库连接 5 connection = pymysql.connect( 6 host='localhost', # IP，MySQL数据库服务器IP地址 7 port=3306, # 端口，默认3306，可以不输入 8 user='root', # 数据库用户名 9 password='yxh1990', # 数据库登录密码 10 database='testdb', # 要连接的数据库 11 charset='utf8' # 字符集，注意不是'utf-8' 12 ) 13 14 # 使用cursor()方法创建一个游标对象cursor 15 cursor = connection.cursor() 16 17 # 插入语句 18 insert_sql = "INSERT INTO EMPLOYEE(FIRST_NAME, LAST_NAME, AGE, SEX, SALARY) VALUES (%s, %s, %s, %s, %s)" # 注意此处不要使用'%s'，使用s%站位 19 args_list = [('Mei', 'Han', 20, 'F', 3000.00), ('Obama', 'Qiao', 57, 'M', 2348.01), ('Jim', 'Cluse', 35, 'F', 2231.01), ('Macer', 'Jordan', 45, 'M', 2340.10)] 20 21 try: 22 # 执行sql语句 23 cursor.executemany(insert_sql, args_list) 24 # 提交 25 connection.commit() 26 except: 27 # 发生错误时回滚 28 connection.rollback() 29 30 # 关闭数据库 31 connection.close()
4.数据库查询操作
Python查询MySQL使用fetchone()获取单条数据，使用fetchmany(size=None)获取多条数据，使用fetchall()获取所有数据。
- fetchone()：获取下个一个查询结果集。结果集是一个对象（目前看到的事tuple格式）
- fetchmany(size=None)：从结果集中获取size个结果，如果size=None，则获取第一个
- fetchall()：获取全部的返回行。
- rowcount：这是一个只读属性，并返回执行execute()方法后影响的行数。
1 # -*- coding:utf-8 -*- 2 import pymysql 3 4 # 打开数据库连接 5 connection = pymysql.connect( 6 host='localhost', # IP，MySQL数据库服务器IP地址 7 port=3306, # 端口，默认3306，可以不输入 8 user='root', # 数据库用户名 9 password='yxh1990', # 数据库登录密码 10 database='testdb', # 要连接的数据库 11 charset='utf8' # 字符集，注意不是'utf-8' 12 ) 13 14 # 使用cursor()方法创建一个游标对象cursor 15 cursor = connection.cursor() 16 17 # 查询语句 18 select_sql = "SELECT * FROM EMPLOYEE WHERE SALARY>2000" 19 20 # fetchone()方法 21 try: 22 # 执行sql语句 23 cursor.execute(select_sql) 24 result_one = cursor.fetchone() 25 result_two = cursor.fetchone() 26 result_three = cursor.fetchone() 27 result_four = cursor.fetchone() 28 print(result_one) 29 print(result_two) 30 print(result_three) 31 print(result_four) 32 except: 33 print('fetchone获取数据失败') 34 35 # fetchmany(size=none) 36 try: 37 cursor.execute(select_sql) 38 result_many = cursor.fetchmany(size=None) 39 print(result_many) 40 except: 41 print('fetchmany获取数据失败') 42 43 # fetchall()和rowcount 44 try: 45 cursor.execute(select_sql) 46 result_all = cursor.fetchall() 47 row_count = cursor.rowcount 48 print(result_all) 49 print(row_count) 50 except: 51 print('fetchmany获取数据失败') 52 53 # 关闭数据库 54 connection.close()
以上脚本执行结果如下：
1 (2, 'Jim', 'Cluse', 32, 'M', 5000.78) 2 (3, 'Mary', 'Lily', 28, 'F', 3564.89) 3 (4, 'Tom', 'Kuke', 35, 'M', 4545.56) 4 None 5 ((2, 'Jim', 'Cluse', 32, 'M', 5000.78), (3, 'Mary', 'Lily', 28, 'F', 3564.89)) 6 ((2, 'Jim', 'Cluse', 32, 'M', 5000.78), (3, 'Mary', 'Lily', 28, 'F', 3564.89), (4, 'Tom', 'Kuke', 35, 'M', 4545.56)) 7 3
5.数据库更新操作
1 # -*- coding:utf-8 -*- 2 import pymysql 3 4 # 打开数据库连接 5 connection = pymysql.connect( 6 host='localhost', # IP，MySQL数据库服务器IP地址 7 port=3306, # 端口，默认3306，可以不输入 8 user='root', # 数据库用户名 9 password='yxh1990', # 数据库登录密码 10 database='testdb', # 要连接的数据库 11 charset='utf8' # 字符集，注意不是'utf-8' 12 ) 13 14 # 使用cursor()方法创建一个游标对象cursor 15 cursor = connection.cursor() 16 17 # 更新语句 18 update_sql = "UPDATE EMPLOYEE SET SALARY = SALARY + 1000 WHERE SEX='%c'" % ('M') 19 20 try: 21 # 执行sql语句 22 cursor.execute(update_sql) 23 connection.commit() 24 except: 25 # 发生错误时回滚 26 connection.rollback() 27 28 # 关闭数据库 29 connection.close()
6.数据库删除操作
1 # -*- coding:utf-8 -*- 2 import pymysql 3 4 # 打开数据库连接 5 connection = pymysql.connect( 6 host='localhost', # IP，MySQL数据库服务器IP地址 7 port=3306, # 端口，默认3306，可以不输入 8 user='root', # 数据库用户名 9 password='yxh1990', # 数据库登录密码 10 database='testdb', # 要连接的数据库 11 charset='utf8' # 字符集，注意不是'utf-8' 12 ) 13 14 # 使用cursor()方法创建一个游标对象cursor 15 cursor = connection.cursor() 16 17 # 删除语句 18 delete_sql = "DELETE FROM EMPLOYEE WHERE AGE>'%s'" % (30) 19 20 # fetchone()方法 21 try: 22 # 执行sql语句 23 cursor.execute(delete_sql) 24 # 提交修改 25 connection.commit() 26 except: 27 # 发生错误时回滚 28 connection.rollback() 29 30 # 关闭数据库 31 connection.close()
7.Connection类和Cursor类
7.1 Connection类
class pymysql.connections.Connection(host=None, user=None, password='', database=None, port=0, unix_socket=None, charset='', sql_mode=None, read_default_file=None, conv=None, use_unicode=None, client_flag=0, cursorclass=<class 'pymysql.cursors.Cursor'>, init_command=None, connect_timeout=10, ssl=None, read_default_group=None, compress=None, named_pipe=None, autocommit=False, db=None, passwd=None, local_infile=False, max_allowed_packet=16777216, defer_connect=False, auth_plugin_map=None, read_timeout=None, write_timeout=None, bind_address=None, binary_prefix=False, program_name=None, server_public_key=None)
参数：
host：数据库服务器所在的主机
user：用户名
password：密码
database：数据库名, None to not use a particular one.
port：端口号，默认值3306
charset：编码（注：utf8不是utf-8）
begin()：开始事务
close()：关闭连接
Raise:如果该连接已关闭，则会引起异常
commit():提交事务
cursor(cursor=None)：创建一个游标
参数：Cursor，SSCursor，DictCursor和SSDictCursor中的任意一个，默认None的时候用的Cursor
open：如果连接打开，则返回True
ping(reconnect=True)：检查数据库服务连接是否正常
参数：reconnect 如果连接断开则重新连接
Raise：如果连接已经关闭，且此时reconnect=False时则会引起异常
rollback()：回滚事务
select_db()：选择数据库
参数：db 数据库名称
show_warnings()：发送“警告”SQL命令
7.2 Cursor类
用于数据库交互的对象。不要用Corsor自己创建游标实例，调用connections.Connect.cursor()。
close()：使用所有数据时关闭游标
execute(query, args=None)：执行一个query语句
参数：
query(str)：Query to execute
args(tuple,list or dict)可选参数
返回：受影响的行数（返回类型：int）
注：如果参数args是列表或元组，%s可以用作查询中的占位符。如果参数args是一个字典， %(name)s可以用作查询中的占位符。
executemany(query, args)：通过参数批量执行query语句
参数：
query： Query to execute on the server
args：序列的序列或者映射的序列。
返回：受影响的行数（返回类型：int）
注：该方法提高了多行INSERT和REPLACE的性能。否则，它相当于用execute()遍历所有参数。
fetchall()：获取所有行
fetchmany(size=None)：根据size值获取行数
fetchone()：获取下一行
max_stmt_length=1024000：executemany()生成的语句的最大大小。
允许语句的最大大小为max_allowed_packet - packet_header_size。max_allowed_packet的默认值是1048576。
mogrify(query, args=None)：
7.3 SSCursor类，DictCursor类和SSDictCursor类
SSCursor中的方法有：close()、fetchall()、fetchall_unbuffered()、fetchmany(size=None)、fetchone()、read_next
SSCursor，无缓冲游标，主要用于返回大量数据的查询，或在网速慢的时候连接远程服务器。
使用 SSCursor (流式游标)，避免客户端占用大量内存。(这个 cursor 实际上没有缓存下来任何数据，它不会读取所有所有到内存中，它的做法是从储存块中读取记录，并且一条一条返回给你。)，需要注意的：因为 SSCursor 是没有缓存的游标,结果集只要没取完，这个 conn 是不能再处理别的 sql，包括另外生成一个 cursor 也不行的。如果需要干别的，请另外再生成一个连接对象。
DictCursor的返回结果是字典类型：
1 # -*- coding:utf-8 -*- 2 import pymysql 3 4 # 打开数据库连接 5 connection = pymysql.connect( 6 host='localhost', # IP，MySQL数据库服务器IP地址 7 port=3306, # 端口，默认3306，可以不输入 8 user='root', # 数据库用户名 9 password='yxh1990', # 数据库登录密码 10 database='testdb', # 要连接的数据库 11 charset='utf8' # 字符集，注意不是'utf-8' 12 ) 13 14 # 使用cursor()方法创建一个字典游标对象DictCursor 15 dict_cursor = connection.cursor(pymysql.cursors.DictCursor) 16 17 # 查询语句 18 select_sql = "SELECT * FROM EMPLOYEE" 19 20 try: 21 # 执行sql语句 22 dict_cursor.execute(select_sql) 23 result_all = dict_cursor.fetchall() 24 print(result_all) 25 except: 26 print('查询发生错误！') 27 28 # 关闭数据库 29 connection.close()
执行结果：
[{'ID': 1, 'FIRST_NAME': 'Mac', 'LAST_NAME': 'Mohan', 'AGE': 20, 'SEX': 'M', 'SALARY': 3000.0},
{'ID': 3, 'FIRST_NAME': 'Mary', 'LAST_NAME': 'Lily', 'AGE': 28, 'SEX': 'F', 'SALARY': 3564.89},
{'ID': 4, 'FIRST_NAME': 'Mei', 'LAST_NAME': 'Han', 'AGE': 20, 'SEX': 'F','SALARY': 3000.0},
{'ID': 5, 'FIRST_NAME': 'Obama', 'LAST_NAME': 'Qiao', 'AGE': 57, 'SEX': 'M', 'SALARY': 2348.01},
{'ID': 6, 'FIRST_NAME': 'Jim', 'LAST_NAME': 'Cluse', 'AGE': 35, 'SEX': 'F', 'SALARY': 2231.01},
{'ID': 7, 'FIRST_NAME': 'Macer', 'LAST_NAME': 'Jordan', 'AGE': 45, 'SEX': 'M', 'SALARY': 2340.1}]