2012-03-29 9 views
9

मेरे पास User एस और Task एस के बीच कई से अधिक संबंध हैं। मैं Task या User हटाते समय "द्वितीयक तालिका" (अर्थात्, तालिका जो कई से कई संबंधों को सुविधाजनक बनाता है) साफ़ कर लेना चाहता हूं। मैं इसके लिए SQLAlchemy कैसे कॉन्फ़िगर कर सकता हूं?पायथन का स्क्लाक्लेमी माध्यमिक (कई से कई) तालिका को साफ़ नहीं करता है?

यहां कुछ नमूना पायथन कोड है जो मेरी समस्या का प्रदर्शन करता है। नोट: यह कोड पूरी तरह से निहित है, और केवल sqlalchemy मॉड्यूल की आवश्यकता है। यदि आप इस कोड को कॉपी और पेस्ट करते हैं, तो आप इसे किसी भी दुष्प्रभाव के बिना चलाने में सक्षम होना चाहिए और वही व्यवहार स्वयं देख सकते हैं। स्क्रिप्ट की आखिरी पंक्ति से पता चलता है कि जब मैंने इसी कार्य को हटा दिया था तो "द्वितीयक तालिका" में प्रासंगिक पंक्ति को हटाया नहीं गया था। सभी उदाहरण इस उदाहरण में गुजरते हैं।

from sqlalchemy import create_engine, Column, Integer, Text, Table, ForeignKey 
from sqlalchemy.ext.declarative import declarative_base 
from sqlalchemy.orm import Session, relationship 

Model = declarative_base() 

class User(Model): 
    __tablename__ = 'users' 
    id = Column('user_id', Integer, primary_key=True) 
    email = Column('email', Text, unique=True) 

    def __init__(self, email): 
     self.email = email 

user_tasks = Table('user_tasks', Model.metadata, 
    Column('user_id', Integer, ForeignKey('users.user_id')), 
    Column('task_id', Integer, ForeignKey('tasks.task_id'))) 

class Task(Model): 
    __tablename__ = 'tasks' 
    id = Column('task_id', Integer, primary_key=True) 
    description = Column('description', Text) 
    assigned_to = relationship('User', secondary=user_tasks, backref='tasks') 

    def __init__(self, description): 
     self.description = description 

if __name__ == '__main__': 
    engine = create_engine('sqlite:///:memory:') 
    Model.metadata.create_all(engine) 
    s = Session(engine) 
    the_user = User('user') 
    s.add(the_user) 
    s.commit() 
    assert s.query(User).all() == [the_user] 
    user_task = Task('user_one task') 
    user_task.assigned_to.append(the_user) 
    s.add(user_task) 
    s.commit() 
    assert s.query(Task).all() == [user_task] 
    assert s.query(user_tasks).all() == [(1,1)] 
    s.query(Task).delete() 
    s.commit() 
    assert s.query(Task).all() == [] 
    assert s.query(User).all() == [the_user] 
    assert s.query(user_tasks).all() == [(1,1)] # I was expecting [] . 

उत्तर

12

delete(synchronize_session='evaluate') देखें:

विधि में अजगर संबंधों के व्यापक प्रदान नहीं करता है - यह माना जाता है पर DELETE कि CASCADE किसी भी विदेशी कुंजी संदर्भ जो इसे की आवश्यकता के लिए कॉन्फ़िगर किया गया है। सत्र को समाप्त होने की आवश्यकता है (निर्भर() के बाद स्वचालित रूप से होता है, या निर्भर वस्तुओं की स्थिति के लिए निर्भर वस्तुओं को राज्य को हटाने या हटाने के लिए - अनाथ कैस्केड को सही ढंग से प्रदर्शित करने के अधीन होता है। यह करने के लिए सबसे अच्छा तरीका है विदेशी चालू हटाना कैस्केड पर उपयोग करने के लिए है -

है, SQLAlchemy लगाने के लिए सभी कार्य वस्तुओं को हटा रहे हैं और प्रत्येक पंक्ति user_tasks से हटाए जाने में यह पता लगाने में सक्षम नहीं है कुंजी (MySQL MyISAM तालिकाओं या SQLite के साथ काम करेंगे नहीं विदेशी कुंजी सक्षम न हों तो):

http://docs.sqlalchemy.org/en/latest/core/constraints.html#on-update-and-on-delete

+0

मैं sqlite3 के अपने संस्करण का मानना ​​है (? 3.7.3 मुझे लगता है कि) विदेशी तालिकाओं का समर्थन करता है? क्या मुझे इसे विशेष रूप से चालू करना है? या SQLite3 के साथ काम करने के लिए कोई और तरीका है? – Buttons840

+0

SQLite3 की सुविधा http://sqlite.org/foreignkeys.html पर वर्णित है। यदि आप इसका उपयोग करना चाहते हैं, तो आप SQLAlchemy में एक ईवेंट श्रोता का उपयोग करेंगे ताकि प्रत्येक बार एक नया कनेक्शन बनाया जा सके ("कनेक्ट" ईवेंट) PRAGMA सेट करें। ऐसा करने का दूसरा तरीका है प्रत्येक कार्य ऑब्जेक्ट पर सत्र.डिलीट() का उपयोग करना, एसक्यूएलए "असाइन_to" संबंध बनाए रखने के लिए अतिरिक्त प्रयासों के माध्यम से जाएगा। – zzzeek

+0

लिंक http://docs.sqlalchemy.org/en/latest/core/schema.html#on-update-and-on-delete मान्य है, लेकिन यह एंकर को ऑन-अपडेट-एंड- ऑन-delete'। ऐसा लगता है कि यह खो गया है, साथ ही संस्करण 0.9 और 1.0 में भी। – fedorqui

1

जब मैं अपनी नहीं दे रही है त्रुटि sqlite के साथ अपने कोड की कोशिश की, लेकिन जब, मैं MySQL डाटाबेस के साथ की कोशिश की मैं त्रुटि

2012-03-29 10:43:15,330 INFO sqlalchemy.engine.base.Engine SELECT DATABASE() 
2012-03-29 10:43:15,331 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,332 INFO sqlalchemy.engine.base.Engine SHOW VARIABLES LIKE 'character_set%%' 
2012-03-29 10:43:15,332 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,333 INFO sqlalchemy.engine.base.Engine SHOW VARIABLES LIKE 'lower_case_table_names' 
2012-03-29 10:43:15,333 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,334 INFO sqlalchemy.engine.base.Engine SHOW COLLATION 
2012-03-29 10:43:15,334 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,337 INFO sqlalchemy.engine.base.Engine SHOW VARIABLES LIKE 'sql_mode' 
2012-03-29 10:43:15,338 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,339 INFO sqlalchemy.engine.base.Engine DESCRIBE `user_tasks` 
2012-03-29 10:43:15,339 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,355 INFO sqlalchemy.engine.base.Engine DESCRIBE `users` 
2012-03-29 10:43:15,355 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,356 INFO sqlalchemy.engine.base.Engine DESCRIBE `tasks` 
2012-03-29 10:43:15,356 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,357 INFO sqlalchemy.engine.base.Engine 
DROP TABLE user_tasks 
2012-03-29 10:43:15,357 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,439 INFO sqlalchemy.engine.base.Engine COMMIT 
2012-03-29 10:43:15,440 INFO sqlalchemy.engine.base.Engine 
DROP TABLE users 
2012-03-29 10:43:15,440 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,573 INFO sqlalchemy.engine.base.Engine COMMIT 
2012-03-29 10:43:15,573 INFO sqlalchemy.engine.base.Engine 
DROP TABLE tasks 
2012-03-29 10:43:15,573 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,623 INFO sqlalchemy.engine.base.Engine COMMIT 
2012-03-29 10:43:15,624 INFO sqlalchemy.engine.base.Engine DESCRIBE `tasks` 
2012-03-29 10:43:15,624 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,632 INFO sqlalchemy.engine.base.Engine ROLLBACK 
2012-03-29 10:43:15,633 INFO sqlalchemy.engine.base.Engine DESCRIBE `users` 
2012-03-29 10:43:15,633 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,634 INFO sqlalchemy.engine.base.Engine ROLLBACK 
2012-03-29 10:43:15,634 INFO sqlalchemy.engine.base.Engine DESCRIBE `user_tasks` 
2012-03-29 10:43:15,634 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,635 INFO sqlalchemy.engine.base.Engine ROLLBACK 
2012-03-29 10:43:15,635 INFO sqlalchemy.engine.base.Engine 
CREATE TABLE tasks (
    task_id INTEGER NOT NULL AUTO_INCREMENT, 
    description TEXT, 
    PRIMARY KEY (task_id) 
) 


2012-03-29 10:43:15,635 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,732 INFO sqlalchemy.engine.base.Engine COMMIT 
2012-03-29 10:43:15,733 INFO sqlalchemy.engine.base.Engine 
CREATE TABLE users (
    user_id INTEGER NOT NULL AUTO_INCREMENT, 
    email VARCHAR(20), 
    PRIMARY KEY (user_id), 
    UNIQUE (email) 
) 


2012-03-29 10:43:15,733 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,841 INFO sqlalchemy.engine.base.Engine COMMIT 
2012-03-29 10:43:15,842 INFO sqlalchemy.engine.base.Engine 
CREATE TABLE user_tasks (
    user_id INTEGER, 
    task_id INTEGER, 
    FOREIGN KEY(user_id) REFERENCES users (user_id), 
    FOREIGN KEY(task_id) REFERENCES tasks (task_id) 
) 


2012-03-29 10:43:15,842 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:15,959 INFO sqlalchemy.engine.base.Engine COMMIT 
2012-03-29 10:43:15,964 INFO sqlalchemy.engine.base.Engine BEGIN (implicit) 
2012-03-29 10:43:15,965 INFO sqlalchemy.engine.base.Engine INSERT INTO users (email) VALUES (%s) 
2012-03-29 10:43:15,965 INFO sqlalchemy.engine.base.Engine ('user',) 
2012-03-29 10:43:15,966 INFO sqlalchemy.engine.base.Engine COMMIT 
2012-03-29 10:43:16,010 INFO sqlalchemy.engine.base.Engine BEGIN (implicit) 
2012-03-29 10:43:16,010 INFO sqlalchemy.engine.base.Engine SELECT users.user_id AS users_user_id, users.email AS users_email 
FROM users 
2012-03-29 10:43:16,011 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:16,013 INFO sqlalchemy.engine.base.Engine INSERT INTO tasks (description) VALUES (%s) 
2012-03-29 10:43:16,014 INFO sqlalchemy.engine.base.Engine ('user_one task',) 
2012-03-29 10:43:16,015 INFO sqlalchemy.engine.base.Engine INSERT INTO user_tasks (user_id, task_id) VALUES (%s, %s) 
2012-03-29 10:43:16,016 INFO sqlalchemy.engine.base.Engine (1L, 1L) 
2012-03-29 10:43:16,016 INFO sqlalchemy.engine.base.Engine COMMIT 
2012-03-29 10:43:16,085 INFO sqlalchemy.engine.base.Engine BEGIN (implicit) 
2012-03-29 10:43:16,086 INFO sqlalchemy.engine.base.Engine SELECT tasks.task_id AS tasks_task_id, tasks.description AS tasks_description 
FROM tasks 
2012-03-29 10:43:16,086 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:16,087 INFO sqlalchemy.engine.base.Engine SELECT user_tasks.user_id AS user_tasks_user_id, user_tasks.task_id AS user_tasks_task_id 
FROM user_tasks 
2012-03-29 10:43:16,088 INFO sqlalchemy.engine.base.Engine() 
2012-03-29 10:43:16,089 INFO sqlalchemy.engine.base.Engine SELECT user_tasks.user_id AS user_tasks_user_id, user_tasks.task_id AS user_tasks_task_id 
FROM user_tasks 
2012-03-29 10:43:16,089 INFO sqlalchemy.engine.base.Engine() 
[(1L, 1L)] 
2012-03-29 10:43:16,091 INFO sqlalchemy.engine.base.Engine DELETE FROM tasks 
2012-03-29 10:43:16,091 INFO sqlalchemy.engine.base.Engine() 
Traceback (most recent call last): 
    File "/tmp/test2.py", line 46, in <module> 
    s.query(Task).delete() 
    File "/home/npatel/.local/lib/python2.7/site-packages/sqlalchemy/orm/query.py", line 2283, in delete 
    result = session.execute(delete_stmt, params=self._params) 
    File "/home/npatel/.local/lib/python2.7/site-packages/sqlalchemy/orm/session.py", line 762, in execute 
    clause, params or {}) 
    File "/home/npatel/.local/lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 1399, in execute 
    params) 
    File "/home/npatel/.local/lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 1532, in _execute_clauseelement 
    compiled_sql, distilled_params 
    File "/home/npatel/.local/lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 1640, in _execute_context 
    context) 
    File "/home/npatel/.local/lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 1633, in _execute_context 
    context) 
    File "/home/npatel/.local/lib/python2.7/site-packages/sqlalchemy/engine/default.py", line 325, in do_execute 
    cursor.execute(statement, parameters) 
    File "/usr/lib64/python2.7/site-packages/MySQLdb/cursors.py", line 174, in execute 
    self.errorhandler(self, exc, value) 
    File "/usr/lib64/python2.7/site-packages/MySQLdb/connections.py", line 36, in defaulterrorhandler 
    raise errorclass, errorvalue 
sqlalchemy.exc.IntegrityError: (IntegrityError) (1451, 'Cannot delete or update a parent row: a foreign key constraint fails (`test1`.`user_tasks`, CONSTRAINT `user_tasks_ibfk_2` FOREIGN KEY (`task_id`) REFERENCES `tasks` (`task_id`))') 'DELETE FROM tasks'() 

मिला तो उस के बाद मुझे पता चला कि sqlite विदेशी कुंजी बाधा नहीं बनाए रख आया । अब मैं अपना कोड बदलता हूं और आउटपुट की जांच करता हूं।

from sqlalchemy import create_engine, Column, Integer, Text, Table, ForeignKey, String 
from sqlalchemy.ext.declarative import declarative_base 
from sqlalchemy.orm import Session, relationship 

Model = declarative_base() 


class User(Model): 
    __tablename__ = 'users' 
    id = Column('user_id', Integer, primary_key=True) 
    email = Column('email', String(length=20), unique=True) 

    def __init__(self, email): 
     self.email = email 

user_tasks = Table('user_tasks', Model.metadata, 
    Column('user_id', Integer, ForeignKey('users.user_id')), 
    Column('task_id', Integer, ForeignKey('tasks.task_id'))) 


class Task(Model): 
    __tablename__ = 'tasks' 
    id = Column('task_id', Integer, primary_key=True) 
    description = Column('description', Text) 
    assigned_to = relationship('User', secondary=user_tasks, backref='tasks') 

    def __init__(self, description): 
     self.description = description 

if __name__ == '__main__': 
    engine = create_engine('mysql://test:[email protected]/test', echo=True) 
    Model.metadata.drop_all(engine) 
    Model.metadata.create_all(engine) 
    s = Session(engine) 
    the_user = User('user') 
    s.add(the_user) 
    s.commit() 
    assert s.query(User).all() == [the_user] 
    user_task = Task('user_one task') 
    user_task.assigned_to.append(the_user) 
    s.add(user_task) 
    s.commit() 
    assert s.query(Task).all() == [user_task] 
    assert s.query(user_tasks).all() == [(1, 1)] 
    the_user.tasks = [] 
    s.query(Task).delete() 
    s.commit() 
    assert s.query(Task).all() == [] 
    assert s.query(User).all() == [the_user] 
    assert s.query(user_tasks).all() == [(1,1)] # I was expecting [] . 
संबंधित मुद्दे