盤點Flask與數(shù)據(jù)庫的交互插件--Flask-Sqlalchemy

pip install flask-sqlalchemy
from flask_sqlalchemy import SQLAlchemyimport osimport pymysql as pfrom flask import Flask

db_type='mysql'db_conn='pymysql'host='127.0.0.1'username='root'password='123456'port='3306'db_name='people'SQLALCHEMY_DATABASE_URI='{}+{}://{}:{}@{}:{}/{}?charset=utf8'.format(db_type,db_conn,username,password,host,port,db_name)SQLALCHEMY_COMMIT_ON_TEARDOWN=FalseSQLALCHEMY_TRACK_MODIFICATIONS=True

from flask_sqlalchemy import SQLAlchemyfrom flask import Flaskimport configapp=Flask(__name__)app.config.from_object(config) # 連接數(shù)據(jù)庫配置文件db=SQLAlchemy(app)db.create_all()  # 創(chuàng)建所有的數(shù)據(jù)庫

app=Flask(__name__)p.install_as_MySQLdb()   # mysql連接器，因為不支持py3版本，所以必須加上這行app.config['SECRET_KEY']=os.urandom(50)app.config['SQLALCHEMY_DATABASE_URI']='mysql+pymysql://root:[email protected]:3306/people'app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN']=True   # 每次請求結(jié)束后都會自動提交數(shù)據(jù)庫中的變動app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True  # 動態(tài)追蹤修改設置，如未設置只會提示警告db = SQLAlchemy(app)

SQLALCHEMY_NATIVE_UNICODE    # 可以用于顯式禁用原生 unicode 支持SQLALCHEMY_POOL_SIZE         # 數(shù)據(jù)庫連接池的大小，默認是引擎默認值（5） SQLALCHEMY_POOL_TIMEOUT      # 設定連接池的連接超時時間，默認是 10SQLALCHEMY_POOL_RECYCLE      # 多少秒后自動回收連接，mysql默認為2小時SQLALCHEMY_RECORD_QUERIES    # 可以用于顯式地禁用或啟用查詢記錄SQLALCHEMY_ECHO              # 為Ture時用于調(diào)試，顯示錯誤信息SQLALCHEMY_BINDS             # 一個映射 binds 到連接 URI 的字典

from sqlalchemy import create_engine# echo參數(shù)為True時，會顯示每條執(zhí)行的SQL語句，為False時關(guān)閉engine = create_engine('mysql+pymysql://root:[email protected]:3306/people',echo=True)engine.connect()

app.config['SQLALCHEMY_BINDS']={'users': "mysql+pymysql://root:[email protected]:3306/user",    'admin': 'sqlite://C:/Users/Administrator/Desktop/admin',    'buy':   'postgresql://root:[email protected]/buy'}

db.create_all(bind=['users'])db.create_all(bind='admin')

__bind_key__ = 'users'bind key 內(nèi)部存儲在表的 info 字典中  即：info={'bind_key': 'users'}

from flask_sqlalchemy import SQLAlchemyfrom flask import Flaskimport configapp=Flask(__name__)app.config.from_object(config) # 添加配置文件db=SQLAlchemy(app)class User(db.Model):    __tablename__='users'    id=db.Column(db.Integer, primary_key=True,autoincrement=True) # 整數(shù)類型的自增主鍵    username=db.Column(db.String(100),nullable=False)  # 字符類型不為空    password=db.Column(db.String(100),nullable=False)  # 字符類型不為空
    def __init__(self,username,password):        self.username=username        self.password=password
    def __repr__(self):        # 打印當前類名和它的實例化后的值        return ' %s is %r' %(self.__class__.__name__,self.username)         # 請求鉤子,第一次請求之前執(zhí)行@app.before_first_requestdef create_table():     db.drop_all()  # 刪除所有表    db.create_all() # 創(chuàng)建新的表
    @app.route('/')def create():    use1= User('hwhrr', '123321')      use2= User('hwzjj', '123456')    use3= User('hwzzz', '654321')    db.session.add_all([use1,use2,use3]) # 添加所有的用戶,添加一個用戶去掉_all后面加一個元祖即可     db.session.commit()  # 提交數(shù)據(jù)    return use1.__repr__() # 返回用戶1的值
if __name__ == '__main__':      app.run(debug=True)

Column        參數(shù)列表  name          列名type_         類型*args         列表參數(shù)Constraint（約束）, ForeignKey（外鍵）, ColumnDefault（默認）, Sequenceobjects（序列）定義key         列名的別名primary_key 如果為True，則是主鍵nullable    如果是True，則可以為nulldefault     設置默認值，默認是Noneindex       是否是索引，默認是Trueunique      是否唯一鍵，默認是Falseonupdate    指定一個更新時候的值autoincrement 設置為整型自動增長quote         如果列明是關(guān)鍵字，則強制轉(zhuǎn)義，默認False

from flask import Flaskfrom sqlalchemy import create_enginefrom sqlalchemy.orm import sessionmakerfrom sqlalchemy.ext.declarative import declarative_basefrom sqlalchemy import Column, Integer, Stringapp=Flask(__name__)Base = declarative_base()# 創(chuàng)建連接數(shù)據(jù)庫的引擎并且打開回顯engine = create_engine("mysql+pymysql://root:123456@localhost/people",echo=True)Session = sessionmaker(bind=engine) # 創(chuàng)建會話標記class User(Base):    __tablename__ = 'article'    id = Column(Integer, primary_key=True,autoincrement=True)    username = Column(String(100),nullable=False)    password = Column(String(100),nullable=False)    def __init__(self, username,password):        self.username = username        self.password=password    def __repr__(self):        return ' %s is %r' %(self.__class__.__name__,self.username)    @app.before_first_requestdef create_table():    Base.metadata.drop_all(engine) # 刪除所有數(shù)據(jù)庫    Base.metadata.create_all(engine) # 創(chuàng)建所有數(shù)據(jù)庫    @app.route('/')def index():    user= User("hwhrr","123321")    session = Session()   # 創(chuàng)建會話    session.add(user)  # 添加內(nèi)容    session.commit()  # 提交    return user.__repr__()
if __name__ == '__main__':      app.run(debug=True)

class father(db.Model):    __tablename__='Father'    id=db.Column(db.Integer, primary_key=True,autoincrement=True)    name= db.Column(db.String(100),nullable=False)    age= db.Column(db.Integer,nullable=False)    #主要是要在一個表上設置uselist 然后設置back_populates的值為其它表的映射返回值    son_fa=db.relationship('son',uselist=False, back_populates='fa_son')     def __init__(self,name,age):        self.name=name        self.age=age    def __repr__(self):        return '%s is %r'%(self.__class__.__name__,self.name)

class son(db.Model):    __tablename__='Son'    id=db.Column(db.Integer, primary_key=True,autoincrement=True)    name= db.Column(db.String(100),nullable=False)    age= db.Column(db.Integer,nullable=False)    # 這里無需設置uselist    fa_son=db.relationship('father',back_populates='son_fa')    def __init__(self,name,age):        self.name=name        self.age=age    def __repr__(self):        return '%s is %r'%(self.__class__.__name__,self.name)

class father(db.Model):    __tablename__='Father'    id=db.Column(db.Integer, primary_key=True,autoincrement=True)    name= db.Column(db.String(100),nullable=False)    age= db.Column(db.Integer,nullable=False)    # 表示另一端是son這個模型，backref可替代Father.id訪問father模型    son_fa=db.relationship('son',backref='fa'，lazy='dynamic')    # lazy表示加載方式：    # dynamic：動態(tài)加載，只有用到了才加載 只可以用在一對多和多對多關(guān)系中    # subquery：全部加載    def __init__(self,name,age):        self.name=name        self.age=age    def __repr__(self):        return '%s is %r'%(self.__class__.__name__,self.name)

class son(db.Model):    __tablename__='Son'    id=db.Column(db.Integer, primary_key=True,autoincrement=True)    name= db.Column(db.String(100),nullable=False)    age= db.Column(db.Integer,nullable=False)    f_id=db.Column(db.Integer,db.ForeignKey('Father.id')) # 建立外鍵關(guān)聯(lián)，指明表名和字段    def __init__(self,name,age):        self.name=name        self.age=age            def __repr__(self):        return '%s is %r'%(self._class__.__name__,self.name)
@app.route('/')def create():    use1= father('hw', 45)    use2= son('hyy', 20)    db.session.add_all([use1,use2])    db.session.commit()    return use1.__repr__()+'\n'+use2.__repr__()

class father(db.Model):    __tablename__='Father'    id=db.Column(db.Integer, primary_key=True,autoincrement=True)    name= db.Column(db.String(100),nullable=False)    age= db.Column(db.Integer,nullable=False)    # 表示另一端是son這個模型    son_fa=db.relationship('son', back_populates="fath")     def __init__(self,name,age):        self.name=name        self.age=age    def __repr__(self):        return '%s is %r'%(self.__class__.__name__,self.name)

class son(db.Model):    __tablename__='Son'    id=db.Column(db.Integer, primary_key=True,autoincrement=True)    name= db.Column(db.String(100),nullable=False)    age= db.Column(db.Integer,nullable=False)    f_id=db.Column(db.Integer,db.ForeignKey('Father.id')) # 建立外鍵關(guān)聯(lián)    # 表示另一端是father這個模型    fa_son=db.relationship('father',back_populates="so")     def __init__(self,name,age):        self.name=name        self.age=age    def __repr__(self):        return '%s is %r'%(self.__class__.__name__,self.name)

# 設置關(guān)聯(lián)表gl=db.Table('glb',    db.Column('id',db.Integer,primary_key=True,autoincrement=True),    db.Column('son_id',db.Integer,db.ForeignKey('Son.id')),    db.Column('father_id',db.Integer,db.ForeignKey('Father.id')))
# 父表class father(db.Model):    __tablename__='Father'    id=db.Column(db.Integer, primary_key=True,autoincrement=True)    name= db.Column(db.String(100),nullable=False)    age= db.Column(db.Integer,nullable=False)    # 設置關(guān)聯(lián)表 動態(tài)加載    son_fa=db.relationship('son',secondary=gl,backref="fas",lazy="dynamic")    def __init__(self,name,age):        self.name=name        self.age=age    def __repr__(self):        return '%s is %r'%(self.__class__.__name__,self.name)
# 子表class son(db.Model):    __tablename__='Son'    id=db.Column(db.Integer, primary_key=True,autoincrement=True)    name= db.Column(db.String(100),nullable=False)    age= db.Column(db.Integer,nullable=False)    def __init__(self,name,age):        self.name=name        self.age=age    def __repr__(self):        return '%s is %r'%(self.__class__.__name__,self.name)

father.query.all()

father.query.filter_by(name='hw').all()  # 查找所有名字為hw的記錄

father.query.filter(father.name.startswith('h').all() # 查找所有名字首字母為h的記錄

father.query.get(1) # 查看id為1的記錄

from sqlalchemy import not_father.query.filter(not_(father.name=='hw')).all() # 查找所有除了名字不是hw的記錄

from sqlalchemy import and_# 查找名字末尾是h并且年齡等于50的記錄father.query.filter(and_(father.name.endswith('h'),father.age==50)).all()

from sqlalchemy import or_# 查找名字末尾是h或者年齡等于50的記錄father.query.filter(or_(father.name.endswith('h'),father.age==50)).all()

son.query.filter_by(f_id=2).all()

son.query.filter_by(fa=use1).all()

son.query.filter(son.age==10).first()son.query.filter(son.age==10)[0]

son.query.filter(son.age==10).limit(10).all() # 返回十個查找到的對象

son.query.filter(son.age==10).offset(2).all() # 返回偏移了2的對象

son.query.filter(son.age==10).order_by(son.create_time.desc()).all() # 返回按降序排序的記錄

son.query.filter(son.age==10).group_by(son.name).all() # 返回age為10的名字對象分組

son.query.filter(son.age==10).count() # son的年齡為10的數(shù)量

son.query(son).slice(10,40).all()   # son從10到40的記錄son.query(son)[10:40]

p=request.args.get('p')# 從請求的查詢字符串中獲取當前頁面，返回一個每頁顯示3條記錄的分頁對象paginate=son.query.paginate(p=int(p),per_page=3) paginate 屬性：pages     # 總共生成頁面數(shù)量page      # 當前頁數(shù)has_next  # 判斷是否有下一頁has_prev  # 判斷是否有上一頁next_num  # 獲取下一頁的頁碼數(shù)prev_num  # 獲取上一頁的頁碼數(shù)items     # 獲取當前頁的記錄total     # 查詢返回的記錄總數(shù)

son.query(son).one()

ss=son.query.get(1)ss.name='fasd'     # 更改name的值來達到更新的目的db.session.commit()

ss=son.query.get(1)db.session.delete(ss)db.session.commit()