diff options
Diffstat (limited to 'store/sql_job_status_store.go')
| -rw-r--r-- | store/sql_job_status_store.go | 190 |
1 files changed, 0 insertions, 190 deletions
diff --git a/store/sql_job_status_store.go b/store/sql_job_status_store.go deleted file mode 100644 index a87b8267b..000000000 --- a/store/sql_job_status_store.go +++ /dev/null @@ -1,190 +0,0 @@ -// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved. -// See License.txt for license information. - -package store - -import ( - "database/sql" - "net/http" - - "github.com/mattermost/platform/model" -) - -type SqlJobStatusStore struct { - SqlStore -} - -func NewSqlJobStatusStore(sqlStore SqlStore) JobStatusStore { - s := &SqlJobStatusStore{sqlStore} - - for _, db := range sqlStore.GetAllConns() { - table := db.AddTableWithName(model.JobStatus{}, "JobStatuses").SetKeys(false, "Id") - table.ColMap("Id").SetMaxSize(26) - table.ColMap("Type").SetMaxSize(32) - table.ColMap("Status").SetMaxSize(32) - table.ColMap("Data").SetMaxSize(1024) - } - - return s -} - -func (jss SqlJobStatusStore) CreateIndexesIfNotExists() { - jss.CreateIndexIfNotExists("idx_jobstatuses_type", "JobStatuses", "Type") -} - -func (jss SqlJobStatusStore) SaveOrUpdate(status *model.JobStatus) StoreChannel { - storeChannel := make(StoreChannel, 1) - - go func() { - result := StoreResult{} - - if err := jss.GetReplica().SelectOne(&model.JobStatus{}, - `SELECT - * - FROM - JobStatuses - WHERE - Id = :Id`, map[string]interface{}{"Id": status.Id}); err == nil { - if _, err := jss.GetMaster().Update(status); err != nil { - result.Err = model.NewLocAppError("SqlJobStatusStore.SaveOrUpdate", - "store.sql_job_status.update.app_error", nil, "id="+status.Id+", "+err.Error()) - } - } else if err == sql.ErrNoRows { - if err := jss.GetMaster().Insert(status); err != nil { - result.Err = model.NewLocAppError("SqlJobStatusStore.SaveOrUpdate", - "store.sql_job_status.save.app_error", nil, "id="+status.Id+", "+err.Error()) - } - } else { - result.Err = model.NewLocAppError("SqlJobStatusStore.SaveOrUpdate", - "store.sql_job_status.save_or_update.app_error", nil, "id="+status.Id+", "+err.Error()) - } - - if result.Err == nil { - result.Data = status - } - - storeChannel <- result - close(storeChannel) - }() - - return storeChannel -} - -func (jss SqlJobStatusStore) Get(id string) StoreChannel { - storeChannel := make(StoreChannel, 1) - - go func() { - result := StoreResult{} - - var status *model.JobStatus - - if err := jss.GetReplica().SelectOne(&status, - `SELECT - * - FROM - JobStatuses - WHERE - Id = :Id`, map[string]interface{}{"Id": id}); err != nil { - if err == sql.ErrNoRows { - result.Err = model.NewAppError("SqlJobStatusStore.Get", - "store.sql_job_status.get.app_error", nil, "Id="+id+", "+err.Error(), http.StatusNotFound) - } else { - result.Err = model.NewAppError("SqlJobStatusStore.Get", - "store.sql_job_status.get.app_error", nil, "Id="+id+", "+err.Error(), http.StatusInternalServerError) - } - } else { - result.Data = status - } - - storeChannel <- result - close(storeChannel) - }() - - return storeChannel -} - -func (jss SqlJobStatusStore) GetAllByType(jobType string) StoreChannel { - storeChannel := make(StoreChannel, 1) - - go func() { - result := StoreResult{} - - var statuses []*model.JobStatus - - if _, err := jss.GetReplica().Select(&statuses, - `SELECT - * - FROM - JobStatuses - WHERE - Type = :Type`, map[string]interface{}{"Type": jobType}); err != nil { - result.Err = model.NewLocAppError("SqlJobStatusStore.GetAllByType", - "store.sql_job_status.get_all_by_type.app_error", nil, "Type="+jobType+", "+err.Error()) - } else { - result.Data = statuses - } - - storeChannel <- result - close(storeChannel) - }() - - return storeChannel -} - -func (jss SqlJobStatusStore) GetAllByTypePage(jobType string, offset int, limit int) StoreChannel { - storeChannel := make(StoreChannel, 1) - - go func() { - result := StoreResult{} - - var statuses []*model.JobStatus - - if _, err := jss.GetReplica().Select(&statuses, - `SELECT - * - FROM - JobStatuses - WHERE - Type = :Type - ORDER BY - StartAt ASC - LIMIT - :Limit - OFFSET - :Offset`, map[string]interface{}{"Type": jobType, "Limit": limit, "Offset": offset}); err != nil { - result.Err = model.NewLocAppError("SqlJobStatusStore.GetAllByTypePage", - "store.sql_job_status.get_all_by_type_page.app_error", nil, "Type="+jobType+", "+err.Error()) - } else { - result.Data = statuses - } - - storeChannel <- result - close(storeChannel) - }() - - return storeChannel -} - -func (jss SqlJobStatusStore) Delete(id string) StoreChannel { - storeChannel := make(StoreChannel, 1) - - go func() { - result := StoreResult{} - - if _, err := jss.GetReplica().Exec( - `DELETE FROM - JobStatuses - WHERE - Id = :Id`, map[string]interface{}{"Id": id}); err != nil { - result.Err = model.NewLocAppError("SqlJobStatusStore.DeleteByType", - "store.sql_job_status.delete.app_error", nil, "id="+id+", "+err.Error()) - } else { - result.Data = id - } - - storeChannel <- result - close(storeChannel) - }() - - return storeChannel -} |