From 5fdb8223fc23a12945c00a66edbfc6ef299320f9 Mon Sep 17 00:00:00 2001 From: enahum Date: Mon, 24 Oct 2016 17:05:27 -0300 Subject: Add database indexes to timestamp columns (#4314) * Add database indexes to timestamp columns * add indexes to session table --- store/sql_channel_store.go | 3 +++ store/sql_command_store.go | 3 +++ store/sql_emoji_store.go | 3 +++ store/sql_file_info_store.go | 3 +++ store/sql_post_store.go | 1 + store/sql_session_store.go | 3 +++ store/sql_team_store.go | 4 ++++ store/sql_user_store.go | 3 +++ store/sql_webhook_store.go | 8 ++++++++ 9 files changed, 31 insertions(+) (limited to 'store') diff --git a/store/sql_channel_store.go b/store/sql_channel_store.go index a860fea73..f863d57fd 100644 --- a/store/sql_channel_store.go +++ b/store/sql_channel_store.go @@ -54,6 +54,9 @@ func NewSqlChannelStore(sqlStore *SqlStore) ChannelStore { func (s SqlChannelStore) CreateIndexesIfNotExists() { s.CreateIndexIfNotExists("idx_channels_team_id", "Channels", "TeamId") s.CreateIndexIfNotExists("idx_channels_name", "Channels", "Name") + s.CreateIndexIfNotExists("idx_channels_update_at", "Channels", "UpdateAt") + s.CreateIndexIfNotExists("idx_channels_create_at", "Channels", "CreateAt") + s.CreateIndexIfNotExists("idx_channels_delete_at", "Channels", "DeleteAt") s.CreateIndexIfNotExists("idx_channelmembers_channel_id", "ChannelMembers", "ChannelId") s.CreateIndexIfNotExists("idx_channelmembers_user_id", "ChannelMembers", "UserId") diff --git a/store/sql_command_store.go b/store/sql_command_store.go index 410f9a287..0db0ba98e 100644 --- a/store/sql_command_store.go +++ b/store/sql_command_store.go @@ -36,6 +36,9 @@ func NewSqlCommandStore(sqlStore *SqlStore) CommandStore { func (s SqlCommandStore) CreateIndexesIfNotExists() { s.CreateIndexIfNotExists("idx_command_team_id", "Commands", "TeamId") + s.CreateIndexIfNotExists("idx_command_update_at", "Commands", "UpdateAt") + s.CreateIndexIfNotExists("idx_command_create_at", "Commands", "CreateAt") + s.CreateIndexIfNotExists("idx_command_delete_at", "Commands", "DeleteAt") } func (s SqlCommandStore) Save(command *model.Command) StoreChannel { diff --git a/store/sql_emoji_store.go b/store/sql_emoji_store.go index 85fd1a80d..f9218d8d7 100644 --- a/store/sql_emoji_store.go +++ b/store/sql_emoji_store.go @@ -27,6 +27,9 @@ func NewSqlEmojiStore(sqlStore *SqlStore) EmojiStore { } func (es SqlEmojiStore) CreateIndexesIfNotExists() { + es.CreateIndexIfNotExists("idx_emoji_update_at", "Emoji", "UpdateAt") + es.CreateIndexIfNotExists("idx_emoji_create_at", "Emoji", "CreateAt") + es.CreateIndexIfNotExists("idx_emoji_delete_at", "Emoji", "DeleteAt") } func (es SqlEmojiStore) Save(emoji *model.Emoji) StoreChannel { diff --git a/store/sql_file_info_store.go b/store/sql_file_info_store.go index 78c36c08a..426ec5c76 100644 --- a/store/sql_file_info_store.go +++ b/store/sql_file_info_store.go @@ -30,6 +30,9 @@ func NewSqlFileInfoStore(sqlStore *SqlStore) FileInfoStore { } func (fs SqlFileInfoStore) CreateIndexesIfNotExists() { + fs.CreateIndexIfNotExists("idx_fileinfo_update_at", "FileInfo", "UpdateAt") + fs.CreateIndexIfNotExists("idx_fileinfo_create_at", "FileInfo", "CreateAt") + fs.CreateIndexIfNotExists("idx_fileinfo_delete_at", "FileInfo", "DeleteAt") } func (fs SqlFileInfoStore) Save(info *model.FileInfo) StoreChannel { diff --git a/store/sql_post_store.go b/store/sql_post_store.go index 05e298ed3..51cf042b5 100644 --- a/store/sql_post_store.go +++ b/store/sql_post_store.go @@ -41,6 +41,7 @@ func NewSqlPostStore(sqlStore *SqlStore) PostStore { func (s SqlPostStore) CreateIndexesIfNotExists() { s.CreateIndexIfNotExists("idx_posts_update_at", "Posts", "UpdateAt") s.CreateIndexIfNotExists("idx_posts_create_at", "Posts", "CreateAt") + s.CreateIndexIfNotExists("idx_posts_delete_at", "Posts", "DeleteAt") s.CreateIndexIfNotExists("idx_posts_channel_id", "Posts", "ChannelId") s.CreateIndexIfNotExists("idx_posts_root_id", "Posts", "RootId") s.CreateIndexIfNotExists("idx_posts_user_id", "Posts", "UserId") diff --git a/store/sql_session_store.go b/store/sql_session_store.go index 9a377239a..4e1bea3cf 100644 --- a/store/sql_session_store.go +++ b/store/sql_session_store.go @@ -32,6 +32,9 @@ func NewSqlSessionStore(sqlStore *SqlStore) SessionStore { func (me SqlSessionStore) CreateIndexesIfNotExists() { me.CreateIndexIfNotExists("idx_sessions_user_id", "Sessions", "UserId") me.CreateIndexIfNotExists("idx_sessions_token", "Sessions", "Token") + me.CreateIndexIfNotExists("idx_sessions_expires_at", "Sessions", "ExpiresAt") + me.CreateIndexIfNotExists("idx_sessions_create_at", "Sessions", "CreateAt") + me.CreateIndexIfNotExists("idx_sessions_last_activity_at", "Sessions", "LastActivityAt") } func (me SqlSessionStore) Save(session *model.Session) StoreChannel { diff --git a/store/sql_team_store.go b/store/sql_team_store.go index 7addb980e..cc425ccf6 100644 --- a/store/sql_team_store.go +++ b/store/sql_team_store.go @@ -44,9 +44,13 @@ func NewSqlTeamStore(sqlStore *SqlStore) TeamStore { func (s SqlTeamStore) CreateIndexesIfNotExists() { s.CreateIndexIfNotExists("idx_teams_name", "Teams", "Name") s.CreateIndexIfNotExists("idx_teams_invite_id", "Teams", "InviteId") + s.CreateIndexIfNotExists("idx_teams_update_at", "Teams", "UpdateAt") + s.CreateIndexIfNotExists("idx_teams_create_at", "Teams", "CreateAt") + s.CreateIndexIfNotExists("idx_teams_delete_at", "Teams", "DeleteAt") s.CreateIndexIfNotExists("idx_teammembers_team_id", "TeamMembers", "TeamId") s.CreateIndexIfNotExists("idx_teammembers_user_id", "TeamMembers", "UserId") + s.CreateIndexIfNotExists("idx_teammembers_delete_at", "TeamMembers", "DeleteAt") } func (s SqlTeamStore) Save(team *model.Team) StoreChannel { diff --git a/store/sql_user_store.go b/store/sql_user_store.go index 7904bdbfe..c1fb9b28d 100644 --- a/store/sql_user_store.go +++ b/store/sql_user_store.go @@ -55,6 +55,9 @@ func NewSqlUserStore(sqlStore *SqlStore) UserStore { func (us SqlUserStore) CreateIndexesIfNotExists() { us.CreateIndexIfNotExists("idx_users_email", "Users", "Email") + us.CreateIndexIfNotExists("idx_users_update_at", "Users", "UpdateAt") + us.CreateIndexIfNotExists("idx_users_create_at", "Users", "CreateAt") + us.CreateIndexIfNotExists("idx_users_delete_at", "Users", "DeleteAt") us.CreateFullTextIndexIfNotExists("idx_users_username_txt", "Users", USER_SEARCH_TYPE_USERNAME) us.CreateFullTextIndexIfNotExists("idx_users_all_names_txt", "Users", USER_SEARCH_TYPE_ALL) diff --git a/store/sql_webhook_store.go b/store/sql_webhook_store.go index 7c267064b..1e1740796 100644 --- a/store/sql_webhook_store.go +++ b/store/sql_webhook_store.go @@ -44,6 +44,14 @@ func (s SqlWebhookStore) CreateIndexesIfNotExists() { s.CreateIndexIfNotExists("idx_incoming_webhook_user_id", "IncomingWebhooks", "UserId") s.CreateIndexIfNotExists("idx_incoming_webhook_team_id", "IncomingWebhooks", "TeamId") s.CreateIndexIfNotExists("idx_outgoing_webhook_team_id", "OutgoingWebhooks", "TeamId") + + s.CreateIndexIfNotExists("idx_incoming_webhook_update_at", "IncomingWebhooks", "UpdateAt") + s.CreateIndexIfNotExists("idx_incoming_webhook_create_at", "IncomingWebhooks", "CreateAt") + s.CreateIndexIfNotExists("idx_incoming_webhook_delete_at", "IncomingWebhooks", "DeleteAt") + + s.CreateIndexIfNotExists("idx_outgoing_webhook_update_at", "OutgoingWebhooks", "UpdateAt") + s.CreateIndexIfNotExists("idx_outgoing_webhook_create_at", "OutgoingWebhooks", "CreateAt") + s.CreateIndexIfNotExists("idx_outgoing_webhook_delete_at", "OutgoingWebhooks", "DeleteAt") } func (s SqlWebhookStore) SaveIncoming(webhook *model.IncomingWebhook) StoreChannel { -- cgit v1.2.3-1-g7c22