sqlstore

package
v6.1.6+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 29, 2019 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Index

Constants

View Source
const ContextSessionName = "db-session"
View Source
const MAX_VERSIONS_TO_DELETE = 100

Variables

This section is empty.

Functions

func AddApiKey

func AddApiKey(cmd *m.AddApiKeyCommand) error

func AddDataSource

func AddDataSource(cmd *m.AddDataSourceCommand) error

func AddOrgUser

func AddOrgUser(cmd *m.AddOrgUserCommand) error

func AddTeamMember

func AddTeamMember(cmd *m.AddTeamMemberCommand) error

AddTeamMember adds a user to a team

func ChangeUserPassword

func ChangeUserPassword(cmd *m.ChangeUserPasswordCommand) error

func CreateAlertNotificationCommand

func CreateAlertNotificationCommand(cmd *m.CreateAlertNotificationCommand) error

func CreateDashboardSnapshot

func CreateDashboardSnapshot(cmd *m.CreateDashboardSnapshotCommand) error

func CreateLoginAttempt

func CreateLoginAttempt(cmd *m.CreateLoginAttemptCommand) error

func CreateOrg

func CreateOrg(cmd *m.CreateOrgCommand) error

func CreatePlaylist

func CreatePlaylist(cmd *m.CreatePlaylistCommand) error

func CreateTeam

func CreateTeam(cmd *m.CreateTeamCommand) error

func CreateTempUser

func CreateTempUser(cmd *m.CreateTempUserCommand) error

func CreateUser

func CreateUser(ctx context.Context, cmd *m.CreateUserCommand) error

func DeleteAlertNotification

func DeleteAlertNotification(cmd *m.DeleteAlertNotificationCommand) error

func DeleteAlertNotificationWithUid

func DeleteAlertNotificationWithUid(cmd *m.DeleteAlertNotificationWithUidCommand) error

func DeleteApiKeyCtx

func DeleteApiKeyCtx(ctx context.Context, cmd *m.DeleteApiKeyCommand) error

func DeleteAuthInfo

func DeleteAuthInfo(cmd *m.DeleteAuthInfoCommand) error

func DeleteDashboard

func DeleteDashboard(cmd *m.DeleteDashboardCommand) error

func DeleteDashboardSnapshot

func DeleteDashboardSnapshot(cmd *m.DeleteDashboardSnapshotCommand) error

func DeleteDataSourceById

func DeleteDataSourceById(cmd *m.DeleteDataSourceByIdCommand) error

func DeleteDataSourceByName

func DeleteDataSourceByName(cmd *m.DeleteDataSourceByNameCommand) error

func DeleteExpiredSnapshots

func DeleteExpiredSnapshots(cmd *m.DeleteExpiredSnapshotsCommand) error

DeleteExpiredSnapshots removes snapshots with old expiry dates. SnapShotRemoveExpired is deprecated and should be removed in the future. Snapshot expiry is decided by the user when they share the snapshot.

func DeleteExpiredVersions

func DeleteExpiredVersions(cmd *m.DeleteExpiredVersionsCommand) error

func DeleteOldLoginAttempts

func DeleteOldLoginAttempts(cmd *m.DeleteOldLoginAttemptsCommand) error

func DeleteOrg

func DeleteOrg(cmd *m.DeleteOrgCommand) error

func DeletePlaylist

func DeletePlaylist(cmd *m.DeletePlaylistCommand) error

func DeleteTeam

func DeleteTeam(cmd *m.DeleteTeamCommand) error

DeleteTeam will delete a team, its member and any permissions connected to the team

func DeleteUser

func DeleteUser(cmd *m.DeleteUserCommand) error

func GetAdminStats

func GetAdminStats(query *m.GetAdminStatsQuery) error

func GetAlertById

func GetAlertById(query *m.GetAlertByIdQuery) error

func GetAlertNotifications

func GetAlertNotifications(query *m.GetAlertNotificationsQuery) error

func GetAlertNotificationsWithUid

func GetAlertNotificationsWithUid(query *m.GetAlertNotificationsWithUidQuery) error

func GetAlertNotificationsWithUidToSend

func GetAlertNotificationsWithUidToSend(query *m.GetAlertNotificationsWithUidToSendQuery) error

func GetAlertNotifiersUsageStats

func GetAlertNotifiersUsageStats(ctx context.Context, query *m.GetAlertNotifierUsageStatsQuery) error

func GetAlertStatesForDashboard

func GetAlertStatesForDashboard(query *m.GetAlertStatesForDashboardQuery) error

func GetAlertsByDashboardId2

func GetAlertsByDashboardId2(dashboardId int64, sess *DBSession) ([]*m.Alert, error)

func GetAllAlertNotifications

func GetAllAlertNotifications(query *m.GetAllAlertNotificationsQuery) error

func GetAllAlertQueryHandler

func GetAllAlertQueryHandler(query *m.GetAllAlertsQuery) error

func GetAllDataSources

func GetAllDataSources(query *m.GetAllDataSourcesQuery) error

func GetApiKeyById

func GetApiKeyById(query *m.GetApiKeyByIdQuery) error

func GetApiKeyByName

func GetApiKeyByName(query *m.GetApiKeyByNameQuery) error

func GetApiKeys

func GetApiKeys(query *m.GetApiKeysQuery) error

func GetAuthInfo

func GetAuthInfo(query *m.GetAuthInfoQuery) error

func GetDBHealthQuery

func GetDBHealthQuery(query *m.GetDBHealthQuery) error

func GetDashboard

func GetDashboard(query *m.GetDashboardQuery) error

func GetDashboardAclInfoList

func GetDashboardAclInfoList(query *m.GetDashboardAclInfoListQuery) error

GetDashboardAclInfoList returns a list of permissions for a dashboard. They can be fetched from three different places. 1) Permissions for the dashboard 2) permissions for its parent folder 3) if no specific permissions have been set for the dashboard or its parent folder then get the default permissions

func GetDashboardPermissionsForUser

func GetDashboardPermissionsForUser(query *m.GetDashboardPermissionsForUserQuery) error

GetDashboardPermissionsForUser returns the maximum permission the specified user has for a dashboard(s) The function takes in a list of dashboard ids and the user id and role

func GetDashboardSlugById

func GetDashboardSlugById(query *m.GetDashboardSlugByIdQuery) error

func GetDashboardSnapshot

func GetDashboardSnapshot(query *m.GetDashboardSnapshotQuery) error

func GetDashboardTags

func GetDashboardTags(query *m.GetDashboardTagsQuery) error

func GetDashboardUIDById

func GetDashboardUIDById(query *m.GetDashboardRefByIdQuery) error

func GetDashboardVersion

func GetDashboardVersion(query *m.GetDashboardVersionQuery) error

GetDashboardVersion gets the dashboard version for the given dashboard ID and version number.

func GetDashboardVersions

func GetDashboardVersions(query *m.GetDashboardVersionsQuery) error

GetDashboardVersions gets all dashboard versions for the given dashboard ID.

func GetDashboards

func GetDashboards(query *m.GetDashboardsQuery) error

func GetDashboardsByPluginId

func GetDashboardsByPluginId(query *m.GetDashboardsByPluginIdQuery) error

func GetDashboardsBySlug

func GetDashboardsBySlug(query *m.GetDashboardsBySlugQuery) error

func GetDataSourceAccessStats

func GetDataSourceAccessStats(query *m.GetDataSourceAccessStatsQuery) error

func GetDataSourceById

func GetDataSourceById(query *m.GetDataSourceByIdQuery) error

func GetDataSourceByName

func GetDataSourceByName(query *m.GetDataSourceByNameQuery) error

func GetDataSourceStats

func GetDataSourceStats(query *m.GetDataSourceStatsQuery) error

func GetDataSources

func GetDataSources(query *m.GetDataSourcesQuery) error

func GetGlobalQuotaByTarget

func GetGlobalQuotaByTarget(query *m.GetGlobalQuotaByTargetQuery) error

func GetOrCreateAlertNotificationState

func GetOrCreateAlertNotificationState(ctx context.Context, cmd *m.GetOrCreateNotificationStateQuery) error

func GetOrgById

func GetOrgById(query *m.GetOrgByIdQuery) error

func GetOrgByName

func GetOrgByName(query *m.GetOrgByNameQuery) error

func GetOrgQuotaByTarget

func GetOrgQuotaByTarget(query *m.GetOrgQuotaByTargetQuery) error

func GetOrgQuotas

func GetOrgQuotas(query *m.GetOrgQuotasQuery) error

func GetOrgUsers

func GetOrgUsers(query *m.GetOrgUsersQuery) error

func GetPlaylist

func GetPlaylist(query *m.GetPlaylistByIdQuery) error

func GetPlaylistItem

func GetPlaylistItem(query *m.GetPlaylistItemsByIdQuery) error

func GetPluginSettingById

func GetPluginSettingById(query *m.GetPluginSettingByIdQuery) error

func GetPluginSettings

func GetPluginSettings(query *m.GetPluginSettingsQuery) error

func GetPreferences

func GetPreferences(query *m.GetPreferencesQuery) error

func GetPreferencesWithDefaults

func GetPreferencesWithDefaults(query *m.GetPreferencesWithDefaultsQuery) error

func GetProvisionedDashboardDataQuery

func GetProvisionedDashboardDataQuery(cmd *models.GetProvisionedDashboardDataQuery) error

func GetProvisionedDataByDashboardId

func GetProvisionedDataByDashboardId(cmd *models.IsDashboardProvisionedQuery) error

func GetSignedInUser

func GetSignedInUser(query *m.GetSignedInUserQuery) error

func GetSystemStats

func GetSystemStats(query *m.GetSystemStatsQuery) error

func GetSystemUserCountStats

func GetSystemUserCountStats(ctx context.Context, query *m.GetSystemUserCountStatsQuery) error

func GetTeamById

func GetTeamById(query *m.GetTeamByIdQuery) error

func GetTeamMembers

func GetTeamMembers(query *m.GetTeamMembersQuery) error

GetTeamMembers return a list of members for the specified team

func GetTeamsByUser

func GetTeamsByUser(query *m.GetTeamsByUserQuery) error

GetTeamsByUser is used by the Guardian when checking a users' permissions

func GetTempUserByCode

func GetTempUserByCode(query *m.GetTempUserByCodeQuery) error

func GetTempUsersQuery

func GetTempUsersQuery(query *m.GetTempUsersQuery) error

func GetUserByAuthInfo

func GetUserByAuthInfo(query *m.GetUserByAuthInfoQuery) error

func GetUserByEmail

func GetUserByEmail(query *m.GetUserByEmailQuery) error

func GetUserById

func GetUserById(query *m.GetUserByIdQuery) error

func GetUserByLogin

func GetUserByLogin(query *m.GetUserByLoginQuery) error

func GetUserLoginAttemptCount

func GetUserLoginAttemptCount(query *m.GetUserLoginAttemptCountQuery) error

func GetUserOrgList

func GetUserOrgList(query *m.GetUserOrgListQuery) error

func GetUserProfile

func GetUserProfile(query *m.GetUserProfileQuery) error

func GetUserQuotaByTarget

func GetUserQuotaByTarget(query *m.GetUserQuotaByTargetQuery) error

func GetUserQuotas

func GetUserQuotas(query *m.GetUserQuotasQuery) error

func GetUserStars

func GetUserStars(query *m.GetUserStarsQuery) error

func HandleAlertsQuery

func HandleAlertsQuery(query *m.GetAlertsQuery) error

func HasEditPermissionInFolders

func HasEditPermissionInFolders(query *m.HasEditPermissionInFoldersQuery) error

func InsertSqlTestData

func InsertSqlTestData(cmd *m.InsertSqlTestDataCommand) error

func IsStarredByUser

func IsStarredByUser(query *m.IsStarredByUserQuery) error

func IsTestDbMySql

func IsTestDbMySql() bool

func IsTestDbPostgres

func IsTestDbPostgres() bool

func PauseAlert

func PauseAlert(cmd *m.PauseAlertCommand) error

func PauseAllAlerts

func PauseAllAlerts(cmd *m.PauseAllAlertCommand) error

func RemoveOrgUser

func RemoveOrgUser(cmd *m.RemoveOrgUserCommand) error

func RemoveTeamMember

func RemoveTeamMember(cmd *m.RemoveTeamMemberCommand) error

RemoveTeamMember removes a member from a team

func SaveAlerts

func SaveAlerts(cmd *m.SaveAlertsCommand) error

func SaveDashboard

func SaveDashboard(cmd *m.SaveDashboardCommand) error

func SavePreferences

func SavePreferences(cmd *m.SavePreferencesCommand) error

func SaveProvisionedDashboard

func SaveProvisionedDashboard(cmd *models.SaveProvisionedDashboardCommand) error

func SearchDashboardSnapshots

func SearchDashboardSnapshots(query *m.GetDashboardSnapshotsQuery) error

SearchDashboardSnapshots returns a list of all snapshots for admins for other roles, it returns snapshots created by the user

func SearchDashboards

func SearchDashboards(query *search.FindPersistedDashboardsQuery) error

func SearchOrgs

func SearchOrgs(query *m.SearchOrgsQuery) error

func SearchPlaylists

func SearchPlaylists(query *m.GetPlaylistsQuery) error

func SearchTeams

func SearchTeams(query *m.SearchTeamsQuery) error

func SearchUsers

func SearchUsers(query *m.SearchUsersQuery) error

func SetAlertNotificationStateToCompleteCommand

func SetAlertNotificationStateToCompleteCommand(ctx context.Context, cmd *m.SetAlertNotificationStateToCompleteCommand) error

func SetAlertNotificationStateToPendingCommand

func SetAlertNotificationStateToPendingCommand(ctx context.Context, cmd *m.SetAlertNotificationStateToPendingCommand) error

func SetAlertState

func SetAlertState(cmd *m.SetAlertStateCommand) error

func SetAuthInfo

func SetAuthInfo(cmd *m.SetAuthInfoCommand) error

func SetUserHelpFlag

func SetUserHelpFlag(cmd *m.SetUserHelpFlagCommand) error

func SetUsingOrg

func SetUsingOrg(cmd *m.SetUsingOrgCommand) error

func StarDashboard

func StarDashboard(cmd *m.StarDashboardCommand) error

func UnstarDashboard

func UnstarDashboard(cmd *m.UnstarDashboardCommand) error

func UpdateAlertNotification

func UpdateAlertNotification(cmd *m.UpdateAlertNotificationCommand) error

func UpdateAlertNotificationWithUid

func UpdateAlertNotificationWithUid(cmd *m.UpdateAlertNotificationWithUidCommand) error

func UpdateAuthInfo

func UpdateAuthInfo(cmd *m.UpdateAuthInfoCommand) error

func UpdateDashboardAcl

func UpdateDashboardAcl(cmd *m.UpdateDashboardAclCommand) error

func UpdateDataSource

func UpdateDataSource(cmd *m.UpdateDataSourceCommand) error

func UpdateOrg

func UpdateOrg(cmd *m.UpdateOrgCommand) error

func UpdateOrgAddress

func UpdateOrgAddress(cmd *m.UpdateOrgAddressCommand) error

func UpdateOrgQuota

func UpdateOrgQuota(cmd *m.UpdateOrgQuotaCmd) error

func UpdateOrgUser

func UpdateOrgUser(cmd *m.UpdateOrgUserCommand) error

func UpdatePlaylist

func UpdatePlaylist(cmd *m.UpdatePlaylistCommand) error

func UpdatePluginSetting

func UpdatePluginSetting(cmd *m.UpdatePluginSettingCmd) error

func UpdatePluginSettingVersion

func UpdatePluginSettingVersion(cmd *m.UpdatePluginSettingVersionCmd) error

func UpdateTeam

func UpdateTeam(cmd *m.UpdateTeamCommand) error

func UpdateTeamMember

func UpdateTeamMember(cmd *m.UpdateTeamMemberCommand) error

UpdateTeamMember updates a team member

func UpdateTempUserStatus

func UpdateTempUserStatus(cmd *m.UpdateTempUserStatusCommand) error

func UpdateTempUserWithEmailSent

func UpdateTempUserWithEmailSent(cmd *m.UpdateTempUserWithEmailSentCommand) error

func UpdateUser

func UpdateUser(cmd *m.UpdateUserCommand) error

func UpdateUserLastSeenAt

func UpdateUserLastSeenAt(cmd *m.UpdateUserLastSeenAtCommand) error

func UpdateUserPermissions

func UpdateUserPermissions(cmd *m.UpdateUserPermissionsCommand) error

func UpdateUserQuota

func UpdateUserQuota(cmd *m.UpdateUserQuotaCmd) error

func ValidateDashboardBeforeSave

func ValidateDashboardBeforeSave(cmd *m.ValidateDashboardBeforeSaveCommand) (err error)

Types

type DBSession

type DBSession struct {
	*xorm.Session
	// contains filtered or unexported fields
}

func (*DBSession) InsertId

func (sess *DBSession) InsertId(bean interface{}) (int64, error)

type DashboardExtras

type DashboardExtras struct {
	Id          int64
	DashboardId int64
	Key         string
	Value       string
}

type DashboardSearchProjection

type DashboardSearchProjection struct {
	Id          int64
	Uid         string
	Title       string
	Slug        string
	Term        string
	IsFolder    bool
	FolderId    int64
	FolderUid   string
	FolderSlug  string
	FolderTitle string
}

type DashboardSlugDTO

type DashboardSlugDTO struct {
	Slug string
}

type DashboardTag

type DashboardTag struct {
	Id          int64
	DashboardId int64
	Term        string
}

type DatabaseConfig

type DatabaseConfig struct {
	Type             string
	Host             string
	Name             string
	User             string
	Pwd              string
	Path             string
	SslMode          string
	CaCertPath       string
	ClientKeyPath    string
	ClientCertPath   string
	ServerCertName   string
	ConnectionString string
	MaxOpenConn      int
	MaxIdleConn      int
	ConnMaxLifetime  int
	CacheMode        string
	UrlQueryParams   map[string][]string
}

type SearchBuilder

type SearchBuilder struct {
	SqlBuilder
	// contains filtered or unexported fields
}

SearchBuilder is a builder/object mother that builds a dashboard search query

func NewSearchBuilder

func NewSearchBuilder(signedInUser *m.SignedInUser, limit int, permission m.PermissionType) *SearchBuilder

func (*SearchBuilder) IsStarred

func (sb *SearchBuilder) IsStarred() *SearchBuilder

func (*SearchBuilder) ToSql

func (sb *SearchBuilder) ToSql() (string, []interface{})

ToSql builds the sql and returns it as a string, together with the params.

func (*SearchBuilder) WithDashboardIdsIn

func (sb *SearchBuilder) WithDashboardIdsIn(ids []int64) *SearchBuilder

func (*SearchBuilder) WithFolderIds

func (sb *SearchBuilder) WithFolderIds(folderIds []int64) *SearchBuilder

func (*SearchBuilder) WithTags

func (sb *SearchBuilder) WithTags(tags []string) *SearchBuilder

func (*SearchBuilder) WithTitle

func (sb *SearchBuilder) WithTitle(title string) *SearchBuilder

func (*SearchBuilder) WithType

func (sb *SearchBuilder) WithType(queryType string) *SearchBuilder

type SqlAnnotationRepo

type SqlAnnotationRepo struct {
}

func (*SqlAnnotationRepo) Delete

func (r *SqlAnnotationRepo) Delete(params *annotations.DeleteParams) error

func (*SqlAnnotationRepo) Find

func (*SqlAnnotationRepo) Save

func (r *SqlAnnotationRepo) Save(item *annotations.Item) error

func (*SqlAnnotationRepo) Update

func (r *SqlAnnotationRepo) Update(item *annotations.Item) error

type SqlBuilder

type SqlBuilder struct {
	// contains filtered or unexported fields
}

func (*SqlBuilder) AddParams

func (sb *SqlBuilder) AddParams(params ...interface{})

func (*SqlBuilder) GetSqlString

func (sb *SqlBuilder) GetSqlString() string

func (*SqlBuilder) Write

func (sb *SqlBuilder) Write(sql string, params ...interface{})

type SqlStore

type SqlStore struct {
	Cfg          *setting.Cfg        `inject:""`
	Bus          bus.Bus             `inject:""`
	CacheService *cache.CacheService `inject:""`

	Dialect migrator.Dialect
	// contains filtered or unexported fields
}

func InitTestDB

func InitTestDB(t *testing.T) *SqlStore

func (*SqlStore) GetSignedInUserWithCache

func (ss *SqlStore) GetSignedInUserWithCache(query *m.GetSignedInUserQuery) error

func (*SqlStore) InTransaction

func (ss *SqlStore) InTransaction(ctx context.Context, fn func(ctx context.Context) error) error

func (*SqlStore) Init

func (ss *SqlStore) Init() error

func (*SqlStore) NewSession

func (ss *SqlStore) NewSession() *DBSession

NewSession returns a new DBSession

func (*SqlStore) WithDbSession

func (ss *SqlStore) WithDbSession(ctx context.Context, callback dbTransactionFunc) error

WithDbSession calls the callback with an session attached to the context.

func (*SqlStore) WithTransactionalDbSession

func (ss *SqlStore) WithTransactionalDbSession(ctx context.Context, callback dbTransactionFunc) error

WithTransactionalDbSession calls the callback with an session within a transaction

type XormLogger

type XormLogger struct {
	// contains filtered or unexported fields
}

func NewXormLogger

func NewXormLogger(level glog.Lvl, grafanaLog glog.Logger) *XormLogger

func (*XormLogger) Debug

func (s *XormLogger) Debug(v ...interface{})

Debug implement core.ILogger

func (*XormLogger) Debugf

func (s *XormLogger) Debugf(format string, v ...interface{})

Debugf implement core.ILogger

func (*XormLogger) Error

func (s *XormLogger) Error(v ...interface{})

Error implement core.ILogger

func (*XormLogger) Errorf

func (s *XormLogger) Errorf(format string, v ...interface{})

Errorf implement core.ILogger

func (*XormLogger) Info

func (s *XormLogger) Info(v ...interface{})

Info implement core.ILogger

func (*XormLogger) Infof

func (s *XormLogger) Infof(format string, v ...interface{})

Infof implement core.ILogger

func (*XormLogger) IsShowSQL

func (s *XormLogger) IsShowSQL() bool

IsShowSQL implement core.ILogger

func (*XormLogger) Level

func (s *XormLogger) Level() core.LogLevel

Level implement core.ILogger

func (*XormLogger) SetLevel

func (s *XormLogger) SetLevel(l core.LogLevel)

SetLevel implement core.ILogger

func (*XormLogger) ShowSQL

func (s *XormLogger) ShowSQL(show ...bool)

ShowSQL implement core.ILogger

func (*XormLogger) Warn

func (s *XormLogger) Warn(v ...interface{})

Warn implement core.ILogger

func (*XormLogger) Warnf

func (s *XormLogger) Warnf(format string, v ...interface{})

Warnf implement core.ILogger

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL