删除未级联到sqlalchemy中的表

Question

我正在开发对使用sqlalchemy 0.6的现有应用程序的扩展。

该应用程序创建了非声明式的sqlalchemy表。我试图在我的扩展中创建一个新的表，其中有一个外键列指向应用程序数据库中主表的主键，我正在声明性地创建它。

这一切都正常工作，一旦扩展加载，创建表，并没有投诉。我的表格打印出来并显示新行已添加好。 我想和想的是可能的（但不知道，因为我从来没有使用SQL或任何其他数据库）是我的表中相应的行被删除时，应用程序的主表中的行与相应的外键是删除。

到目前为止，已经尝试了许多排列，没有任何工作。我认为，使用backref集以及使用delete级联定义的关系时，应该没有问题。因为新的表格是在扩展中定义的，所以我不想在主应用程序中编辑代码，至少这是我的目标。但是我遇到的一个问题是，我想要引用的主要应用程序表中没有在其类中定义的成员变量，没有在其映射器中声明其主键，并且只在表中声明了主键。这使得创建关系（ship）子句变得困难，其中的第一个参数必须是类或映射器（在这种情况下，没有声明主键）。 有没有办法实现这个？

ps - 这里是我正在使用的一些代码。 LocalFile是声明类。所有连接细节由主应用程序处理。

if not self.LocalFile.__table__.exists(bind=Engine): 
     self.LocalFile__table__.create(bind=Engine) 

这里是LOCALFILE类 - 基本是一种声明基类与绑定引擎=在构造通过：

class LocalFile(Base): 
    __tablename__ = 'local_file' 
    _id = Column(Integer, Sequence('local_file_sequence', start=1, increment=1), primary_key=True) 
    _filename = Column(String(50), nullable=False) 
    _filepath = Column(String(128), nullable=False) 
    _movieid = Column(Integer, ForeignKey(db.tables.movies.c.movie_id, onupdate='CASCADE', ondelete='CASCADE')) 
    #movies = relation(db.Movie, backref="local_file", cascade="all") 

    @property 
    def filename(self): 
     return self._filename 

    @filename.setter 
    def filename(self, filename): 
     self._filename = filename 

    @property 
    def filepath(self): 
     return self._filepath 

    @filepath.setter 
    def filepath(self, filepath): 
     self._filepath = filepath 

    @property 
    def movieid(self): 
     return self._movieid 

    @movieid.setter 
    def movieid(self, movieid): 
     self._movieid = movieid 

    @property 
    def id(self): 
     return self._id 

    @id.setter 
    def id(self, id): 
     self._id = id 

    filename = synonym('_filename', descriptor=filename) 
    movieid = synonym('_movieid', descriptor=movieid) 
    filepath = synonym('_filepath', descriptor=filepath) 
    id = synonym('_id', descriptor=id) 

    def __init__(self, filename, filepath, movieid): 
     self._filename = filename 
     self._filepath = filepath 
     self._movieid = movieid 

    def __repr__(self): 
     return "<User('%s','%s', '%s')>" % (self.filename, self.filepath, self.movieid) 

编辑：

后端是sqlite3的。下面是通过使用echo命令创建的表的代码（感谢您指出了这一点，这非常有用 - 我怀疑现有的应用程序生成的sql比必要的要多得多）。 以下报告的sql表创建是删除一行时生成的代码。我个人看不到任何引用本地文件表中可能删除行的语句，但我目前知道的很少。谢谢。

 2011-12-29 16:29:18,530 INFO sqlalchemy.engine.base.Engine.0x...0650 
    CREATE TABLE local_file (
_id INTEGER NOT NULL, 
_filename VARCHAR(50) NOT NULL, 
_filepath VARCHAR(128) NOT NULL, 
_movieid INTEGER, 
PRIMARY KEY (_id), 
FOREIGN KEY(_movieid) REFERENCES movies (movie_id) ON DELETE CASCADE ON UPDATE CASCADE 

）

2011-12-29T16:29:18: I: sqlalchemy.engine.base.Engine.0x...0650(base:1387): 
    CREATE TABLE local_file (
_id INTEGER NOT NULL, 
_filename VARCHAR(50) NOT NULL, 
_filepath VARCHAR(128) NOT NULL, 
_movieid INTEGER, 
PRIMARY KEY (_id), 
FOREIGN KEY(_movieid) REFERENCES movies (movie_id) ON DELETE CASCADE ON UPDATE CASCADE 

）

2011-12-29 16:29:18,534 INFO sqlalchemy.engine.base.Engine.0x...0650() 
2011-12-29T16:29:18: I: sqlalchemy.engine.base.Engine.0x...0650(base:1388):() 
2011-12-29 16:29:18,643 INFO sqlalchemy.engine.base.Engine.0x...0650 COMMIT 
2011-12-29T16:29:18: I: sqlalchemy.engine.base.Engine.0x...0650(base:1095): COMMIT 

用于表行产生用于两个表如下：

本地文件表： （中，u” 310 To Yuma'） （，u'Ravenous'）

在现有的应用程序中的电影表： （，u'IMDb - 3:10至尤马“） （，u'Ravenous”）

代码时删除行这么久，我不能包括它在这里（200行左右 - 删除一行是不是有点太多？），但它没有提及删除localfile表中的一行。有喜欢的语句：

2011-12-29 17:09:17,141 INFO sqlalchemy.engine.base.Engine.0x...0650 UPDATE movies SET poster_md5=?, updated=? WHERE movies.movie_id = ? 
    2011-12-29T17:09:17: I: sqlalchemy.engine.base.Engine.0x...0650(base:1387): UPDATE movies SET poster_md5=?, updated=? WHERE movies.movie_id = ? 
    2011-12-29 17:09:17,142 INFO sqlalchemy.engine.base.Engine.0x...0650 (None, '2011-12-29 17:09:17.141019', 2) 
    2011-12-29T17:09:17: I: sqlalchemy.engine.base.Engine.0x...0650(base:1388): (None, '2011-12-29 17:09:17.141019', 2) 
    2011-12-29 17:09:17,150 INFO sqlalchemy.engine.base.Engine.0x...0650 DELETE FROM posters WHERE posters.md5sum = ? 
    2011-12-29T17:09:17: I: sqlalchemy.engine.base.Engine.0x...0650(base:1387): DELETE FROM posters WHERE posters.md5sum = ? 
    2011-12-29 17:09:17,157 INFO sqlalchemy.engine.base.Engine.0x...0650 (u'083841e14b8bb9ea166ea4b2b976f03d',) 

Answer 1

SQLite中，你必须明确地打开了外键支持，否则根本不理会有关外键的任何SQL。

engine = create_engine(database_url) 

def on_connect(conn, record): 
    conn.execute('pragma foreign_keys=ON') 

from sqlalchemy import event 
event.listen(engine, 'connect', on_connect)