pymysql

# ### python 操作mysql
import pymysql
# ###1 基本语法

# (1) 创建连接,用来连接mysql, host(主机) user password database 这四个参数必须写,端口可以写,但是不要带引号
conn=pymysql.connect(host="localhost",user="root",password="123456",database="testdb1",charset="utf8",port=3306)
# (2) 创建游标对象,有了该对象才能进行增删改查操作
cursor=conn.cursor()
# (3) 写要执行的sql语句
sql="select * from employee"
# (4)execute 开始执行,返回的结果是查询的总条数
res=cursor.execute(sql)
print(res)
# (5)获取查询结果的第一条数据
res=cursor.fetchone() #查询结果是元组
print(res)
# 获取查询结果的所有数据 fetchmany(n) 获取n条
res=cursor.fetchall()
print(res)
# (6)释放游标对象
cursor.close()
# (7)关闭连接
conn.close()

# ###2 创建/删除 数据库

conn=pymysql.connect(host="127.0.0.1",user="root",password="123456",database="testdb1")
cursor=conn.cursor()

sql="""
create table t1(
id int unsigned primary key auto_increment,
first_name char(10) not null,
last_name char(10) not null,
age int unsigned,
sex tinyint,
money float
)"""

res=cursor.execute(sql)
print(res)

# 2 查看表结构

sql="desc t1"
res=cursor.execute(sql)
print(res)
res=cursor.fetchone()
print(res)

#3删除表,异常梳理抑制错误,防止程序终止

try:
sql="drop table t1"
res=cursor.execute(sql)
print(res)
except:
pass

cursor.close()
conn.close()

# ###3 事物处理

"""python 操作事物处理,只有commit提交数据,才会真正的更改数据库,否则回滚"""
conn=pymysql.connect(host="127.0.0.1",user="root",password="123456",database="testdb1")
cursor=conn.cursor()
sql1="begin"
sql2="select * from employee"
sql3="update employee set emp_name='abc' where id=4"
sql4="commit"

cursor.execute(sql1)
cursor.execute(sql2)
cursor.execute(sql3)
cursor.execute(sql4)

cursor.close()
conn.close()