用pymysql操作数据库

用pymysql操作数据库随笔

from pymysql import Connectioncon = True
try:# 创建数据库连接con = Connection(host='localhost',port=3306,user='root',password='root',database='db_python',  # 设置要连接的数据库名称autocommit=True  # 设置自动提交)# 创建cursor对象cursor = con.cursor()# 创建一张表sql = """create table tb_goods(id int auto_increment primary key,name varchar(20) not null,price decimal(11,2) not null) engine=innodb default charset=utf8;"""# 执行这段sqlcursor.execute(sql)print('表创建成功')# 向表中插入一些数据cursor.execute("insert into tb_goods values (1,'西瓜','10'),(2,'香蕉','5');")print('插入成功')# 查询这张表中的数据cursor.execute("select * from tb_goods;")print('查询成功')# 将查询出来的数据显示在控制台result = cursor.fetchall()for row in result:print(row)# 更新表中的数据cursor.execute("update tb_goods set price=15 where id=1")print("更新后的数据")cursor.execute("select * from tb_goods;")result1 = cursor.fetchall()for i in result1:print(i)
except Exception as e:print("异常:", e)
finally:if con:con.close()