- # 显示界面信息
- # 循环界面信息
- # 根据用户输入数据来做相应的选择
- from pymysql import connect
- def jingdong_info():
- '''# 显示界面信息'''
- print('*' * 20)
- print('1 查询所有商品信息')
- print('2 查询所有商品在种类信息')
- print('3 查询所有商品在品牌信息')
- print('4 添加商品种类')
- print('5 根据 id 查询商品信息')
- print('6 根据 id 查询商品信息安全方式')
- print('0 退出系统')
- print('*' * 20)
- def query_all_info():
- '''查询所有商品信息'''
- # 1. 连接数据库
- conn = connect(host='localhost', port=3306, user='root', password='mysql', database='jing_dong', charset='utf8')
- cs = conn.cursor()
- # 2. 执行 sql 语句
- sql = '''select * from goods;'''
- print('所执行的 sql 语句是:', sql)
- cs.execute(sql)
- # 获取数据
- data = cs.fetchall()
- # 3. 关闭
- cs.close()
- conn.close()
- # 有关查询的数据操作放在关闭后
- for temp in data:
- print(temp)
- def query_all_cate_info():
- '''查询所有商品在种类信息'''
- # 1. 连接数据库
- conn = connect(host='localhost', port=3306, user='root', password='mysql', database='jing_dong', charset='utf8')
- cs = conn.cursor()
- # 2. 执行 sql 语句
- sql = '''select * from goods_cates;'''
- print('所执行的 sql 语句是:', sql)
- cs.execute(sql)
- # 获取数据
- data = cs.fetchall()
- # 3. 关闭
- cs.close()
- conn.close()
- # 有关查询的数据操作放在关闭后
- for temp in data:
- print(temp)
- def query_all_brand_info():
- """查询所有商品在品牌信息"""
- # 1. 连接数据库
- conn = connect(host='localhost', port=3306, user='root', password='mysql', database='jing_dong', charset='utf8')
- # 创建一个游标
- cs = conn.cursor()
- # 2. 执行 sql 语句
- sql = '''select * from goods_brands;'''
- print('所执行的 sql 语句是:', sql)
- cs.execute(sql)
- # 获取数据
- data = cs.fetchall()
- # 3. 关闭
- cs.close()
- conn.close()
- # 数据的操作
- for temp in data:
- print(temp)
- def add_goods_cates_name(class_name):
- '''添加商品种类的名称'''
- # 1. 连接数据库
- conn = connect(host='localhost', port=3306, user='root', password='mysql', database='jing_dong', charset='utf8')
- # 创建一个游标
- cs = conn.cursor()
- # 2. 执行 sql 语句
- sql = '''insert into goods_cates(NAME ) VALUES ("%s");''' % class_name
- print('所执行的 sql 语句是:', sql)
- # 这里用一个元组去传参有助于数据的安全传输
- cs.execute(sql)
- # 注意 有关数据的操作需要提交
- conn.commit()
- # 3. 关闭
- cs.close()
- conn.close()
- def query_goods_info_by_id(goods_id):
- '''根据 id 查询商品信息'''
- # 1. 连接数据库
- conn = connect(host='localhost', port=3306, user='root', password='mysql', database='jing_dong', charset='utf8')
- cs = conn.cursor()
- # 2. 执行 sql 语句
- sql = '''select * from goods WHERE id = %s;''' % goods_id
- print('所执行的 sql 语句是:', sql)
- cs.execute(sql)
- # 获取数据
- data = cs.fetchone()
- # 3. 关闭
- cs.close()
- conn.close()
- print(data)
- def query_goods_info_by_id_save(goods_id):
- '''根据 id 查询商品信息'''
- # 1. 连接数据库
- conn = connect(host='localhost', port=3306, user='root', password='mysql', database='jing_dong', charset='utf8')
- cs = conn.cursor()
- # 2. 执行 sql 语句
- sql = '''select * from goods WHERE id = %s;'''
- print('所执行的 sql 语句是:', sql)
- cs.execute(sql, (goods_id,))
- # 获取数据
- data = cs.fetchone()
- # 3. 关闭
- cs.close()
- conn.close()
- print(data)
- def main():
- '''京东数据库案例'''
- while True:
- jingdong_info()
- # 用户输入操作的指令
- action = input()
- # 根据不同的指令来做不同的操作
- if action == '1':
- # 查询所有商品信息
- query_all_info()
- elif action == '2':
- # 查询所有商品在种类信息
- query_all_cate_info()
- elif action == '3':
- # 查询所有商品在品牌信息
- query_all_brand_info()
- elif action == '4':
- # 添加商品种类
- print('请输入种类名称:')
- class_name = input()
- add_goods_cates_name(class_name)
- elif action == '5':
- # 根据 id 查询商品信息
- print('请输入商品 id:')
- goods_id = input()
- query_goods_info_by_id(goods_id)
- elif action == '6':
- # 根据 id 查询商品信息安全方式
- print('请输入商品 id:')
- goods_id = input()
- query_goods_info_by_id_save(goods_id)
- elif action == '0':
- exit()
- else:
- print('亲, 您的输入有误!')
- if __name__ == '__main__':
- main()
来源: http://www.bubuko.com/infodetail-2735705.html