盘点Flask与数据库的交互插件(Flask-Sqlalchemy)
yuyutoo 2024-10-12 00:48 4 浏览 0 评论
来源:Python爬虫与数据挖掘
作者:Python进阶者
大家好,我是Python进阶者。
前言
在我们做web开发的时候,经常需要用到与数据库交互,因为我们的数据通常都是保存在数据库中的,如果有人需要访问,就必须与数据库访问,所以今天我们介绍一个Flask中与数据库交互的插件---Flask-Sqlalchemy。
一、安装并导入
pip install flask-sqlalchemy
from flask_sqlalchemy import SQLAlchemy
import os
import pymysql as p
from flask import Flask
二、基本用法
今天我们要了解的是Mysql数据库,所以这里重点介绍连接Mysql数据库的方法。
1.连接数据库
1).写在配置文件中然后读取
首先创建一个配置文件"config.py",内容为:
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
然后在应用中导入配置文件:
from flask_sqlalchemy import SQLAlchemy
from flask import Flask
import config
app=Flask(__name__)
app.config.from_object(config) # 连接数据库配置文件
db=SQLAlchemy(app)
db.create_all() # 创建所有的数据库
2).直接写在应用中读取
app=Flask(__name__)
p.install_as_MySQLdb() # mysql连接器,因为不支持py3版本,所以必须加上这行
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 # 每次请求结束后都会自动提交数据库中的变动
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True # 动态追踪修改设置,如未设置只会提示警告
db = SQLAlchemy(app)
还有许多其它的配置参数,比如:
SQLALCHEMY_NATIVE_UNICODE # 可以用于显式禁用原生 unicode 支持
SQLALCHEMY_POOL_SIZE # 数据库连接池的大小,默认是引擎默认值(5)
SQLALCHEMY_POOL_TIMEOUT # 设定连接池的连接超时时间,默认是 10
SQLALCHEMY_POOL_RECYCLE # 多少秒后自动回收连接,mysql默认为2小时
SQLALCHEMY_RECORD_QUERIES # 可以用于显式地禁用或启用查询记录
SQLALCHEMY_ECHO # 为Ture时用于调试,显示错误信息
SQLALCHEMY_BINDS # 一个映射 binds 到连接 URI 的字典
3).使用独特的创建引擎
from sqlalchemy import create_engine
# echo参数为True时,会显示每条执行的SQL语句,为False时关闭
engine = create_engine('mysql+pymysql://root:123456@127.0.0.1:3306/people',echo=True)
engine.connect()
这样我们就算与People数据库建立连接了,接下来我们来建立一张表。
4).创建连接多个数据库
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数据库中的表:
__bind_key__ = 'users'
bind key 内部存储在表的 info 字典中 即:info={'bind_key': 'users'}
2.建立数据表并插入值
1).继承"db.Model"类
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) # 整数类型的自增主键
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)
# 请求钩子,第一次请求之前执行
@app.before_first_request
def create_table():
db.drop_all() # 删除所有表
db.create_all() # 创建新的表
@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() # 提交数据
return use1.__repr__() # 返回用户1的值
if __name__ == '__main__':
app.run(debug=True)
Column 参数列表
name 列名
type_ 类型
*args 列表参数
Constraint(约束), ForeignKey(外键), ColumnDefault(默认), Sequenceobjects(序列)定义
key 列名的别名
primary_key 如果为True,则是主键
nullable 如果是True,则可以为null
default 设置默认值,默认是None
index 是否是索引,默认是True
unique 是否唯一键,默认是False
onupdate 指定一个更新时候的值
autoincrement 设置为整型自动增长
quote 如果列明是关键字,则强制转义,默认False
2).利用原始引擎来创建会话(稍微复杂点)
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()
# 创建连接数据库的引擎并且打开回显
engine = create_engine("mysql+pymysql://root:123456@localhost/people",echo=True)
Session = sessionmaker(bind=engine) # 创建会话标记
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) # 删除所有数据库
Base.metadata.create_all(engine) # 创建所有数据库
@app.route('/')
def index():
user= User("hwhrr","123321")
session = Session() # 创建会话
session.add(user) # 添加内容
session.commit() # 提交
return user.__repr__()
if __name__ == '__main__':
app.run(debug=True)
3.数据库之间的关系
1). 一对一
只需让两张表都在同等的位置上,属于双向关系。
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)
2).一对多
我们需要建立一个主表和一个子表,分别命名为“father”和‘son’,然后需要建立外键和反射来互相引用建立一种关系,我们来看看:
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:动态加载,只有用到了才加载 只可以用在一对多和多对多关系中
# 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')) # 建立外键关联,指明表名和字段
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).多对一
就是将反射应用在子表上,与父表同时进行关联。
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')) # 建立外键关联
# 表示另一端是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)
4).多对多
设置一个关联表来对两个表同时进行管理。
# 设置关联表
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)
# 设置关联表 动态加载
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)
可以看出我们已经创建出了一张关联表,名字就是我们设置的“glb”。
4.查看数据
1).查看全部数据(all)
father.query.all()
2).精准查询(filter_by)
father.query.filter_by(name='hw').all() # 查找所有名字为hw的记录
3).模糊查询(filter)
father.query.filter(father.name.startswith('h').all() # 查找所有名字首字母为h的记录
4).主键查询(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).一对多正向查询
son.query.filter_by(f_id=2).all()
9).一对多反向查询
son.query.filter_by(fa=use1).all()
10).查询第一个出现的数据
son.query.filter(son.age==10).first()
son.query.filter(son.age==10)[0]
11).查询对象并返回指定数量的结果
son.query.filter(son.age==10).limit(10).all() # 返回十个查找到的对象
12).查询时指定偏移量
son.query.filter(son.age==10).offset(2).all() # 返回偏移了2的对象
13).查找对象并排序
son.query.filter(son.age==10).order_by(son.create_time.desc()).all() # 返回按降序排序的记录
14).查找对象返回分组结果
son.query.filter(son.age==10).group_by(son.name).all() # 返回age为10的名字对象分组
15).返回查询结果的数量
son.query.filter(son.age==10).count() # son的年龄为10的数量
16).返回切片结果
son.query(son).slice(10,40).all() # son从10到40的记录
son.query(son)[10:40]
17).分页获取数据
p=request.args.get('p')
# 从请求的查询字符串中获取当前页面,返回一个每页显示3条记录的分页对象
paginate=son.query.paginate(p=int(p),per_page=3)
paginate 属性:
pages # 总共生成页面数量
page # 当前页数
has_next # 判断是否有下一页
has_prev # 判断是否有上一页
next_num # 获取下一页的页码数
prev_num # 获取上一页的页码数
items # 获取当前页的记录
total # 查询返回的记录总数
18).查询仅显示一条记录
son.query(son).one()
5.更新数据
ss=son.query.get(1)
ss.name='fasd' # 更改name的值来达到更新的目的
db.session.commit()
6.删除数据
ss=son.query.get(1)
db.session.delete(ss)
db.session.commit()
三、总结
Sqlalchemy支持很多表的建立和操作,通过对它的了解,我们可以很方便的操作数据库的数据从而与前端页面交互达到可视化的效果,通过这篇文章的学习,相信你可以独立开发一个小网站了。
相关推荐
- 野路子科技!2步教你把手机改造成一个FTP服务器,支持PC互传
-
哈喽,大家好,我是野路子科技,今天来给大家带来一个教程,希望大家喜欢。正如标题所言,就是教大家如何把售价改造成FTP服务器,而这个时候估计有朋友会问了,把手机改造成FTP服务器有什么用呢?现在有Q...
- 不得不看:别样于Server-U的群晖文件存储服务器的搭建与使用
-
我先前的作品中,有着关于Server-U的ftp文件存储服务器的搭建与访问的头条文章和西瓜视频,而且我们通过各种方式也给各位粉丝介绍了如何突破局域网实现真正意义上的公网访问机制技术。关于Server-...
- Qt三种方式实现FTP上传功能_qt引入qftp库
-
FTP协议FTP的中文名称是“文件传输协议”,是FileTransferProtocol三个英文单词的缩写。FTP协议是TCP/IP协议组中的协议之一,其传输效率非常高,在网络上传输大的文件时,经...
- Filezilla文件服务器搭建及客户端的使用
-
FileZilla是一个免费开源的FTP软件,分为客户端版本和服务器版本,具备所有的FTP软件功能。可控性、有条理的界面和管理多站点的简化方式使得Filezilla客户端版成为一个方便高效的FTP客户...
- 美能达柯美/震旦复印机FTP扫描怎么设置?
-
好多网友不知道怎么安装美能达/震旦复印机扫描,用得最多是SMB和FTP扫描,相对于SMB来说,FTP扫描安装步骤更为便捷,不容易出问题,不需要设置文件夹共享,所以小编推荐FTP来扫描以美能达机器为例详...
- CCD(简易FTP服务器软件)_简单ftp服务器软件
-
CCD简易FTP服务器软件是一款很方便的FPT搭建工具,可以将我们的电脑快速变成一个FPT服务器。使用方法非常简单,只要运行软件就会自动生效,下载银行有该资源。该工具是不提供操作界面的,其他用户可以输...
- Ubuntu系统搭建FTP服务器教程_ubuntu架设服务器
-
在Ubuntu系统上搭建FTP服务器是文件传输的一个非常实用方法,适合需要进行大量文件交换的场景。以下是一步步指导,帮助您在Ubuntu上成功搭建FTP服务器。1.安装vsftpd软件...
- 理光FTP扫描设置教程_理光ftp扫描设置方法
-
此教程主要用来解决WIN10系统下不能使用SMB文件夹扫描的问题,由于旧的SMB协议存在安全漏洞,所以微软在新的系统,WIN8/WIN10/SERVER201220162018里使用了新的SMB传...
- 纯小白如何利用wireshark学习网络技术
-
写在前面工欲善其事必先利其器!熟悉掌握一种神器对以后的工作必然是有帮助的,下面我将从简单的描述Wireshark的使用和自己思考去写,若有错误或不足还请批评指正。...
- 京东买13盘位32GB内存NAS:NAS系统安装设置教程
-
本内容来源于@什么值得买APP,观点仅代表作者本人|作者:yasden你没有看错,我在京东自营商城购买硬件,组装了一台13盘位,32GB内存的NAS,硬盘有13个盘位!CPU是AMD的5500!本文...
- python教程之FTP相关操作_python ftps
-
ftplib类库常用相关操作importftplibftp=ftplib.FTP()ftp.set_debuglevel(2)#打开调试级别2,显示详细信息ftp.connect(“I...
- xftp怎么用,xftp怎么用,具体使用方法
-
Xftp是一款界面化的ftp传输工具,用起来方便简单,这里为大家分享下Xftp怎么使用?希望能帮到有需要的朋友。IIS7服务器管理工具可以批量管理、定时上传下载、同步操作、数据备份、到期提醒、自动更新...
- 树莓派文件上传和下载,详细步骤设置FTP服务器
-
在本指南中,详细记录了如何在树莓Pi上设置FTP。设置FTP可以在网络上轻松地将文件传输到Pi上。FTP是文件传输协议的缩写,只是一种通过网络在两个设备之间传输文件的方法。还有一种额外的方法,你可以用...
- win10电脑操作系统,怎么设置FTP?windows10系统设置FTP操作方法
-
打印,打印,扫描的日常操作是每一个办公工作人员的必需专业技能,要应用FTP作用扫描文件到电脑上,最先要必须一台可以接受文件的FTP服务器。许多软件都需要收费标准进行,但人们还可以应用Windows的系...
你 发表评论:
欢迎- 一周热门
- 最近发表
- 标签列表
-
- mybatis plus (70)
- scheduledtask (71)
- css滚动条 (60)
- java学生成绩管理系统 (59)
- 结构体数组 (69)
- databasemetadata (64)
- javastatic (68)
- jsp实用教程 (53)
- fontawesome (57)
- widget开发 (57)
- vb net教程 (62)
- hibernate 教程 (63)
- case语句 (57)
- svn连接 (74)
- directoryindex (69)
- session timeout (58)
- textbox换行 (67)
- extension_dir (64)
- linearlayout (58)
- vba高级教程 (75)
- iframe用法 (58)
- sqlparameter (59)
- trim函数 (59)
- flex布局 (63)
- contextloaderlistener (56)