整合Flask中的目录结构

1、SQLAlchemy-Utilspython

因为sqlalchemy中没有提供choice方法,因此借助SQLAlchemy-Utils组件提供的choice方法mysql

import datetime
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String, Text, ForeignKey, DateTime, UniqueConstraint, Index
from sqlalchemy.orm import relationship
from sqlalchemy_utils import ChoiceType

Base = declarative_base()
class Xuan(Base):
    __tablename__ = 'xuan'
    types_choices = (
        (1,'欧美'),
        (2,'日韩'),
        (3,'老男孩'),
    )
    id = Column(Integer,primary_key=True,autoincrement=True)
    name = Column(String(64))
    types = Column(ChoiceType(types_choices,Integer()))

    __table_args__ = {
        'mysql_engine':'Innodb',
        'mysql_charset':'utf8',
    }

engine = create_engine(
    "mysql+pymysql://root:123@127.0.0.1:3306/ttt2?charset=utf8",
    max_overflow=0,  # 超过链接池大小外最多建立的链接
    pool_size=5,  # 链接池大小
    pool_timeout=30,  # 池中没有线程最多等待的时间,不然报错
    pool_recycle=-1  # 多久以后对线程池中的线程进行一次链接的回收(重置)
)

Base.metadata.create_all(engine)


查询:

  result_list = session.query(Xuan).all()
  for item in result_list:
    print(item.types.code,item.types.value)sql

 

 2、scoped_session数据库

from sqlalchemy.orm import sessionmaker
from sqlalchemy import create_engine
from sqlalchemy.orm import scoped_session
engine = create_engine(
        "mysql+pymysql://root:123@47.93.4.198:3306/ttt?charset=utf8",
        max_overflow=0,  # 超过链接池大小外最多建立的链接
        pool_size=5,  # 链接池大小
        pool_timeout=30,  # 池中没有线程最多等待的时间,不然报错
        pool_recycle=-1  # 多久以后对线程池中的线程进行一次链接的回收(重置)
)
SessionFactory = sessionmaker(bind=engine)
# 方式一:因为没法提供线程共享功能,全部在开发时要注意,在每一个线程中本身建立 session。
#         from sqlalchemy.orm.session import Session
#         本身具备操做数据库的:'close', 'commit', 'connection', 'delete', 'execute', 'expire',.....
session = SessionFactory()

# print('原生session',session)
# 操做
session.close()


# 方式二:支持线程安全,为每一个线程建立一个session
#               - threading.Local
#               - 惟一标识
# ScopedSession对象
#       self.registry(), 加括号 建立session
#       self.registry(), 加括号 建立session
#       self.registry(), 加括号 建立session
from greenlet import getcurrent as get_ident
session = scoped_session(SessionFactory,get_ident)
# session.add
# 操做
session.remove()

3、Flask-SQLAlchemy和Flask-Migrate 组件flask

四、Flask-SQLAlchemy:吧Flask和SQLAlchemy结合在一块儿,粘合剂
    在__init__.py 文件中
        1 引入Flask-SQLAlchemy    中的SQLAlchemy,实例化了一个SQLAlchemy对象
        2 注册Flask-SQLAlchemy:
            - 有两种方式
                方式一: 在函数里面,SQLAlchemy(app)  #若是想在其余地方使用这种方式就很差使了
                方式二: 在全局:
                    db = SQLAlchemy(),
                    在函数里面 db.init_app(app)  #调用init_app方法吧app放进去了
        3、导入models的类
        4、导入的类中继承了db.model,其实本质上仍是继承了Base类
        五、manage.py 建立数据库表,能够经过命令来建立。借助Flask-Migrate组件来完成
五、Flask-Migrate:
    -旧5 被毙掉了:在manage.py里面导入db,之后执行db.create_all()建立表,之后执行drop_all()删除表
      这样很差,咱们能够和Flask-Migrate结合起来用
    -新5:Flask-Migrate
        - 安装组件:pip install Flask-Migrate
        - 5.1 导入    
            from flask_migrate import Migrate, MigrateCommand
            from app import db, app
        - 5.2 migrate = Migrate(app,db) #建立实例
        - 5.3 建立命令
            manager.add_command("db",MigrateCommand)
        - 5.4 执行命令
            python manage.py db init  #只执行第一次
            python manage.py db migrate
            python manage.py db upgrade
    在执行命令以前,得先链接数据库,他才会知道吧表放在那里,

详说注册SQLAlchemy的两种方式安全

方式一session

from flask_sqlalchemy import SQLAlchemy
from flask import FLask
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = \
    "mysql://root:12345@localhost/test"
db = SQLAlchemy(app)

 方式二:app

from flask_sqlalchemy import SQLAlchemy
from flask import FLask
db = SQLAlchemy()

def create_app():
    app = Flask(__name__)
    db.init_app(app)
    return app

4、操做数据库ide

经过上面注册了SQLAlchemy,就直接能够从db.session了函数

#方式一
        db.session  #会自动建立一个session
        db.session.add()
        db.session.query(models.User.id,models.User.name).all()
        db.session.commit()
        db.session.remove()
    #方式二
        导入models
        models.User.query

5、flask中全部用到过的组件

全部用过的组件
    Flask
    链接数据库的两种操做
        要么DBUtils:用于执行原生SQL的
            用本身的util里面的sqlhelper来完成
        要么SQLAlchemy:遵循他本身的语法来连接
            方式一:SQLAlchemy(app)这种方式有局限性,若是我在其余地方也得用到呢?能够吧它写到全局
            方式二:优势,
                实例化一下:db = SQLAlchemy()
                注册:
                    在settings里面配置一下数据库连接方式
                        SQLALCHEMY_DATABASE_URI = "mysql+pymysql://root:123@47.93.4.198:3306/s6?charset=utf8"
                        SQLALCHEMY_POOL_SIZE = 2
                        SQLALCHEMY_POOL_TIMEOUT = 30
                        SQLALCHEMY_POOL_RECYCLE = -1
                    Flask-SQLAlchemy: db.init_app(app)
            
    Flask-Session  #用于吧session保存在其余地方
    Flask-Script  #生成命令
    Flask-Migrate   #数据库迁移
    Flask-SQLAlchemy  #将Flask和SQLAlchemy很好的结合在一块儿
        #本质、:每次操做数据库就会自动建立一个session链接,完了自动关闭
    Blinker  #信号
    Wtforms  #FORM组件
    用到的组件和版本
        pip3 freeze  #获取环境中全部安装的模块
        pip3 freeze > a.txt
        pip3 freeze > requirements.txt
        #pip3 install pipreqs  #帮你找到当前程序的全部模块,而且自动生成 requirements.txt文件,写入内容
        pipreqs ./  #根目录
        
        之后别人给你一个程序,告知你一个文件夹须要安装的组件:requirements.txt
             进入程序目录:
                pip install -r requirements.txt #就会把设计到的全部的组件就会装上 
        
        结构:
            app
                static
                templates
                views
                __init__.py
                models.py
相关文章
相关标签/搜索