mirror of
https://github.com/mattermost/mattermost.git
synced 2026-03-03 13:51:38 -05:00
9c272f0b20
* Implement AppendFile for FileBackend * Split test into subtests * [MM-26812] Add support for resumable file uploads (#15252) * Implement UploadSession * Implement UploadSessionStore * Add error strings * Implement resumable file uploads * Add UploadType * Fix retry layer tests * Regenerate store layers * Fix store error handling * Use base for filename * Prevent concurrent uploads on the same upload session * Fix erroneus error string * Improve error handling Co-authored-by: Mattermod <mattermod@users.noreply.github.com> * Fix translations Co-authored-by: Mattermod <mattermod@users.noreply.github.com>
106 lines
3.9 KiB
Go
106 lines
3.9 KiB
Go
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
package sqlstore
|
|
|
|
import (
|
|
sq "github.com/Masterminds/squirrel"
|
|
_ "github.com/go-sql-driver/mysql"
|
|
_ "github.com/lib/pq"
|
|
"github.com/mattermost/gorp"
|
|
"github.com/mattermost/mattermost-server/v5/store"
|
|
)
|
|
|
|
/*type SqlStore struct {
|
|
master *gorp.DbMap
|
|
replicas []*gorp.DbMap
|
|
searchReplicas []*gorp.DbMap
|
|
team TeamStore
|
|
channel ChannelStore
|
|
post PostStore
|
|
user UserStore
|
|
audit AuditStore
|
|
compliance ComplianceStore
|
|
session SessionStore
|
|
oauth OAuthStore
|
|
system SystemStore
|
|
webhook WebhookStore
|
|
command CommandStore
|
|
preference PreferenceStore
|
|
license LicenseStore
|
|
token TokenStore
|
|
emoji EmojiStore
|
|
status StatusStore
|
|
fileInfo FileInfoStore
|
|
reaction ReactionStore
|
|
jobStatus JobStatusStore
|
|
SchemaVersion string
|
|
rrCounter int64
|
|
srCounter int64
|
|
}*/
|
|
|
|
type SqlStore interface {
|
|
DriverName() string
|
|
GetCurrentSchemaVersion() string
|
|
GetMaster() *gorp.DbMap
|
|
GetSearchReplica() *gorp.DbMap
|
|
GetReplica() *gorp.DbMap
|
|
GetDbVersion() (string, error)
|
|
TotalMasterDbConnections() int
|
|
TotalReadDbConnections() int
|
|
TotalSearchDbConnections() int
|
|
MarkSystemRanUnitTests()
|
|
DoesTableExist(tablename string) bool
|
|
DoesColumnExist(tableName string, columName string) bool
|
|
DoesTriggerExist(triggerName string) bool
|
|
CreateColumnIfNotExists(tableName string, columnName string, mySqlColType string, postgresColType string, defaultValue string) bool
|
|
CreateColumnIfNotExistsNoDefault(tableName string, columnName string, mySqlColType string, postgresColType string) bool
|
|
RemoveColumnIfExists(tableName string, columnName string) bool
|
|
RemoveTableIfExists(tableName string) bool
|
|
RenameColumnIfExists(tableName string, oldColumnName string, newColumnName string, colType string) bool
|
|
GetMaxLengthOfColumnIfExists(tableName string, columnName string) string
|
|
AlterColumnTypeIfExists(tableName string, columnName string, mySqlColType string, postgresColType string) bool
|
|
AlterColumnDefaultIfExists(tableName string, columnName string, mySqlColDefault *string, postgresColDefault *string) bool
|
|
AlterPrimaryKey(tableName string, columnNames []string) bool
|
|
CreateUniqueIndexIfNotExists(indexName string, tableName string, columnName string) bool
|
|
CreateIndexIfNotExists(indexName string, tableName string, columnName string) bool
|
|
CreateCompositeIndexIfNotExists(indexName string, tableName string, columnNames []string) bool
|
|
CreateUniqueCompositeIndexIfNotExists(indexName string, tableName string, columnNames []string) bool
|
|
CreateFullTextIndexIfNotExists(indexName string, tableName string, columnName string) bool
|
|
RemoveIndexIfExists(indexName string, tableName string) bool
|
|
GetAllConns() []*gorp.DbMap
|
|
Close()
|
|
LockToMaster()
|
|
UnlockFromMaster()
|
|
Team() store.TeamStore
|
|
Channel() store.ChannelStore
|
|
Post() store.PostStore
|
|
User() store.UserStore
|
|
Bot() store.BotStore
|
|
Audit() store.AuditStore
|
|
ClusterDiscovery() store.ClusterDiscoveryStore
|
|
Compliance() store.ComplianceStore
|
|
Session() store.SessionStore
|
|
OAuth() store.OAuthStore
|
|
System() store.SystemStore
|
|
Webhook() store.WebhookStore
|
|
Command() store.CommandStore
|
|
CommandWebhook() store.CommandWebhookStore
|
|
Preference() store.PreferenceStore
|
|
License() store.LicenseStore
|
|
Token() store.TokenStore
|
|
Emoji() store.EmojiStore
|
|
Status() store.StatusStore
|
|
FileInfo() store.FileInfoStore
|
|
UploadSession() store.UploadSessionStore
|
|
Reaction() store.ReactionStore
|
|
Job() store.JobStore
|
|
Plugin() store.PluginStore
|
|
UserAccessToken() store.UserAccessTokenStore
|
|
Role() store.RoleStore
|
|
Scheme() store.SchemeStore
|
|
TermsOfService() store.TermsOfServiceStore
|
|
UserTermsOfService() store.UserTermsOfServiceStore
|
|
LinkMetadata() store.LinkMetadataStore
|
|
getQueryBuilder() sq.StatementBuilderType
|
|
}
|