@@ -744,6 +744,7 @@ function mixinMigration(PostgreSQL) {
744
744
745
745
// remove indexes
746
746
aiNames . forEach ( function ( indexName ) {
747
+ var schema = self . escapeName ( self . schema ( model ) || 'public' ) ;
747
748
var i = ai [ indexName ] ;
748
749
var propName = propNameRegEx . exec ( indexName ) ;
749
750
var si ; // index definition from model schema
@@ -753,7 +754,7 @@ function mixinMigration(PostgreSQL) {
753
754
propName = propName && self . propertyName ( model , propName [ 1 ] ) || null ;
754
755
if ( ! ( indexNames . indexOf ( indexName ) > - 1 ) && ! ( propName && m . properties [ propName ] &&
755
756
m . properties [ propName ] . index ) ) {
756
- sql . push ( 'DROP INDEX ' + self . escapeName ( indexName ) ) ;
757
+ sql . push ( 'DROP INDEX ' + schema + '.' + self . escapeName ( indexName ) ) ;
757
758
} else {
758
759
// The index was found, verify that database matches what we're expecting.
759
760
// first: check single column indexes.
@@ -765,7 +766,7 @@ function mixinMigration(PostgreSQL) {
765
766
! ( ( ! si . type || si . type === ai [ indexName ] . type ) && ( ! si . unique || si . unique === ai [ indexName ] . unique ) )
766
767
) {
767
768
// Drop the index if the type or unique differs from the actual table
768
- sql . push ( 'DROP INDEX ' + self . escapeName ( indexName ) ) ;
769
+ sql . push ( 'DROP INDEX ' + schema + '.' + self . escapeName ( indexName ) ) ;
769
770
delete ai [ indexName ] ;
770
771
}
771
772
}
@@ -791,7 +792,7 @@ function mixinMigration(PostgreSQL) {
791
792
}
792
793
793
794
if ( ! identical ) {
794
- sql . push ( 'DROP INDEX ' + self . escapeName ( indexName ) ) ;
795
+ sql . push ( 'DROP INDEX ' + schema + '.' + self . escapeName ( indexName ) ) ;
795
796
delete ai [ indexName ] ;
796
797
}
797
798
}
0 commit comments