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