1 SQLALchemy,他连接数据库比较方便,就建立创建基类和对应的ORM,
连接数据库,创建引擎,创建会话,创建实例,创建实例,就可以对数据库对应的数据表进行对应的操作
2 Flask-SQLAlchemy ,这话比较麻烦一点,必须要在上下文推动才能连接到数据,也就是路由请求。但是它可以一次性绑定两个数据库。
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column,Integer,String
#---------第一部分:定义表-----------*
# 实例,创建基类
Base=declarative_base()
# 所有的表必须继承于Base
class Student(Base):
__tablename__='student' # 定义该表在mysql数据库中的实际名称
# 定义表的内容,个人信息表,ORM映射到数据表的对应字段
id=Column(Integer,primary_key=True) # 数据库设置为自增id
name=Column(String(5),nullable=False)
age=Column(Integer,nullable=False)
addr=Column(String(32),nullable=False)
#---------第二部分:与数据库连接--------
# 数据库连接配置,
MYSQL_CONFIG_BASE = {
# 连接数据库主机的ip
'host': '127.0.0.1',
# 端口号默认就是3306
'port': 3306,
# 数据库账户
'user': 'root',
# 秘密
'password': '123456',
# 创建数据库的编码
'charset': 'utf8mb4',
# 数据库
'database': 'db'
}
# 拼接连接,用的是pymysql驱动,你也可以添加数据库的编码charset
SQLALCHEMY_DATABASE_URI = 'mysql+pymysql://{user}:{password}@{host}:{port}/{database}'
SQLALCHEMY_BINDS = SQLALCHEMY_DATABASE_URI.format(**MYSQL_CONFIG_BASE)
# 建立引擎,现在已经是连接到数据,接下来还要创建会话
engine_data = create_engine(SQLALCHEMY_BINDS)
# 创建会话
Sesssion = sessionmaker(bind=engine_data)
session = Sesssion_data()
#----------第三部分:进行数据操作--------
# 只能加一条数据
session.add(Student(name="xiamei",age=12,addr='天津'))
# 使用add_all可以一次传入多条数据,以列表的形式。
session.add_all([Student(name="tom",age=22,addr='北京'),Student(name="tony",age=23,addr='北京')])
# 提交数据,只有增加、删除、修改才需要提交数据,查询不需要。要是没提交就只是缓存而已,没结束会话前可以查询缓存,话结束后,就查询不到了,数据库也没保存有
session.commit()
# 结束会话,记得关闭不然会导致内存泄漏,出现会很多奇奇怪怪难以排查的问题。
session.close()
from flask import Flask
from config import FLASK_CONFIGS
from app.extensions import db, cors
from flask_sqlalchemy import SQLAlchemy
from flask_cors import CORS
db = SQLAlchemy()
cors = CORS()
class ProdConfig(Config):
ENV = 'production'
DEBUG = False
MYSQL_CONFIG = MYSQL_CONFIG_BASE
MYSQL_CONFIG['host'] = '192.168.1.147'
SQLALCHEMY_BINDS = {
'device_param': SQLALCHEMY_URI_FORMAT.format(**MYSQL_CONFIG, database='device_param'),
'device_data': SQLALCHEMY_URI_FORMAT.format(**MYSQL_CONFIG, database='device_data')
}
app = Flask(__name__)
app.config.from_object(ProdConfig)
# 注册扩展
db.init_app(app)
cors.init_app(app)
# 注册蓝图就不写了
@app.route('/')
def app_route():
return "Ok"
return app