[[418400]]

大家好，我是Python進(jìn)階者。

前言

在我們做web開(kāi)發(fā)的時(shí)候，經(jīng)常需要用到與數(shù)據(jù)庫(kù)交互，因?yàn)槲覀兊臄?shù)據(jù)通常都是保存在數(shù)據(jù)庫(kù)中的，如果有人需要訪(fǎng)問(wèn)，就必須與數(shù)據(jù)庫(kù)訪(fǎng)問(wèn)，所以今天我們介紹一個(gè)Flask中與數(shù)據(jù)庫(kù)交互的插件---Flask-Sqlalchemy。

一、安裝并導(dǎo)入

pip install flask-sqlalchemy 
 
from flask_sqlalchemy import SQLAlchemy 
import os 
import pymysql as p 
from flask import Flask 

二、基本用法

今天我們要了解的是Mysql數(shù)據(jù)庫(kù)，所以這里重點(diǎn)介紹連接Mysql數(shù)據(jù)庫(kù)的方法。

1.連接數(shù)據(jù)庫(kù)

1).寫(xiě)在配置文件中然后讀取

首先創(chuàng)建一個(gè)配置文件"config.py"，內(nèi)容為：

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=False 
SQLALCHEMY_TRACK_MODIFICATIONS=True 

然后在應(yīng)用中導(dǎo)入配置文件：

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

2).直接寫(xiě)在應(yīng)用中讀取

app=Flask(__name__) 
p.install_as_MySQLdb()   # mysql連接器，因?yàn)椴恢С謕y3版本，所以必須加上這行 
app.config['SECRET_KEY']=os.urandom(50) 
app.config['SQLALCHEMY_DATABASE_URI']='mysql+pymysql://root:123456@127.0.0.1:3306/people' 
app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN']=True   # 每次請(qǐng)求結(jié)束后都會(huì)自動(dòng)提交數(shù)據(jù)庫(kù)中的變動(dòng) 
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True  # 動(dòng)態(tài)追蹤修改設(shè)置，如未設(shè)置只會(huì)提示警告 
db = SQLAlchemy(app) 

還有許多其它的配置參數(shù)，比如：

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

3).使用獨(dú)特的創(chuàng)建引擎

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

這樣我們就算與People數(shù)據(jù)庫(kù)建立連接了，接下來(lái)我們來(lái)建立一張表。

4).創(chuàng)建連接多個(gè)數(shù)據(jù)庫(kù)

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

然后引用表：

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

指定Users數(shù)據(jù)庫(kù)中的表：

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

2.建立數(shù)據(jù)表并插入值

1).繼承"db.Model"類(lèi)

from flask_sqlalchemy import SQLAlchemy 
from flask import Flask 
import config 
app=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ù)類(lèi)型的自增主鍵 
    username=db.Column(db.String(100),nullable=False)  # 字符類(lèi)型不為空 
    password=db.Column(db.String(100),nullable=False)  # 字符類(lèi)型不為空 
 
    def __init__(self,username,password): 
        self.username=username 
        self.password=password 
 
    def __repr__(self): 
        # 打印當(dāng)前類(lèi)名和它的實(shí)例化后的值 
        return ' %s is %r' %(self.__class__.__name__,self.username)  
     
     
# 請(qǐng)求鉤子,第一次請(qǐng)求之前執(zhí)行 
@app.before_first_request 
def 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]) # 添加所有的用戶(hù),添加一個(gè)用戶(hù)去掉_all后面加一個(gè)元祖即可  
    db.session.commit()  # 提交數(shù)據(jù) 
    return use1.__repr__() # 返回用戶(hù)1的值 
 
if __name__ == '__main__':   
    app.run(debug=True) 

Column        參數(shù)列表   
name          列名 
type_         類(lèi)型 
*args         列表參數(shù) 
Constraint（約束）, ForeignKey（外鍵）, ColumnDefault（默認(rèn)）, Sequenceobjects（序列）定義 
key         列名的別名 
primary_key 如果為True，則是主鍵 
nullable    如果是True，則可以為null 
default     設(shè)置默認(rèn)值，默認(rèn)是None 
index       是否是索引，默認(rèn)是True 
unique      是否唯一鍵，默認(rèn)是False 
onupdate    指定一個(gè)更新時(shí)候的值 
autoincrement 設(shè)置為整型自動(dòng)增長(zhǎng) 
quote         如果列明是關(guān)鍵字，則強(qiáng)制轉(zhuǎn)義，默認(rèn)False 

2).利用原始引擎來(lái)創(chuàng)建會(huì)話(huà)(稍微復(fù)雜點(diǎn))

from flask import Flask 
from sqlalchemy import create_engine 
from sqlalchemy.orm import sessionmaker 
from sqlalchemy.ext.declarative import declarative_base 
from sqlalchemy import Column, Integer, String 
app=Flask(__name__) 
Base = declarative_base() 
# 創(chuàng)建連接數(shù)據(jù)庫(kù)的引擎并且打開(kāi)回顯 
engine = create_engine("mysql+pymysql://root:123456@localhost/people",echo=True) 
Session = sessionmaker(bind=engine) # 創(chuàng)建會(huì)話(huà)標(biāo)記 
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_request 
def create_table(): 
    Base.metadata.drop_all(engine) # 刪除所有數(shù)據(jù)庫(kù) 
    Base.metadata.create_all(engine) # 創(chuàng)建所有數(shù)據(jù)庫(kù) 
     
@app.route('/') 
def index(): 
    user= User("hwhrr","123321") 
    session = Session()   # 創(chuàng)建會(huì)話(huà) 
    session.add(user)  # 添加內(nèi)容 
    session.commit()  # 提交 
    return user.__repr__() 
 
if __name__ == '__main__':   
    app.run(debug=True) 

3.數(shù)據(jù)庫(kù)之間的關(guān)系

1). 一對(duì)一

只需讓兩張表都在同等的位置上，屬于雙向關(guān)系。

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) 
    #主要是要在一個(gè)表上設(shè)置uselist 然后設(shè)置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) 
    # 這里無(wú)需設(shè)置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) 

2).一對(duì)多

我們需要建立一個(gè)主表和一個(gè)子表，分別命名為“father”和‘son’，然后需要建立外鍵和反射來(lái)互相引用建立一種關(guān)系，我們來(lái)看看：

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這個(gè)模型，backref可替代Father.id訪(fǎng)問(wèn)father模型 
    son_fa=db.relationship('son',backref='fa'，lazy='dynamic') 
    # lazy表示加載方式： 
    # dynamic：動(dòng)態(tài)加載，只有用到了才加載 只可以用在一對(duì)多和多對(duì)多關(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__() 

3).多對(duì)一

就是將反射應(yīng)用在子表上，與父表同時(shí)進(jìn)行關(guān)聯(lián)。

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這個(gè)模型 
    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這個(gè)模型 
    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) 

4).多對(duì)多

設(shè)置一個(gè)關(guān)聯(lián)表來(lái)對(duì)兩個(gè)表同時(shí)進(jìn)行管理。

# 設(shè)置關(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) 
    # 設(shè)置關(guān)聯(lián)表 動(dòng)態(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) 

可以看出我們已經(jīng)創(chuàng)建出了一張關(guān)聯(lián)表，名字就是我們?cè)O(shè)置的“glb”。

4.查看數(shù)據(jù)

1).查看全部數(shù)據(jù)(all)

father.query.all() 

2).精準(zhǔn)查詢(xún)(filter_by)

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

3).模糊查詢(xún)(filter)

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

4).主鍵查詢(xún)(get)

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

5).取反操作(not_)

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

6).與操作(and_)

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

7).或操作(or_)

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

8).一對(duì)多正向查詢(xún)

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

9).一對(duì)多反向查詢(xún)

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

10).查詢(xún)第一個(gè)出現(xiàn)的數(shù)據(jù)

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

11).查詢(xún)對(duì)象并返回指定數(shù)量的結(jié)果

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

12).查詢(xún)時(shí)指定偏移量

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

13).查找對(duì)象并排序

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

14).查找對(duì)象返回分組結(jié)果

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

15).返回查詢(xún)結(jié)果的數(shù)量

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

16).返回切片結(jié)果

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

17).分頁(yè)獲取數(shù)據(jù)

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

18).查詢(xún)僅顯示一條記錄

son.query(son).one() 

5.更新數(shù)據(jù)

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

6.刪除數(shù)據(jù)

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

三、總結(jié)

Sqlalchemy支持很多表的建立和操作，通過(guò)對(duì)它的了解，我們可以很方便的操作數(shù)據(jù)庫(kù)的數(shù)據(jù)從而與前端頁(yè)面交互達(dá)到可視化的效果，通過(guò)這篇文章的學(xué)習(xí)，相信你可以獨(dú)立開(kāi)發(fā)一個(gè)小網(wǎng)站了。

本文轉(zhuǎn)載自微信公眾號(hào)「Python爬蟲(chóng)與數(shù)據(jù)挖掘」，可以通過(guò)以下二維碼關(guān)注。轉(zhuǎn)載本文請(qǐng)聯(lián)系Python爬蟲(chóng)與數(shù)據(jù)挖掘公眾號(hào)。