pymysql对数据库的操作2

import  pymysql
conn=pymysql.connect(    #1.创建连接对象
    host="127.0.0.1",    #数据库服务所在的主机地址
    port=3306,           #占用的端口号
    user="root",         #用户名
    db="bee",            #pymysql连接操作的数据库
    charset="utf8"       #指定字符集uft8
)
cur = conn.cursor()       #2、创建游标
#创建数据库
# create_employee="create table employee(FIRST_NAME VARCHAR(20),LAST_NAME VARCHAR(20),AGE INT,SEX VARCHAR(1),INCOME FLOAT);"
# cur.execute(create_employee,)
#添加
# insert_employee="insert into employee values(%s,%s,%s,%s,%s);"
# cur.executemany(insert_employee,[('Mac','A',20,'M',20000),('Tom','B',20,'F',30000),('Bob','C',20,'M',40000)])
#查询
# select_employee="select * from employee;"
# cur.execute(select_employee)
# print(cur.fetchall())
#修改/更新
# update_employee="update employee set INCOME=%s where FIRST_NAME=%s;"
# cur.execute(update_employee,(10000,'Mac'))
#删除
# delete_employee="delete from employee where FIRST_NAME=%s;"
# cur.execute(delete_employee,'Tom')


#4.提交事务（保证数据写操作成功）以及关闭资源
conn.commit()  #提交事务  这句必须要有，否则数据可能写入不成功
cur.close()
conn.close()

conn.commit()  #提交事务  这句必须要有，否则数据可能写入不成功

conn.commit()提交事务必须要执行，否则数据库里面就查不到