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

发布时间：2020-12-20 13:26:42 所属栏目：Python 来源：网络整理

导读：我试图将一个对象从一个数据库移动到另一个数据库.映射是相同的,但表是不同的.这是一个合并工具,需要将旧数据库中的数据导入到新数据库中.不过,我认为我在这里遗漏了一些关于SQLAlchemy的基本信息.它是什么？ from sqlalchemy import Column,Float,String,En

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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!