# 引入链接mysql数据库的包
import pymysql
# 创建链接对象
conn = pymysql.connect(host='localhost', port=3306, user='root', password='062823', database='dome')
# 获取游标对象
cs = conn.cursor()
# 插入语句
# sql = 'insert into showss (name) values("老王")'
# content = cs.execute(sql)
# print(content, '插入成功')
# # 删除语句
# sql = "delete from showss where name='老王'"
# content = cs.execute(sql)
# print(content, '删除成功')
find_name = input('请输入你的要查询的名字')
# 查询语句 防止sql注入 也可以过滤掉关键字防止sql 注入
sql = "select * from showss where name=%s"
print(sql, [find_name])
content = cs.execute(sql, [find_name])
print(content, '条影响的数据行数')
# print(cs.fetchone(), '获取一条数据')
for i in cs.fetchall():
print(i, '获取所有数据')
conn.commit() # pymysql是事务的,所以曾删改 都需要conn.commit()
cs.close() # 关闭游标
conn.close() # 关闭链接
发表评论