Flask笔记:数据库ORM操作MySQL+pymysql/mysql-python+SQLAlchem
Python中使用sqlalchemy插件可以实现ORM(Object Relationship Mapping,模型关系映射)框架,而Flask中的flask-sqlalchemy其实就是在sqlalchemy外进行了一层封装,使得在flask中使用起来更加方便,当然sqlalchemy的原有的方法也都可以使用。也就是说sqlalchemy在普通的Python程序中也可以使用,而flask-sqlalchemy是为flask“定制”的。 我这里使用的是MySQL数据库,Python3中对应的驱动插件为pymysql(Python2中对应的驱动插件为mysql-python),所以这里的数据库操作需要安装MySQL、pymysql(或mysql-python)和flask-sqlalchemy。 ? 一、MySQL数据库安装(其实MySQL的东西网上一大堆) 安装版:exe安装版按照步骤一步步来就行了,可以只安装MySQL服务即可,如果电脑上没有对应版本VS C++也会提示你安装的。 免安装版/解压版:根据以下步骤进行即可:
[mysqld] 注:解压后可以自己更改文件夹名称,比如我这儿是“MySQL Server 8.0”,配置这两个信息后,其中的“data”文件夹不要自己创建(默认是没有这个文件夹的,但是会在下一步自动创建),否则MySQL服务会启动失败。
安装和使用过程中遇到的问题和解决方案:
? 二、数据库驱动插件安装(pymysql/mysql-python)
? 三、SQLAlchemy使用 1.安装:pip install sqlalchemy 2.连接数据库:设置数据库连接字符串,并使用create_engine函数创建一个engine对象,并使用engine对象的connect方法连接数据库,注意连接数据库后需要使用close方法关闭连接。 from sqlalchemy import create_engine # 数据库连接信息 HOSTNAME = '127.0.0.1' # 本机地址 PORT = 3306# MySQL默认端口 DATABASE = sqlalchemy_demo# 数据库名 USERNAME = root# 安装数据库时设置的用户名和密码 PASSWORD = 123456' 数据库连接字符串 # dialect+driver://username:password@host:port/database DB_URI = mysql+pymysql://{username}:{password}@{host}:{port}/{database}'.format( username=USERNAME,password=PASSWORD,host=HOSTNAME,port=PORT,database=DATABASE ) 创建一个engine对象 engine = create_engine(DB_URI) 连接数据库 conn = engine.connect() 执行SQL语句,并返回执行结果 sel_res = conn.execute(select * from User) 获取并打印一条查询结果 print(sel_res.fetchone()) 关闭连接 conn.close()
3.定义模型类:使用declarative_base函数生成一个模型类的基类,以便模型类映射到数据库中,且必须使用__tablename__指定表名(一个类对应数据库中一张表,不同的类实例对应表中不同的记录)。 create_engine,Column,Integer,String from sqlalchemy.ext.declarative declarative_base 创建所有模型类的基类 Base = declarative_base(engine) 注意以下定义全是在类中直接进行的,没有在__init__等方法中进行 class Person(Base): 使用__table__name指定表名 __tablename__ = person' 定义属性字段id为整型、主键、自动增长 id = Column(Integer,primary_key=True,autoincrement=True) 定义属性字段name为最长50个字符的字符串类型,且非空 name = Column(String(50),nullable=False) 定义属性字段age为整型 age = Column(Integer) 删除表,不用特地指定表,在加载Python文件时会自动检查定义了哪些表,并删除这些表 Base.metadata.drop_all() 将所有模型映射到数据库中,并且相同的模型类只在第一次执行时会生效,即如果第一次执行后, 又对类进行了修改,重新运行程序执行metadata.create_all()后并不会把更新的内容映射到数据库中,前提是数据库中的表没有被删除 Base.metadata.create_all()
4.常用数据类型:数据类型对应的类直接从模块sqlalchemy中导入即可。
5.Column常用参数:Column的第一个参数name用来指定数据中的属性名,如果不指定则默认为该属性变量名为属性名。
6.增删改查操作:使用sessionmaker创建session,并在session中进行增删改查操作,注意如果涉及到修改数据库,一定要commit后才能在数据库生效。
增删改查简单示例(数据库连接代码和模型类代码见前面的代码示例): declarative_base from sqlalchemy.orm sessionmaker engine = create_engine(DB_URI) 别忘了实例化后再一次调用(加括号),会调用类的__call__生成session session = sessionmaker(engine)() 增加数据 def add_data(): p = Person(name=Jason',age=19) 添加一条数据到内存中 session.add(p) 添加多条数据到内存中 p1 = Person(name=Mickle) p2 = Person(name=Marya) session.add_all([p1,p2]) 提交到数据库中 session.commit() 删除数据 del_data(): p = session.query(Person).first() 直接删除提交即可 session.delete(p) session.commit() 修改数据 update_data(): p = 获取对象后,直接修改提交即可 p.name = JiuyunnZhao session.commit() 查询数据 search_data(): 查找模型类对应表的的所有数据(可用for遍历) persons = session.query(Person).all() 查询满足某个条件的所有数据(可for遍历),查询条件只有参数和一个等号(这种方式比较简单,因为只针对一个类) persons = session.query(Person).filter_by(name='Mickle').all() 查询满足某个条件的所有数据(可for遍历),查询条件类名.参数和双等号(filter中的条件可以更加复杂,这里只是简单举例) persons = session.query(Person).filter(Person.name == 'Mickle').all() for p in persons: print(p) 根据主键查询某一条数据,没有对应的主键则返回None p = session.query(Person).get(100) 获取某张表的第一条数据 p = session.query(Person).first() p = session.query(Person).filter(Person.name == ).first() p = session.query(Person).filter_by(name=).first() (p) 测试代码 if __name__ == __main__: add_data() del_data() update_data() search_data() ? 7.聚合函数:从sqlalchemy中导入func,func中有许多聚合函数可以使用。其实func中没有“真正”的聚合函数,都是MySQL中的函数,也就是说MySQL中的聚合函数都可以在func中找到和使用。
? 8.filter中的条件过滤(注意不是filter_by方法):
? 9.外键及外键约束:在想要定义为外键的列中传入参数ForeignKey('tablename.column_name')即可,如果想要定义外键约束,在ForeignKey中指定参数ondelete为相应约束即可,默认约束为RESTRICT。
sessionmaker HOSTNAME = DATABASE ) engine = create_engine(DB_URI) Base = declarative_base(engine) 父表 User(Base): user user_id = Column(Integer,1)">True) username = Column(String(50),1)">False) 子表 Article(Base): article atc_id = Column(Integer,1)">True) title = Column(String(50),1)">False) content = Column(Text,1)">False) 外键列,意为一个用户可以有多篇文章,注意此列的类型应该对应父表的主键类型一致 ? 10.外键关系:通过relationship将两个存在外键关联的两张表建立一个关系属性,并通过这个属性去进行互相访问。
一对一关系简单示例: 一对一关系示例1:一张表定义外键,另一张表定义一对一关系,即uselist=False 添加一个到模型Article的一对一关系,关键在于uselist=False,因为默认是True,那就是一对多了 article = relationship(ArticleFalse) 外键列“表名.属性名”,而不是“类名.属性变量名” user_id = Column(Integer,1)">)) 添加一个到模型User的关系,由于User类中定义了一对一uselist=False,所以这个关系自然也是一对一了,也不用再指定uselist=False author = relationship(User) 一对一示例2:利用反向引用函数backref建立一对一关系 backref函数中的参数和relationship中的参数是一致的,relationship中可用的参数它都可以用 sessionmaker,relationship,backref 外键列 user_id = Column(Integer,1)">)) 这里backref的使用相当于在User类中建立了一个名为article的关系,且参数uselist为False author = relationship( 一对多关系简单示例 一对多关系示例1 添加一个到模型Article的关系,一对多,表示“多”的的变量articles其实继承自list,所以append等方法也适用这个属性 articles = relationship( 外键列,注意这里是“表名.属性名”,而不是“类名.属性变量名” user_id = Column(Integer,1)"> 添加一个到模型User的关系,多对一 author = relationship( 一对多关系示例2 反向引用,backref参数就相当于自动给User模型添加了一个名为articles且关联到User模型的的关系 author = relationship(articles) 使用示例,以下代码将在article表中添加两条数据 user =User(username=) article1 = Article(title=aaa1111) article2 = Article(title=bbb222) user.articles.append(article1) user.articles.append(article2) session.add(user) session.commit() 多对多关系简单示例 多对多关系示例:一篇文章可以有多个标签,一个标签也可以用于多篇文章 = DATABASE ) engine = declarative_base(engine) session = artcle_id = Column(Integer,1)"> 与Tag建立关联关系和反向引用关系,并指明中间表为article_tag 这个关系可以定义在关联的两张表中的任意一张表中都可以 tags = relationship(Tagarticle_tag) Tag(Base): tag tag_id = Column(Integer,1)">True) name = Column(String(50),1)"> 通过类Table来生成一个中间表 article_tag = Table( article_tag 表名 Base.metadata,1)"> 继承的模型类型 定义中间表中的列,声明此列关联到表article的列article_id,并指明以此列来作为复合主键的其中一列 Column(article_idarticle.article_id'),primary_key=True), 定义中间表中的列,声明此列关联到表tag的列tag_id,并指明以此列来作为复合主键的其中一列 Column(tag_idtag.tag_idTrue) ) 添加数据到数据库中 article1 = Article(title=my article 1my article 2) tag1 = Tag(name=my tag 1) tag2 = Tag(name=my tag 2) article1.tags.append(tag1) article1.tags.append(tag2) article2.tags.append(tag1) article2.tags.append(tag2) session.add(article1) session.add(article2) session.commit() ? ? 11.查询排序:默认升序,降序一般使用对应属性的desc()方法即可。
?升序降序简单示例: 以下列子以模型类Article中的字段create_time作为示例(字符串中的属性名是数据库中的属性名而不是变量名(没有定义时两者是一样的)) 方式一:在session中使用order_by查询排序 升序 articles = session.query(Article).order_by(Article.create_time).all() articles = session.query(Article).order_by(create_time).all() 降序) articles = session.query(Article).order_by(Article.create_time.desc()).all() articles = session.query(Article).order_by(-create_time).all() 方式二、在模型类中使用__mapper_args__的order_by指定查询排序 id = Column(Integer,1)">False) create_time = Column(DateTime,nullable=False,default=datetime.now) __mapper_args__ = { order_by': create_time,1)"> 升序 'order_by': create_time.desc(),# 降序 } 方式三、使用模型类中relationship的roder_by进行指定查询排序 datetime.now) user_id = Column(Integer,1)">user.id)) author = realtionship( 升序 author = realtionship('User',backref=backref('articles',order_by=create_time.desc())) # 降序 ? 12.query对象常用方法:
? 13.高级查询:
? 四、Flask-SQLAlchemy使用 由于Flask-SQLAlchemy其实是SQLAlchemy在外面进行了一层封装,以便更好的适用于flask,所以Flask-SQLAlchemy和SQLAlchemy在使用上除了最外层封装的定义外都是一样的,下面只讲一些常需要注意的不同之处 安装:pip install flask-sqlalchemy 1. 配置:需要在配置文件中配置数据库连接字符串“SQLALCHEMY_DATABASE_URI”,其中driver为Python2的mysqldb,Python3的pymysql,具体以安装的插件为准。 数据库连接固定格式格式字符串 dialect+driver://username:password@host:port/database DIALECT = mysql DRIVER = mysqldb PASSWORD = 123456 HOST = db_demo1 SQLALCHEMY_DATABASE_URI = {dialect}+{driver}://{username}:{password}@{host}:{port}/{database}?charset=utf8.format( dialect=DIALECT,driver=DRIVER,username=USERNAME,host=HOST,1)">DATABASE ) 2.使用:Column、relationship等都可以直接在“from flask_sqlalchemy import SQLAlchemy”的SQLAlchemy实例中直接使用
简单示例(配置信息写在了配置文件config.py中了) from flask Flask from flask_sqlalchemy SQLAlchemy config app = Flask(__name__) app.config.from_object(config) db = SQLAlchemy(app) db.create_all() User(db.Model): ' 设置表名,未设置则以类名全小写为表名 id = db.Column(db.Integer,autoincrement=True) 定义列id,整型,主键,自增长 username = db.Column(db.String(100),nullable=False) 定义列username,字符型(最大100个字符),非空 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |