summaryrefslogtreecommitdiff
path: root/src/mailman/database/tests/test_migrations.py
diff options
context:
space:
mode:
authorAurélien Bompard2015-09-15 11:27:04 +0200
committerBarry Warsaw2015-10-20 21:10:35 -0400
commit0fcb68ac1b88801a9679e00a82d0bdabf86d19d1 (patch)
tree718a3c4710de7901a75ced2dccb65fe3f0db3bc1 /src/mailman/database/tests/test_migrations.py
parent87f2f50b08eb0a7b0a99924b82fd246a6ce10983 (diff)
downloadmailman-0fcb68ac1b88801a9679e00a82d0bdabf86d19d1.tar.gz
mailman-0fcb68ac1b88801a9679e00a82d0bdabf86d19d1.tar.zst
mailman-0fcb68ac1b88801a9679e00a82d0bdabf86d19d1.zip
Diffstat (limited to 'src/mailman/database/tests/test_migrations.py')
-rw-r--r--src/mailman/database/tests/test_migrations.py44
1 files changed, 44 insertions, 0 deletions
diff --git a/src/mailman/database/tests/test_migrations.py b/src/mailman/database/tests/test_migrations.py
index 98d8deb79..d54c525ea 100644
--- a/src/mailman/database/tests/test_migrations.py
+++ b/src/mailman/database/tests/test_migrations.py
@@ -28,6 +28,7 @@ import sqlalchemy as sa
from mailman.config import config
from mailman.database.alembic import alembic_cfg
+from mailman.database.helpers import exists_in_db
from mailman.database.model import Model
from mailman.testing.layers import ConfigLayer
@@ -41,8 +42,17 @@ class TestMigrations(unittest.TestCase):
def tearDown(self):
# Drop and restore a virgin database.
+ config.db.store.rollback()
md = sa.MetaData(bind=config.db.engine)
md.reflect()
+ # We have circular dependencies between user and address, thus we can't
+ # use drop_all() without getting a warning. Setting use_alter to True
+ # on the foreign keys helps SQLAlchemy mark those loops as known.
+ for tablename in ("user", "address"):
+ if tablename not in md.tables:
+ continue
+ for fk in md.tables[tablename].foreign_key_constraints:
+ fk.use_alter = True
md.drop_all()
Model.metadata.create_all(config.db.engine)
@@ -55,3 +65,37 @@ class TestMigrations(unittest.TestCase):
revisions.reverse()
for revision in revisions:
alembic.command.upgrade(alembic_cfg, revision)
+
+ def test_42756496720_header_matches(self):
+ test_header_matches = [
+ ('test-header-1', 'test-pattern-1'),
+ ('test-header-2', 'test-pattern-2'),
+ ('test-header-3', 'test-pattern-3'),
+ ]
+ mlist_table = sa.sql.table('mailinglist',
+ sa.sql.column('id', sa.Integer),
+ sa.sql.column('header_matches', sa.PickleType)
+ )
+ header_match_table = sa.sql.table('headermatch',
+ sa.sql.column('mailing_list_id', sa.Integer),
+ sa.sql.column('header', sa.Unicode),
+ sa.sql.column('pattern', sa.Unicode),
+ )
+ # Downgrading
+ config.db.store.execute(mlist_table.insert().values(id=1))
+ config.db.store.execute(header_match_table.insert().values(
+ [{'mailing_list_id': 1, 'header': hm[0], 'pattern': hm[1]}
+ for hm in test_header_matches]))
+ config.db.store.commit()
+ alembic.command.downgrade(alembic_cfg, '2bb9b382198')
+ results = config.db.store.execute(
+ mlist_table.select()).fetchall()
+ self.assertEqual(results[0].header_matches, test_header_matches)
+ self.assertFalse(exists_in_db(config.db.engine, 'headermatch'))
+ config.db.store.commit()
+ # Upgrading
+ alembic.command.upgrade(alembic_cfg, '42756496720')
+ results = config.db.store.execute(
+ header_match_table.select()).fetchall()
+ self.assertEqual(results,
+ [(1, hm[0], hm[1]) for hm in test_header_matches])