1. 程式人生 > >flask_sqlalchemy和sqlalchemy聯絡區別及其使用方式

flask_sqlalchemy和sqlalchemy聯絡區別及其使用方式

### 使用SQLAlchemy去連線資料庫:

1.使用SQLALchemy去連線資料庫,需要使用一些配置資訊,然後將他們組合成滿足條件的字串:
HOSTNAME = '127.0.0.1'
PORT = '3306'
DATABASE = '1'
USERNAME = 'root'
PASSWORD = 'root'

DB_URI = "mysql+mysqlconnector://{username}:{password}@{host}:{port}/{db}?charset=utf8".format(username=USERNAME,password=PASSWORD,host=HOSTNAME,port=PORT,db=DATABASE)

2.然後使用`create_engine`建立一個引擎`engine`,
engine = create_engine(DB_URI)

3.構建session物件:所有和資料庫的ORM操作都必須通過一個叫做`session`的會話物件來實現,通過以下程式碼來獲取會話物件:
from sqlalchemy.orm import sessionmaker

engine = create_engine(DB_URI)
session = sessionmaker(engine)()


4.將ORM模型對映到資料庫中:
(1)用`declarative_base`根據`engine`建立一個ORM基類。
from sqlalchemy.ext.declarative import declarative_base

engine = create_engine(DB_URI)
Base = declarative_base(engine)
(2)用這個`Base`類作為基類來寫自己的ORM類。要定義`__tablename__`類屬性,來指定這個模型對映到資料庫中的表名。
class Person(Base):
    __tablename__ = 'person'
(3)在這個ORM模型中建立一些屬性,來跟表中的欄位進行一一對映。這些屬性必須是sqlalchemy給我們提供好的資料型別。
from sqlalchemy import create_engine,Column,Integer,String

id = Column(Integer,primary_key=True,autoincrement=True)
(4)使用`Base.metadata.create_all()`來將模型對映到資料庫中。
(5) 一旦使用`Base.metadata.create_all()`將模型對映到資料庫中後,即使改變了模型的欄位,也不會重新映射了。目前來說,只能刪除這個表重新建了

# Base.metadata.drop_all() # 刪除這個表以及裡面的資料
# Base.metadata.create_all() # 新建表以及表結構

### 完整示例程式碼
from sqlalchemy import create_engine,Column,Integer,String
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

HOSTNAME = '127.0.0.1'
PORT = '3306'
DATABASE = '1'
USERNAME = 'root'
PASSWORD = 'root'

# dialect+driver://username:

[email protected]:port/database
DB_URI = "mysql+pymysql://{username}:{password}@{host}:{port}/{db}?charset=utf8".format(username=USERNAME,password=PASSWORD,host=HOSTNAME,port=PORT,db=DATABASE)

engine = create_engine(DB_URI)
Base = declarative_base(engine)
session = sessionmaker(engine)()

class Person(Base):
    __tablename__ = 'person'
    id = Column(Integer,primary_key=True,autoincrement=True)
    name = Column(String(50))
    age = Column(Integer)
    country = Column(String(50))

# Base.metadata.drop_all()
# Base.metadata.create_all()

# 新增多條資料
p1 = Person(name='zhiliao1',age=19,country='china')
p2 = Person(name='zhiliao2',age=20,country='china')
session.add_all([p1,p2])
session.commit()

# 查詢資料
person = session.query(Person).first()
print(person)


### 使用Flask-SQLAlchemy去連線資料庫:
1.資料庫連線:
(1)跟sqlalchemy一樣,定義好資料庫連線字串DB_URI。
(2)將這個定義好的資料庫連線字串DB_URI,通過`SQLALCHEMY_DATABASE_URI`這個鍵放到`app.config`中。
示例程式碼:app.config["SQLALCHEMY_DATABASE_URI"] = DB_URI
(3)使用`flask_sqlalchemy.SQLAlchemy`這個類定義一個物件,並將`app`傳入進去。
示例程式碼:
from flask_sqlalchemy import SQLAlchemy
db = SQLAlchemy(app)

2.建立ORM模型:
還是跟使用sqlalchemy一樣,定義模型。現在不再是需要使用`delarative_base`來建立一個基類。而是使用`db.Model`來作為基類。

3.使用session:
以後session也不需要使用`sessionmaker`來建立了。直接使用`db.session`就可以了。操作這個session的時候就跟之前的`sqlalchemy`的`session`是一模一樣的。

4.在模型類中,`Column`、`String`、`Integer`以及`relationship`等,都不需要匯入了,直接使用`db`下面相應的屬性名就可以了。
id = db.Column(db.Integer,primary_key=True,autoincrement=True)

# 將ORM模型對映到資料庫:
1. db.drop_all()
2. db.create_all()

### 完整示例程式碼
from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)

HOSTNAME = '127.0.0.1'
PORT = '3306'
DATABASE = '1'
USERNAME = 'root'
PASSWORD = 'root'

DB_URI = "mysql+pymysql://{username}:{password}@{host}:{port}/{db}?charset=utf8mb4".format(username=USERNAME,password=PASSWORD,host=HOSTNAME,port=PORT,db=DATABASE)

app.config['SQLALCHEMY_DATABASE_URI'] = DB_URI
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False

db = SQLAlchemy(app)

class UserModel(db.Model):
    __tablename__ = 'user_model'
    id = db.Column(db.Integer,primary_key=True,autoincrement=True)
    username = db.Column(db.String(50),nullable=False)

    def __repr__(self):
        return "<User(username: %s)>" % self.username

# db.drop_all()
# db.create_all()

class Article(db.Model):
    __tablename__ = 'article'
    id = db.Column(db.Integer,primary_key=True,autoincrement=True)
    title = db.Column(db.String(50),nullable=False)

# 新增資料
article = Article(title='title one')
db.session.add(article)
db.session.commit()

# 查詢資料
article = Article.query.first()
print(article)