fix compatibility #1292

This commit is contained in:
袁帆 2019-05-07 13:02:04 +08:00
parent 6a1dd59737
commit 3db4835f1b
1 changed files with 619 additions and 621 deletions

View File

@ -1093,7 +1093,6 @@ func (db *postgres) GetTables() ([]*core.Table, error) {
return tables, nil return tables, nil
} }
func getIndexColName(indexdef string) []string { func getIndexColName(indexdef string) []string {
var colNames []string var colNames []string
@ -1105,7 +1104,6 @@ func getIndexColName(indexdef string) []string {
return colNames return colNames
} }
func (db *postgres) GetIndexes(tableName string) (map[string]*core.Index, error) { func (db *postgres) GetIndexes(tableName string) (map[string]*core.Index, error) {
args := []interface{}{tableName} args := []interface{}{tableName}
s := fmt.Sprintf("SELECT indexname, indexdef FROM pg_indexes WHERE tablename=$1") s := fmt.Sprintf("SELECT indexname, indexdef FROM pg_indexes WHERE tablename=$1")
@ -1131,7 +1129,7 @@ func (db *postgres) GetIndexes(tableName string) (map[string]*core.Index, error)
return nil, err return nil, err
} }
indexName = strings.Trim(indexName, `" `) indexName = strings.Trim(indexName, `" `)
if strings.HasSuffix(indexName, "_pkey") { if strings.HasSuffix(indexName, "_pkey") || strings.HasSuffix(indexName, "primary") {
continue continue
} }
if strings.HasPrefix(indexdef, "CREATE UNIQUE INDEX") { if strings.HasPrefix(indexdef, "CREATE UNIQUE INDEX") {