使用ORM框架SQLAlchemy 時(shí),數(shù)據(jù)庫(kù)中已有表,不需要再使用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)
# ①:反射單個(gè)表
# apply_info = Table('apply_info', metadata, autoload=True)
# apply_info.columns.keys() # 列出所有的列名
# *********************************************************************
# ②:反射整個(gè)數(shù)據(jù)庫(kù)
# 使用reflect()方法,它不會(huì)返回任何值
# metadata.reflect(bind=engine)
# metadata.tables.keys() # 獲取所有的表名
# # 雖然反射了整個(gè)數(shù)據(jù)庫(kù),還是需要再添加一次具體的表反射.
# 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() # 獲取所有的對(duì)象名
# 獲取表對(duì)象
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é)果,可以通過(guò)dot.號(hào)訪問(wèn)。而oracle 不可以。
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。