无法将对象从一个数据库移动到另一个数据库
问题描述:
我想将对象从一个数据库移动到另一个数据库。映射是相同的,但表格是不同的。这是一个合并工具,需要将旧数据库中的数据导入到新数据库中。不过,我想我在这里错过了一些关于SQLAlchemy的基础知识。它是什么?无法将对象从一个数据库移动到另一个数据库
from sqlalchemy import Column, Float, String, Enum
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import orm
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
DeclarativeBase = declarative_base()
class Datum (DeclarativeBase):
__tablename__ = "xUnitTestData"
Key = Column(String, primary_key=True)
Value = Column(Float)
def __init__ (self, k, v):
self.Key = k
self.Value = v
src_engine = create_engine('sqlite:///:memory:', echo=False)
dst_engine = create_engine('sqlite:///:memory:', echo=False)
DeclarativeBase.metadata.create_all(src_engine)
DeclarativeBase.metadata.create_all(dst_engine)
SessionSRC = sessionmaker(bind=src_engine)
SessionDST = sessionmaker(bind=dst_engine)
item = Datum('eek', 666)
session1 = SessionSRC()
session1.add(item)
session1.commit()
session1.close()
session2 = SessionDST()
session2.add(item)
session2.commit()
print item in session2 # >>> True
print session2.query(Datum).all() # >>> []
session2.close()
答
我没有真正意识到对引擎盖下会发生什么,但在ORM图案的物体在特定的表匹配到一个特定的行。如果您尝试将同一对象添加到两个不同数据库中的两个不同表中,即使表定义完全相同,听起来也不是一个好习惯。
我该怎么做才能解决这个问题只需要创建一个新的对象,它是原始对象的副本,并将其添加到数据库:
session1 = SessionSRC()
session1.add(item)
session1.commit()
new_item = Datum(item.Key, item.Value)
session2 = SessionDST()
session2.add(new_item)
session2.commit()
print new_item in session2 # >>> True
print session2.query(Datum).all() # >>> [<__main__.Datum object at 0x.......>]
session2.close()
session1.close()
注意session1
不立即关闭能够在创建新对象时读取原始对象属性。
是的,我想避免这样做,因为它看起来不雅观。啊... – Sardathrion 2012-02-22 10:25:42
问题是如何在表格之间进行复制。如果SQLAlchemy无法执行简单的表副本,或者您不知道如何执行该操作,请直接说出来。 – 2016-01-15 19:11:19