无法将对象从一个数据库移动到另一个数据库

问题描述:

我想将对象从一个数据库移动到另一个数据库。映射是相同的,但表格是不同的。这是一个合并工具,需要将旧数据库中的数据导入到新数据库中。不过,我想我在这里错过了一些关于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不立即关闭能够在创建新对象时读取原始对象属性。

+0

是的,我想避免这样做,因为它看起来不雅观。啊... – Sardathrion 2012-02-22 10:25:42

+1

问题是如何在表格之间进行复制。如果SQLAlchemy无法执行简单的表副本,或者您不知道如何执行该操作,请直接说出来。 – 2016-01-15 19:11:19