SQLAlchemy

1. SQLAlchemy介绍

  SQLAlchemy是一个基于Python实现的ORM框架,能知足大多数数据库操做需求,同时支持多种数据库引擎(SQLite,MySQL,Postgresql,Oracle等)html

  SQLAlchemy组件中最有名的是它的对象关系映射器(ORM)python

  ORM 将数据库中的表与面向对象语言中的类创建了一种对应关系mysql

  ORM将一个Python的对象映射为数据库中的一张关系表。它将SQL封装起来,程序员再也不须要关心数据库的具体操做,只须要专一于本身自己代码和业务逻辑的实现程序员

  对数据表的抽象,容许开发人员首先考虑数据模型,同时使得Python程序更加简洁易读。
  对各类数据库引擎的封装,使得开发人员在面对不一样数据库时,只须要作简单修改便可,工做量大大减小。sql

  总体的实现过程就是:Python代码,经过ORM转换成SQL语句,再经过pymysql去实际操做数据库,最典型的ORM就是咱们的SQLAlchemy数据库

2.使用

  SQLAlchemy自己没法操做数据库,必须依赖pymsql等第三方插件。根据配置文件的不一样调用不一样的数据库API,从而实现对数据库的操做flask

MySQL-Python
    mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname>
    
pymysql
    mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options>]
    
MySQL-Connector
    mysql+mysqlconnector://<user>:<password>@<host>[:<port>]/<dbname>
    
cx_Oracle
    oracle+cx_oracle://user:pass@host:port/dbname[?key=value&key=value...]
    

其余可参考此处:http://docs.sqlalchemy.org/en/latest/dialects/index.htmlsession

 2.1 flask-sqlalchemyoracle

  常见咱们须要下载一个 Flask-SQLAlchemy扩展包app

官方文档连接:猛戳此处

from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)

# 数据库类型://用户名:密码(没有密码则为空,不填)@数据库主机地址/数据库名?编码
DB_URL = 'mysql+pymysql://root:@localhost/test?charset=utf8'

# 添加到全局配制中,这步必学要有
app.config['SQLALCHEMY_DATABASE_URI'] = DB_URL
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False

db = SQLAlchemy(app)


class Parent(db.Model):
    __tablename__ = 'parent'
    id = db.Column(db.Integer, primary_key=True)
    par_name = db.Column(db.String(50), nullable=False)
    children = db.relationship("Child", backref="parent")
   # 在父表类中经过relationship() 方法来引用子表的类集合
   # 当咱们须要在父表中添加子表关系时使用 relationship,这样子表将会在多对一的关系中经过.parent的方式得到父表的属性


class Child(db.Model):
    __tablename__ = 'child'
    id = db.Column(db.Integer, primary_key=True)
    child_name = db.Column(db.String(50), nullable=False)
    parent_id = db.Column(db.Integer, db.ForeignKey('parent.id'))
    # 在子表类中经过 foreign key (外键)引用父表的参考字段


# db.drop_all()         #删除表
# db.create_all()       #建立表


# 添加数据
# par1 = Parent(par_name='爸爸1')
# par2 = Parent(par_name='爸爸2')
# chi = Child(child_name='儿子1',parent_id=2)

# db.session.add(par1)
# db.session.add(par2)
# db.session.add(chi)
# db.session.commit()


# 查看数据
# par =Parent.query.all()
# print(par)  # [<Parent 1>, <Parent 2>]

# chi = Child.query.filter(Child.parent_id).first().child_name
# print(chi)  # 儿子1


# 修改数据
# chi = Child.query.filter(Child.parent_id).first()
# chi.child_name = "好儿子"
# db.session.commit()     # 刷新数据库,能够看见数据已经更新


# 删除数据
# par =Parent.query.filter(Parent.id==1).first()
# db.session.delete(par)
# db.session.commit()     # 刷新数据库,id=1的数据已经不存在


@app.route('/')
def hello_world():
    return 'Hello World!'

if __name__ == '__main__':
    app.run(port=5050)

最终的效果

也可参考本篇博文:博文连接

详细操做参考:博文连接

 进阶阅读:参考知乎连接

相关文章
相关标签/搜索