python——mysql京东数据库设计案例（源码）

Posted 2020-12-31 brucelong

# 显示界面信息
# 循环界面信息
# 根据用户输入数据来做相应的选择
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()