使用ORM框架SQLAlchemy 時,數(shù)據(jù)庫中已有表脚线,不需要再使用SQLalchemy 創(chuàng)建搁胆,可以使用以下方式映射已存在表.
# sqlalchemy 反射
from sqlalchemy import MetaData, create_engine
from sqlalchemy.ext.automap import automap_base
from sqlalchemy.orm import sessionmaker
uri = 'mysql+pymysql://root:sp@2016@10.1.1.1:3306/dev'
engine = create_engine(uri, echo=False)
metadata = MetaData(engine)
# ①:反射單個表
# apply_info = Table('apply_info', metadata, autoload=True)
# apply_info.columns.keys() # 列出所有的列名
# *********************************************************************
# ②:反射整個數(shù)據(jù)庫
# 使用reflect()方法,它不會返回任何值
# metadata.reflect(bind=engine)
# metadata.tables.keys() # 獲取所有的表名
# # 雖然反射了整個數(shù)據(jù)庫邮绿,還是需要再添加一次具體的表反射.
# apply_info = metadata.tables['apply_info']
# *********************************************************************
# ③:基于ORM的反射
Base = automap_base()
# Base = declarative_base()
# apply_info = Base.metadata.tables['apply_info']
Base.prepare(engine, reflect=True)
Base.classes.keys() # 獲取所有的對象名
# 獲取表對象
apply_info = Base.classes.apply_info
# *********************************************************************
Session = sessionmaker(bind=engine)
session = Session()
# 插入數(shù)據(jù)
# session.add(apply_info(email_address="foo@bar.com", name="foo"))
# session.commit()
# keys = apply_info.__table__.columns.keys()
#
# rows = session.query(apply_info)
#
# data = [getattr(rows, key) for key in keys]
# mysql 查詢的結(jié)果渠旁,可以通過dot.號訪問。而oracle 不可以船逮。