# test02_pymysql.py
# 在 tedu1 库中实现下列操作
import pymysql
conn = pymysql.connect(  # 1. 与数据库服务建立连接
    host="127.0.0.1",    # mysql服务所在的主机地址
    port=3306,           # 端口号, 数字类型
    user="root",         # mysql服务用户名
    db="tedu1",          # 操作的数据库名称
    charset="utf8"       # 指定中文字符集
)
cur = conn.cursor()  # 2. 创建游标--操作数据库的接口
# 3. 数据库操作
# ====================3.1 建表=======================
# create_yg = """create table yg (
#     FIRST_NAME VARCHAR(20), LAST_NAME VARCHAR(20),
#     AGE INT, SEX VARCHAR(1), INCOME FLOAT
# );"""
# cur.execute(create_yg)
# ==================3.2 插入数据======================
# insert_yg = "insert into yg values(%s, %s, %s, %s, %s);"
# cur.execute(insert_yg, ('Mac', 'A', 20, 'M', 20000))  # 单条
# cur.executemany(  # 批量
#     insert_yg, [
#         ('Tom', 'B', 20, 'F', 30000),
#         ('Bob', 'C', 20, 'M', 40000)
#     ]
# )
# ==================3.3 查询数据======================
# select_yg = "select * from yg;"
# cur.execute(select_yg)
# print(cur.fetchall())
# ==================3.4 更新数据======================
# update_yg = "update yg set INCOME=%s where FIRST_NAME=%s;"
# cur.execute(update_yg, (10000, "Mac"))
# ==================3.5 删除数据======================
delete_yg = "delete from yg where FIRST_NAME=%s;"
cur.execute(delete_yg, "Tom")
# 4. 提交事务以及关闭资源
conn.commit()  # 提交事务(保证写操作成功)
cur.close()
conn.close()






# 2. 使用 PyMySQL 创建该表
# 3. 使用 PyMySQL 添加以下三条数据
#    1.    'Mac', 'A', 20, 'M', 20000
#    2.    'Tom', 'B', 20, 'F', 30000
#    3.    'Bob', 'C', 20, 'M', 40000
# 4. 使用 PyMySQL 查询所有用户信息，并打印结果
# 5. 将 FIRST_NAME  为 Mac 的用户工资改成 10000
# 6. 删除 FIRST_NAME  为 Tom 的用户信息