PyMySQL是从Python连接到MySQL数据库服务器的接口。 它实现了Python数据库API v2.0，并包含一个纯Python的MySQL客户端库

一、PyMysql安装

pip install pymysql 或者
pip3 install pymysql

二、连接数据库

pymysql连接数据库使用的是 pymsql.connect() 函数，其常用参数如下：

三、数据库常用操作

1、创建数据库

cursor.execute("create database db3 default charset utf8 collate utf8_general_ci")
conn.commit()

2、删除数据库

cursor.execute("drop database db3")
conn.commit()

3、查看数据库

cursor.execute("show databases")
# 获取指令的结果
result = cursor.fetchall()
print(result) # (('information_schema',), ('db3',), ('mysql',), ('performance_schema',), ('sys',))

4、进入数据库、查看表

cursor.execute("use mysql")
cursor.execute("show tables")
result = cursor.fetchall()
print(result) # (('columns_priv',), ('db',), ('engine_cost',), ('event',), ('func',), ('general_log',),..

5、创建数据表

cursor.execute("use db4")
sql = """
create table L4(
    id int not null primary key auto_increment,
    title varchar(128),
    content text,
    ctime datetime
)default charset=utf8;
"""
cursor.execute(sql)
conn.commit()

四、数据表常用操作

连接完数据库后，需要创建一个游标对象，模块会通过游标对象来执行sql语句以及获取查询结果，接下来直接通过代码展示各方法。

# 示例
import pymysql
 db = pymysql.connect(
	host = '127.0.0.1',
	port = 3306,
	user = 'root',
	password = 'admin',
	db = 'students',
	charset = 'utf8'
	)
	
# 获取mysql服务信息（测试连接，会输出MySQL版本号）
print(db.get_server_info())

cursor = db.cursor()  # 创建游标卡尺
# 创建游标(查询数据返回为字典格式)
cursor = db.cursor(pymysql.cursors.DictCursor)
sql = 'show databases'  # sql语句
try:
	cursor.execute(sql) # 执行sql语句
	cursor.commit()  # 提交事务
except:
	db.rollback()  # 若出现错误，则回滚

one = cursor.fetchone() # 获取一条数据
many = cursor.fetchmany(3) # 获取多条数据
all = cursor.fetchall() # 获取所有数据

cursor.close()  # 关闭游标
db.close() # 关闭数据库链接	

# 注意事项：
# 从结果可以看出，fetchone()，fetchmany(size)，fetchall() 三个函数返回值都是元组
# 但是fetchone()返回的是单个元组，另外两个返回的都是元组的嵌套。

一旦建立了与数据库的连接，我们就可以执行各种SQL操作，例如插入、更新、删除和查询等。以下是一些常见的SQL操作示例：

1、插入数据

sql = "INSERT INTO mytable (name, age) VALUES ('John', 25)"
cursor.execute(sql)
conn.commit()

2、删除数据

sql = "DELETE FROM mytable WHERE name = 'John'"
cursor.execute(sql)
conn.commit()

3、修改数据/更新数据

sql = "UPDATE mytable SET age = 26 WHERE name = 'John'"
cursor.execute(sql)
conn.commit()

4、查询数据

sql = "SELECT \* FROM mytable"
cursor.execute(sql)
conn.commit()
# 只要不涉及数据的更改，可以不需要调用commit()方法提交更改
result = cursor.fetchall()
for row in result:
    print(row)

# 注意事项：
# 使用cursor.execute()方法来执行SQL语句，当更改表中数据时，必须调用conn.commit()方法来提交更改，否则数据库表中的数据不会发生改变。操作完成后，可以使用cursor.fetchall()方法获取查询结果，该方法返回一个元组。

五、其他

1、 游标对象的方法：

2、其他方法

3、【拓展】 ：执行sql语句时，sql里面的参数，可能需要动态传参

# 一是采用format函数
# 但是一般情况下不推荐使用format函数，因为format函数里的内容可以比较长，内容比较多，可能造成sql注入等一系列安全问题，比如插入执行了一条删除语句，可能就会造成表的删除
sql = "select * from users where phonenum ={};".format(phone)

# 2、二是通过%s占位符
sql = "select * FROM users  WHERE birth_year < %s and birth_month > %s "
cursor.execute(sql=sql,args=[2000,4])