Flask 数据库基本使用

小咪咪 2022-11-26 08:47 120阅读 0赞

### Flask 数据库基本使用 ###

*  数据库建立
 *  分布式

# 数据库建立 #

import os
    from flask import Flask
    # 引入表格模块
    from flask_sqlalchemy import SQLAlchemy
    #导入pymysql
    import pymysql
    #用pymysql 代替 MySqldb
    pymysql.install_as_MySQLdb()
    
    app=Flask(__name__)
    
    # 获取文件路径
    BASE_DIR=os.path.abspath(os.path.dirname(__file__))
    
    # 配置数据库sqlite
    app.config['SQLALCHEMY_DATABASE_URI']='sqlite:///'+os.path.join(BASE_DIR,'sqlite3.db')
    #配置数据库mysql
    # app.config['SQLALCHEMY_DATABASE_URI']='mysql://root:root@127.0.0.1:3306/test'
    
    # 创建一个父类让python中的类去继承 就可映射成表格
    db=SQLAlchemy(app)
    
    # 创建表格
    """ 数据类型: Integer 整型 Float 浮点型 Date 时间类型年月日 DateTime 时间类型 年月日时分秒 Text 长文本 String 变长字符串 primary_key:主键 autoincrement:自增 nullable:是否为空 default:默认 unique:唯一 index :索引 """
    class Student(db.Model):
        id=db.Column(db.Integer,primary_key=True,autoincrement=True)
        name=db.Column(db.String(10))
    # 创建所有表格
    db.create_all()

# 分布式 #

在项目中创建  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ExMzA5NTI1ODAy_size_16_color_FFFFFF_t_70]

app.py

models.py

#存放类模块
    from app import db
    #抽象父类
    class Base(db.Model):
        __abstract__=True
        id = db.Column(db.INT, primary_key=True, autoincrement=True)
        #添加员工
        def save(self):
            # 保存对象
            db.session.add(self)
            # 提交事务
            db.session.commit()
        def updte(self):
            db.session.commit()
        def delete(self):
            # 删除对象
            db.session.delete(self)
            # 提交事务
            db.session.commit()
    
    # 职员
    class Person(Base):
        """雇员表"""
        __tablename__ = "person"
    
        username = db.Column(db.VARCHAR(100))
        password = db.Column(db.VARCHAR(64))
    
        nickname = db.Column(db.String(64), nullable=True)  # 昵称
        gender = db.Column(db.String(8), nullable=True)  # 性别
        age = db.Column(db.Integer, nullable=True)  # 年龄
        workid = db.Column(db.String(32), nullable=True)  # 工号
        phone = db.Column(db.String(64), nullable=True)  # 电话
        email = db.Column(db.String(64), nullable=True)  # 邮箱
        photo = db.Column(db.String(64), nullable=True)  # 照片
        address = db.Column(db.Text, nullable=True)  # 地址
        score = db.Column(db.Float, nullable=True)  # 绩效

main.py

#控制文件
    from app import app
    from models import db
    from views import *
    
    
    if __name__ == '__main__':
        db.create_all()
        app.run(debug=True)

views.py

from sqlalchemy import func, or_,and_,not_
    
    from  app import app
    from models import Person,db
    
    @app.route('/')
    def index():
        return "index"
    # 查询所有员工
    @app.route('/SelectAll')
    def SelectAll():
        # 得到Person表中所有数据(select * from person)
        res=Person.query.all() #得到的是一个列表对象
        for person in res:
            #得到person对象
            for key,value in person.__dict__.items():
                if value!=None:
                    print(f"{key}:{value}",end=" ")
            print()
        return "SelectAll"
    # 根据id来查找
    @app.route('/Select_By_Id/<int:id>')
    def Select_By_Id(id):
        Person_list=Person.query.filter(Person.id==id) #得到的是一个sql语句
        res=Person_list.all()
        print(res) #当id=1时 [<Person 1>] 当没有找到时 []
        return "Select_By_Id"
    #条件语句
    @app.route('/Filter')
    def Filter():
        # like 模糊查询
        ret=Person.query.filter(Person.username.like("z%")).all()
        # limit()限制返回条数
        # ret2=Person.query.limit(2).all()
        # 偏移1条记录,返回2条记录
        ret2=Person.query.limit(2).offset(1).all()
        # order_by() 排序 Person.id.desc() 降序 asc():升序
        ret3=Person.query.order_by(Person.id.desc()).all()
        # 分组 group_by query(Person.gender,func.count(Person.id))=>select gender,count(id) from person
        ret4=db.session.query(Person.gender,func.count(Person.id)).group_by(Person.gender).all()
        # 逻辑判断 and_,or_,not_
        ret5=Person.query.filter(or_(Person.gender=="男",Person.age>18)).all()
    
        print(ret) #[<Person 2>]
        print(ret2) #[<Person 2>, <Person 3>]
        print(ret3) #[<Person 4>, <Person 3>, <Person 2>, <Person 1>]
        print(ret4) #[('女', 1), ('男', 3)]
        print(ret5) #[<Person 1>, <Person 2>, <Person 3>, <Person 4>]
        return "Filter"
    # 添加员工
    @app.route('/add_person')
    def add_person():
        # 创建员工对象
        person = Person()
        person.name="zhangsan"
        person.age=18
        person.save()
        return 'add person'
    
    # 用户修改
    @app.route('/Person_Update')
    def Person_Update():
        person_obj=Person.query.get(1)
        person_obj.age=30
        # 提交事务
        db.session.commit()
        return "update"
    @app.route('/Person_Del')
    def Person_Del():
        person=Person.query.get(2)
        person.delete()
        return "Person_Del"

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ExMzA5NTI1ODAy_size_16_color_FFFFFF_t_70]: /images/20221124/08ccb6ac1fc54c64abde621f953e3292.png