本站消息

站长简介/公众号


站长简介:高级工程师,爱好交友,无偿辅导python和前端,技术交流,面试指导,找工作指导,瞎聊都可加我微信i88811i哈,欢迎欢迎!也欢迎加入程序员交流群,专属程序员的圈子,加我微信拉你进群.欢迎关注我的微信公众号:程序员总部,程序员的家,探索程序员的人生之路!分享IT最新技术,关注行业最新动向,让你永不落伍。了解同行们的工资,生活工作中的酸甜苦辣,谋求程序员的最终出路!

  价值13000svip视频教程,python大神匠心打造,零基础python开发工程师视频教程全套,基础+进阶+项目实战,包含课件和源码

  出租广告位,需要合作请联系站长

+关注
已关注

分类  

暂无分类

标签  

暂无标签

日期归档  

2021-05(7)

2021-06(6)

Python高级培训考核任务

发布于2022-01-17 08:10     阅读(581)     评论(0)     点赞(14)     收藏(3)



学生管理系统中数据每秒自动储存到数据库中

main.py文件

# 1. 导入管理系统模块
import threading
import time

from managerSystem import *
# 2. 启动管理系统
# 保证是当前文件运行才启动管理系统:if --创建对象并调用run方法
if __name__ == '__main__':
    # 实例化对象
    student_manager = StudentManager()
    # 2.创建线程每秒保存学生数据
    t = threading.Thread(target=student_manager.save_student)
    # ****重点:设置守护线程,当主线程结束后,停止每秒保存数据
    t.setDaemon = True
    t.start()
    # 主程序的运行
    student_manager.run()

student.py文件

# 定义学生类
class Student(object):
    def __init__(self, name, gender, tel):
        # 姓名、性别、手机号
        self.name = name
        self.gender = gender
        self.tel = tel
    
    # 返回字符串数据
    def __str__(self):
        return f'{self.name}, {self.gender}, {self.tel}'

主程序文件

# 模块导入包
import threading
import time
from student import *
import pymysql

# 定义学生管理类
class StudentManager(object):
    def __init__(self):
        # 存储学员数据 -- 列表
        self.student_list = []
        # 数据库
        # 1.连接数据库
        DBHOST = 'localhost'
        DBUSER = 'root'
        DBPASS = '123456'
        DBNAME = 'bearpi'

        try:
            self.db = pymysql.connect(host=DBHOST, user=DBUSER, password=DBPASS, database=DBNAME)
            print("数据库连接成功!")
        except pymysql.Error as e:
            print("数据库连接失败" + str(e))

        # # 2.创建一张新表
        #
        # # 声明一个游标
        # cur = self.db.cursor()
        # # 创建表前先检查表是否存在,如果存在则删除
        # cur.execute('DROP TABLE IF EXISTS Student_information')
        # # 编辑sql语句
        # sqlQuery = "CREATE TABLE Student_information(Name CHAR(20) NOT NULL,Gender CHAR(20),Tel bigint)"
        # cur.execute(sqlQuery)


    # 一. 程序入口函数
    def run(self):
        # 1. 从数据库中加载学员数据
        self.load_student()


        while True:
            # 2. 显示功能菜单
            self.show_menu()
            # 3. 用户输入目标功能序号
            menu_num = int(input('请输入您需要的功能序号:'))

            # 4. 根据用户输入的序号执行不同的功能 -- 如果用户输入1,执行添加
            if menu_num == 1:
                # 添加学员
                self.add_student()
            elif menu_num == 2:
                # 删除学员
                self.del_student()
            elif menu_num == 3:
                # 修改学员信息
                self.modify_student()
            elif menu_num == 4:
                # 查询学员信息
                self.search_student()
            elif menu_num == 5:
                # 显示所有学员信息
                self.show_student()
            elif menu_num == 6:
                # 保存学员信息
                self.save_student()
            elif menu_num == 7:
                # 退出系统 -- 退出循环
                break
        # 关闭数据库
        self.db.close()

    # 二. 系统功能函数
    # 2.1 显示功能菜单 -- 打印序号的功能对应关系 -- 静态
    @staticmethod
    def show_menu():
        print('请选择如下功能:')
        print('1:添加学员')
        print('2:删除学员')
        print('3:修改学员信息')
        print('4:查询学员信息')
        print('5:显示所有学员信息')
        print('6:保存学员信息')
        print('7:退出系统')

    # 2.2 添加学员
    def add_student(self):
        # 1. 用户输入姓名、性别、手机号
        name = input('请输入您的姓名:')
        gender = input('请输入您的性别:')
        tel = input('请输入您的手机号:')

        # 2. 创建学员对象 -- 类 ?类在student文件里面  先导入student模块,再创建对象
        student = Student(name, gender, tel)

        # 3. 将该对象添加到学员列表
        self.student_list.append(student)

        print(self.student_list)
        print(student)

    # 2.3 删除学员
    def del_student(self):
        # 1. 用户输入目标学员姓名
        del_name = input('请输入要删除的学员姓名:')

        # 2. 遍历学员列表,如果用户输入的学员存在则删除学员对象,否则提示学员不存在
        for i in self.student_list:
            if del_name == i.name:
                # 删除该学员对象
                self.student_list.remove(i)
                break
        else:
            # 循环正常价结束执行的代码:循环结束都没有删除任何一个对象,所以说明用户输入的目标学员不存在
            print('查无此人!')

        print(self.student_list)

    # 2.4 修改学员信息
    def modify_student(self):
        # 1. 用户输入目标学员姓名
        modify_name = input('请输入要修改的学员姓名:')

        # 2. 遍历列表数据,如果学员存在修改姓名性别手机号,否则提示学员不存在
        for i in self.student_list:
            if modify_name == i.name:
                i.name = input('姓名:')
                i.gender = input('性别:')
                i.tel = input('手机号:')
                print(f'修改学员信息成功,姓名{i.name}, 性别{i.gender}, 手机号{i.tel}')
                break
        else:
            print('查无此人!')

    # 2.5 查询学员信息
    def search_student(self):
        # 1. 用户输入目标学员姓名
        search_name = input('请输入您要搜索的学员姓名:')

        # 2. 遍历列表。如果学员存在打印学员信息,否则提示学员不存在
        for i in self.student_list:
            if search_name == i.name:
                print(f'姓名是:{i.name}, 性别是:{i.gender}, 手机号是:{i.tel}')
                break
        else:
            print('查无此人!')

    # 2.6 显示所有学员信息
    def show_student(self):
        # 1. 打印表头
        print('姓名\t性别\t手机号')

        # 2. 打印学员数据
        for i in self.student_list:
            print(f'{i.name}\t{i.gender}\t{i.tel}')

    # 2.7 保存学员信息
    def save_student(self):
        while True:
            # 向学生信息表中插入数据
            sqlQuery = " INSERT  INTO Student_information (Name, Gender, Tel) VALUE (%s,%s,%s) "  # 编辑sql语句

            # try和except来捕获异常
            try:
                cur = self.db.cursor()
                for i in self.student_list:
                    value = (i.name, i.gender, i.tel)
                    cur.execute(sqlQuery, value)
                    self.db.commit()  # 数据提交
                # print('数据成功存入数据库')
            except pymysql.Error as e:
                print('数据存入数据库失败:' + str(e))
                self.db.rollback()  # 数据回滚
            time.sleep(1)


    def load_student(self):
        # 查询表中数据
        sqlQuery = "SELECT * FROM Student_information"
        try:
            cur = self.db.cursor()
            cur.execute(sqlQuery)
            results = cur.fetchall()         # 使用fetchall()方法接收全部的返回结果
            self.student_list = []         # 学生信息列表,用来接受从数据库返回的结果
            for row in results:
                name = row[0]
                gender = row[1]
                tel = row[2]
                student = Student(name, gender, tel)
                self.student_list.append(student)   # 以类的方式添加到列表中
            print('学生信息加载成功')
        except pymysql.Error as e:
            print("数据查询失败:" + str(e))

重点和难点
1.数据能储存至数据库中并查询返回结果
2.使用守护线程来实现主程序结束,自动保存功能也结束。

原文链接:https://blog.csdn.net/weixin_50017445/article/details/122526688

站长简介:高级工程师,爱好交友,无偿辅导python和前端,技术交流,面试指导,找工作指导,瞎聊都可加我微信i88811i哈,欢迎欢迎!也欢迎加入程序员交流群,专属程序员的圈子,加我微信拉你进群
欢迎关注我的公众号:程序员总部,关注公众号回复python,免费领取 全套python视频教程,关注公众号回复充值+你的账号,免费为您充值1000积分







所属网站分类: 技术文章 > 博客

作者:你太美丽

链接:https://www.pythonheidong.com/blog/article/1252889/f4c304270e1d891d960e/

来源:python黑洞网

任何形式的转载都请注明出处,如有侵权 一经发现 必将追究其法律责任

14 0
收藏该文
已收藏

评论内容:(最多支持255个字符)