详解Flask数据库的连接与使用

Editor

目录

数据库连接配置

创建实体类

配置打印SQL语句

或、与、非和排序
数据库连接配置
HOST = "XXXXXXXXXXXXX"
PORT = 3310
USERNAME = "root"
PASSWORD = "@XXXXXXXXXXX"
DATABASE = "mydb"

SQLALCHEMY_DATABASE_URI = f"mysql+pymysql://{USERNAME}:{quote(PASSWORD)}@{HOST}:{PORT}/{DATABASE}?charset=utf8mb4"
SQLALCHEMY_TRACK_MODIFICATIONS = False
SQLALCHEMY_ECHO = True

创建实体类
from exts.DBServer import db
from sqlalchemy import Column, Integer, String, Date, DateTime


class Article(db.Model):
    __tablename__ = "article"
    id = Column(Integer, primay_key=True, autoincrement=True)
    title = Column(String(100), nullable=True)
    pub_time = Column(DateTime, nullable=True)
    author = Column(String(100), nullable=True)
    content = Column(String(10000), nullable=True)
    origin = Column(String(1000), nullable=True)
controller:
import json

from flask.blueprints import Blueprint
from exts.DBServer import db
from ..model.Article import Article
from flask_sqlalchemy.query import Query
from flask_restful import marshal
from flask_restful import fields

article_bp = Blueprint("article", __name__, url_prefix="/article")

article_fields = {
    "id": fields.Integer,
    "title": fields.String,
    "pub_time": fields.DateTime,
    "author": fields.String,
    "content": fields.String,
    "origin": fields.String
}


@article_bp.route("/queryAll")
def queryAll():
    query: Query = Article.query
    articles = query.all()
    article = query.get(1)
    article2 = query.filter_by(author="XXX")
    return json.dumps(marshal(articles, fields=article_fields),ensure_ascii=False)

配置打印SQL语句
from exts.DBServer import db
from sqlalchemy import Column, Integer, String


class User(db.Model):
    __tablename__ = "user"
    id = Column(Integer, primary_key=True, autoincrement=True)
    username = Column(String(100), nullable=True)
    password = Column(String(100), nullable=True)

    def __repr__(self):
        return "User %r" % self.body

或、与、非和排序
@user_bp.route("/query")
def query_match():
    query: Query = User.query
    result = query.filter(or_(User.username.contains("祥"), User.id == 1))

    return json.dumps(marshal(result.all(), fields=user_fields), ensure_ascii=False)


@user_bp.route("/in")
def in_sql():
    query: Query = User.query
    result = query.order_by(-User.password, -User.id)
    return json.dumps(marshal(result.all(), fields=user_fields), ensure_ascii=False)
到此这篇关于详解Flask数据库的连接与使用的文章就介绍到这了,更多相关Flask数据库内容请搜索知鸟论坛以前的文章或继续浏览下面的相关文章希望大家以后多多支持知鸟论坛！

啤酒瓶空了缓

楼主发贴辛苦了，谢谢楼主分享！我觉得知鸟论坛是注册对了！

幸福341

其实我一直觉得楼主的品味不错！呵呵！知鸟论坛太棒了！

我的苦恼冉

论坛不能没有像楼主这样的人才啊！我会一直支持知鸟论坛。

老橡树1

楼主发贴辛苦了，谢谢楼主分享！我觉得知鸟论坛是注册对了！

永远就三年疗

这东西我收了！谢谢楼主！知鸟论坛真好！

伊索谗言

其实我一直觉得楼主的品味不错！呵呵！知鸟论坛太棒了！

知足常乐77

既然你诚信诚意的推荐了，那我就勉为其难的看看吧！知鸟论坛不走平凡路。

贺老师

楼主发贴辛苦了，谢谢楼主分享！我觉得知鸟论坛是注册对了！

戏做顿

楼主，我太崇拜你了！我想我是一天也不能离开知鸟论坛。