diff options
| author | Christopher Speller <crspeller@gmail.com> | 2017-10-27 06:02:16 -0700 |
|---|---|---|
| committer | Joram Wilander <jwawilander@gmail.com> | 2017-10-27 09:02:16 -0400 |
| commit | 91b9514aafbefd5c9c10380878bef1b03245d10c (patch) | |
| tree | c6e951101d304c1dfac6d29e50a2a2fe693cf7a1 /store/sqlstore/supplier.go | |
| parent | 1e2506b2dfda87e65aa2f75f1e507046145cd2b8 (diff) | |
| download | chat-91b9514aafbefd5c9c10380878bef1b03245d10c.tar.gz chat-91b9514aafbefd5c9c10380878bef1b03245d10c.tar.bz2 chat-91b9514aafbefd5c9c10380878bef1b03245d10c.zip | |
Adding Posts table indexes for 20M rows. (#7728)
Diffstat (limited to 'store/sqlstore/supplier.go')
| -rw-r--r-- | store/sqlstore/supplier.go | 21 |
1 files changed, 15 insertions, 6 deletions
diff --git a/store/sqlstore/supplier.go b/store/sqlstore/supplier.go index f90639f3e..a90ea6388 100644 --- a/store/sqlstore/supplier.go +++ b/store/sqlstore/supplier.go @@ -547,18 +547,22 @@ func (ss *SqlSupplier) AlterColumnTypeIfExists(tableName string, columnName stri } func (ss *SqlSupplier) CreateUniqueIndexIfNotExists(indexName string, tableName string, columnName string) bool { - return ss.createIndexIfNotExists(indexName, tableName, columnName, INDEX_TYPE_DEFAULT, true) + return ss.createIndexIfNotExists(indexName, tableName, []string{columnName}, INDEX_TYPE_DEFAULT, true) } func (ss *SqlSupplier) CreateIndexIfNotExists(indexName string, tableName string, columnName string) bool { - return ss.createIndexIfNotExists(indexName, tableName, columnName, INDEX_TYPE_DEFAULT, false) + return ss.createIndexIfNotExists(indexName, tableName, []string{columnName}, INDEX_TYPE_DEFAULT, false) +} + +func (ss *SqlSupplier) CreateCompositeIndexIfNotExists(indexName string, tableName string, columnNames []string) bool { + return ss.createIndexIfNotExists(indexName, tableName, columnNames, INDEX_TYPE_DEFAULT, false) } func (ss *SqlSupplier) CreateFullTextIndexIfNotExists(indexName string, tableName string, columnName string) bool { - return ss.createIndexIfNotExists(indexName, tableName, columnName, INDEX_TYPE_FULL_TEXT, false) + return ss.createIndexIfNotExists(indexName, tableName, []string{columnName}, INDEX_TYPE_FULL_TEXT, false) } -func (ss *SqlSupplier) createIndexIfNotExists(indexName string, tableName string, columnName string, indexType string, unique bool) bool { +func (ss *SqlSupplier) createIndexIfNotExists(indexName string, tableName string, columnNames []string, indexType string, unique bool) bool { uniqueStr := "" if unique { @@ -574,10 +578,15 @@ func (ss *SqlSupplier) createIndexIfNotExists(indexName string, tableName string query := "" if indexType == INDEX_TYPE_FULL_TEXT { + if len(columnNames) != 1 { + l4g.Critical("Unable to create multi column full text index") + os.Exit(EXIT_CREATE_INDEX_POSTGRES) + } + columnName := columnNames[0] postgresColumnNames := convertMySQLFullTextColumnsToPostgres(columnName) query = "CREATE INDEX " + indexName + " ON " + tableName + " USING gin(to_tsvector('english', " + postgresColumnNames + "))" } else { - query = "CREATE " + uniqueStr + "INDEX " + indexName + " ON " + tableName + " (" + columnName + ")" + query = "CREATE " + uniqueStr + "INDEX " + indexName + " ON " + tableName + " (" + strings.Join(columnNames, ", ") + ")" } _, err := ss.GetMaster().ExecNoTimeout(query) @@ -605,7 +614,7 @@ func (ss *SqlSupplier) createIndexIfNotExists(indexName string, tableName string fullTextIndex = " FULLTEXT " } - _, err = ss.GetMaster().ExecNoTimeout("CREATE " + uniqueStr + fullTextIndex + " INDEX " + indexName + " ON " + tableName + " (" + columnName + ")") + _, err = ss.GetMaster().ExecNoTimeout("CREATE " + uniqueStr + fullTextIndex + " INDEX " + indexName + " ON " + tableName + " (" + strings.Join(columnNames, ", ") + ")") if err != nil { l4g.Critical(utils.T("store.sql.create_index.critical"), err) time.Sleep(time.Second) |