removed = set()
for idx in list(conn_indexes):
# MySQL puts implicit indexes on FK columns, even if
- # composite and even if MyISAM, so can't check this too easily
- if idx.name == idx.columns.keys()[0]:
- conn_indexes.remove(idx)
- removed.add(idx.name)
+ # composite and even if MyISAM, so can't check this too easily.
+ # the name of the index may be the column name or it may
+ # be the name of the FK constraint.
+ for col in idx.columns:
+ if idx.name == col.name:
+ conn_indexes.remove(idx)
+ removed.add(idx.name)
+ break
+ for fk in col.foreign_keys:
+ if fk.name == idx.name:
+ conn_indexes.remove(idx)
+ removed.add(idx.name)
+ break
# then remove indexes from the "metadata_indexes"
# that we've removed from reflected, otherwise they come out
Numeric, DATETIME, INTEGER, \
TypeDecorator, Unicode, Enum,\
UniqueConstraint, Boolean, \
- PrimaryKeyConstraint, Index, func, ForeignKeyConstraint
-
+ PrimaryKeyConstraint, Index, func, ForeignKeyConstraint,\
+ ForeignKey
+from sqlalchemy.schema import AddConstraint
from . import sqlite_db, eq_, db_for_dialect
py3k = sys.version_info >= (3, )
Table('nothing_changed', m1,
Column('id1', Integer, primary_key=True),
Column('id2', Integer, primary_key=True),
- Column('x', String(20), unique=True)
+ Column('x', String(20), unique=True),
+ mysql_engine='InnoDB'
)
Table('nothing_changed_related', m1,
Column('id1', Integer),
Column('id2', Integer),
ForeignKeyConstraint(['id1', 'id2'],
- ['nothing_changed.id1', 'nothing_changed.id2'])
+ ['nothing_changed.id1', 'nothing_changed.id2']),
+ mysql_engine='InnoDB'
)
Table('nothing_changed', m2,
Column('id1', Integer, primary_key=True),
Column('id2', Integer, primary_key=True),
- Column('x', String(20), unique=True)
+ Column('x', String(20), unique=True),
+ mysql_engine='InnoDB'
)
Table('nothing_changed_related', m2,
Column('id1', Integer),
Column('id2', Integer),
ForeignKeyConstraint(['id1', 'id2'],
- ['nothing_changed.id1', 'nothing_changed.id2'])
+ ['nothing_changed.id1', 'nothing_changed.id2']),
+ mysql_engine='InnoDB'
)
diffs = self._fixture(m1, m2)
eq_(diffs, [])
+
+
def test_nothing_changed_index_named_as_column(self):
m1 = MetaData()
m2 = MetaData()
diffs = self._fixture(m1, m2)
eq_(diffs, [])
+ def test_nothing_changed_implicit_fk_index_named(self):
+ m1 = MetaData()
+ m2 = MetaData()
+
+ Table("nothing_changed", m1,
+ Column('id', Integer, primary_key=True),
+ Column('other_id',
+ ForeignKey('nc2.id',
+ name='fk_my_table_other_table'
+ ),
+ nullable=False),
+ Column('foo', Integer),
+ mysql_engine='InnoDB')
+ Table('nc2', m1,
+ Column('id', Integer, primary_key=True),
+ mysql_engine='InnoDB')
+
+ Table("nothing_changed", m2,
+ Column('id', Integer, primary_key=True),
+ Column('other_id', ForeignKey('nc2.id',
+ name='fk_my_table_other_table'),
+ nullable=False),
+ Column('foo', Integer),
+ mysql_engine='InnoDB')
+ Table('nc2', m2,
+ Column('id', Integer, primary_key=True),
+ mysql_engine='InnoDB')
+ diffs = self._fixture(m1, m2)
+ eq_(diffs, [])
+
def test_new_idx_index_named_as_column(self):
m1 = MetaData()
m2 = MetaData()
reports_unnamed_constraints = True
def test_removed_idx_index_named_as_column(self):
- # TODO: this should be an "assert fails"
- pass
+ try:
+ super(MySQLUniqueIndexTest,
+ self).test_removed_idx_index_named_as_column()
+ except IndexError:
+ assert True
+ else:
+ assert False, "unexpected success"
@classmethod
def _get_bind(cls):