python课程设计基于Django的购物商城系统源码+数据库（96分以上项目）.zip

'''涵盖项目需要使用到的数据访问类,开始CURD吧!''' import pymysql # 实体类导包 from .models import User from .models import Order from .models import Shopping_cart from .models import Good from .models import Comment from .models import Mini_Shopping_cart # 数据库访问静态工厂 class Mysql_Static_Factory: '''数据库静态工厂 提供如下方法: @staticmethod: get_connecttion() @return: connection连接对象,供CURD操作 ''' @staticmethod def get_connection(): try: connection = pymysql.connect(host="localhost", user='root', password='123456', db='sports_shop', charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor) return connection except Exception as e: print(e) # 用户表 class UserDaoImpl: '''用户表 数据访问 提供如下方法 @methoad: selectByNamePWD() 用于登录验证 @methoad: selectByID() 查询用户的所有数据 @methoad: inserUser() 添加用户 @methoad: selectWalletByUserId() 查询用户余额 @methoad: updateUserWallet() 更新用户余额 ''' # 用于登录验证 def selectByNamePWD (self,username:str, password:str) : '''查询是否有该用户 @param 用户名 @param 密码 @return user_id''' connection = Mysql_Static_Factory.get_connection() affected_num = 0 user_id = 0 try: with connection.cursor() as cursor: # 创建一条预编译的 SQL 语句 sql = "SELECT * FROM users WHERE username = %s AND password = %s" # 执行预编译的 SQL 语句并传入参数 affected_num = cursor.execute(sql, (username, password)) # print('affect_num={}'.format(affected_num)) if affected_num > 0: # 存在该用户密码，登录成功 result = cursor.fetchone() user_id = result['user_id'] # 提交事务 connection.commit() except Exception as e: print(e) finally: connection.close() return user_id # 查询用户的所有数据 def selectByID (self,user_id:int) : '''通过用户ID查询用户信息 @param 用户ID @return 用户实体类''' connection = Mysql_Static_Factory.get_connection() user = User try: with connection.cursor() as cursor: # 创建一条预编译的 SQL 语句 sql = "SELECT * FROM users WHERE user_id = %s" # 执行预编译的 SQL 语句并传入参数 affected_num = cursor.execute(sql, (user_id)) # print('affect_num={}'.format(affected_num)) if affected_num > 0: result = cursor.fetchone() user = User(result['user_id'], result['username'], result['password'], result['level'], result['grade'], result['type'], result['wallet'], result['user_picture'], result['state_message']) # 提交事务 connection.commit() except Exception as e: print(e) finally: connection.close() return user # 添加用户 def inserUser (self,user:User) : '''添加一个新用户 @param User实体类 @return 布尔值True代表成功''' connection = Mysql_Static_Factory.get_connection() affected_num = 0 try: with connection.cursor() as cursor: # 创建一条预编译的 SQL 语句 sql = "INSERT INTO users (username, password,user_picture,type,level,grade,wallet,state_message) VALUES (%s,%s,%s,%s,%s,%s,%s,%s)" # 执行预编译的 SQL 语句并传入参数 affected_num = cursor.execute(sql, (user.username, user.password, user.user_picture, user.type, user.level, user.grade, user.wallet, user.state_message)) # print('affect_num={}'.format(affected_num)) # 提交事务 connection.commit() except Exception as e: print(e) finally: connection.close() return (affected_num > 0) # 查询用户余额 def selectWalletByUserId (self,user_id:int) : '''查询用户余额 @param 用户ID @return 金额Wallet''' connection = Mysql_Static_Factory.get_connection() affected_num = 0 wallet = 0 try: with connection.cursor() as cursor: # 创建一条预编译的 SQL 语句 sql = "select wallet from users where user_id= %s" # 执行预编译的 SQL 语句并传入参数 affected_num = cursor.execute(sql, (user_id)) # print('affect_num={}'.format(affected_num)) if affected_num > 0: # 存在该用户密码，登录成功 result = cursor.fetchone() wallet = result['wallet'] # 提交事务 connection.commit() except Exception as e: print(e) finally: connection.close() return wallet # 更新用户余额 def updateUserWallet (self,user_id:int,wallet:int) : '''更新用户余额 @param 用户ID @param 金额wallet @return 布尔值True代表成功''' connection = Mysql_Static_Factory.get_connection() affected_num = 0 try: with connection.cursor() as cursor: # 创建一条预编译的 SQL 语句 sql = "update users set wallet = %s where user_id= %s" # 执行预编译的 SQL 语句并传入参数 affected_num = cursor.execute(sql, (wallet,user_id)) # print('affect_num={}'.format(affected_num)) # 提交事务 connection.commit() except Exception as e: print(e) finally: connection.close() return (affected_num > 0) # 评论表 class CommentDaoImpl: '''评论表 数据访问 提供如下方法 @methoad: addComment() 添加评论信息 @methoad: selectCommentByGoodId() 通过商品ID获取相关评论信息 @methoad: selectHasCommentByOrderId() 根据order_id 查看是否有评论信息 @methoad: updateSaysByOrderId() 根据根据order_id 修改 评论信息 ''' # 添加评论信息 def addComment (self,comment:Comment) : '''添加一条评论记录 @param 评论表实体类Comment @return 布尔值 True代表成功''' connection = Mysql_Static_Factory.get_connection() list_orders = [] try: with connection.cursor() as cursor: # 创建一条预编译的 SQL 语句 sql