基础入门_Python-模块和包.深入SQLAlchemy之SQLAlchemy ORM重构表?

简单介绍:

说明: 此模块主要用于将关系型数据库表映射到PY的类,行映射到PY类的实例,列映射为PY实例的属性,由于其兼容众多DB-API及扩展,SO可以优先考虑数据模型,而忽略底层的DB-API切换,数据迁移更方便.

快速安装:

pip install --upgrade SQLAlchemy

#!/usr/bin/env python
# -*- coding: utf-8 -*-
"""
#
# Authors: limanman
# OsChina: http://xmdevops.blog.51cto.com/
# Purpose:
#
"""
# 说明: 导入公共模块
from datetime import datetime
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import (create_engine, MetaData, Table, Column, Integer, String, DateTime, Numeric,
                        ForeignKey, PrimaryKeyConstraint, ForeignKeyConstraint, UniqueConstraint)
# 说明: 导入其它模块
from constants import USERNAME, PASSWORD, HOSTNAME, HOSTPORT, DATABASE, CHARSSET, ALLDBURI
Base = declarative_base()
class Cookies(Base):
    __tablename__ = ‘cookies‘
    id = Column(Integer(), primary_key=True, autoincrement=True)
    cookie_name = Column(String(50), index=True)
    cookie_recipe_url = Column(String(255))
    cookie_sku = Column(String(55))
    quantity = Column(Integer())
    unit_cost = Column(Numeric(12, 2))

注意: 要定义一个ORM的表类,需要满足至少四个条件,必须继承自declarative_base实例,必须包含一个__tablename__类属性,值为对应数据库中的表名,必须至少包含一个或是更多的列属性,必须至少有一个或更多列作为主键

索引约束:

class Cookies(Base):
    __tablename__ = ‘cookies‘
    __table_args__ = (PrimaryKeyConstraint(‘id‘))
    id = Column(Integer(), autoincrement=True)
    cookie_name = Column(String(50), index=True)
    cookie_recipe_url = Column(String(255))
    cookie_sku = Column(String(55))
    quantity = Column(Integer())
    unit_cost = Column(Numeric(12, 2))

关系映射:

说明: 如上图,一个用户可以产生多个订单,所以在orders表中创建外键user_id关联users表,而每个订单又可以包含多个商品,且可以包含多个相同的商品最终还得有一个最终价格,所以在line_items中创建外键order_id关联orders,又因为每个商品有具体详情所以在line_items中创建外键cookie_id关联cookies

#!/usr/bin/env python
# -*- coding: utf-8 -*-
"""
#
# Authors: limanman
# OsChina: http://xmdevops.blog.51cto.com/
# Purpose:
#
"""
# 说明: 导入公共模块
from datetime import datetime
from sqlalchemy.orm import relationship, backref
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import (create_engine, Column, Integer, String, DateTime, Numeric, ForeignKey)
# 说明: 导入其它模块
from constants import USERNAME, PASSWORD, HOSTNAME, HOSTPORT, DATABASE, CHARSSET, ALLDBURI
Base = declarative_base()
class Users(Base):
    __tablename__ = ‘users‘
    id = Column(Integer(), primary_key=True, autoincrement=True)
    customer_number = Column(Integer(), autoincrement=True)
    username = Column(String(15), unique=True, nullable=False)
    email_address = Column(String(255), nullable=False)
    phone = Column(String(20), nullable=False)
    password = Column(String(25), nullable=False)
    created_on = Column(DateTime(), default=datetime.now)
    updated_on = Column(DateTime(), default=datetime.now, onupdate=datetime.now)
class Orders(Base):
    __tablename__ = ‘orders‘
    id = Column(Integer(), primary_key=True, autoincrement=True)
    user_id = Column(Integer(), ForeignKey(‘Users.id‘), nullable=False)
    user = relationship(‘Users‘, backref=backref(‘orders‘, order_by=id))
class LineItems(Base):
    __tablename__ = ‘line_items‘
    id = Column(Integer(), primary_key=True, autoincrement=True)
    quantity = Column(Integer())
    extended_cost = Column(Numeric(12, 2))
    order_id = Column(Integer(), ForeignKey(‘Orders.id‘), nullable=False)
    cookie_id = Column(Integer(), ForeignKey(‘Cookies.id‘), nullable=False)
    order = relationship(‘Orders‘, backref=backref(‘line_items‘, order_by=id))
    cookies = relationship(‘Cookies‘, backref=backref(‘line_item‘, uselist=False))
class Cookies(Base):
    __tablename__ = ‘cookies‘
    id = Column(Integer(), primary_key=True, autoincrement=True)
    cookie_name = Column(String(50), index=True)
    cookie_recipe_url = Column(String(255))
    cookie_sku = Column(String(55))
    quantity = Column(Integer())
    unit_cost = Column(Numeric(12, 2))
if __name__ == ‘__main__‘:
    # 第一步: 创建引擎对象
    engine = create_engine(ALLDBURI, echo=True, pool_recycle=3600)
    # 第二步: 创建元数据对象
    Base.metadata.create_all(bind=engine)