mysql_db

package

Go to main page

Versions in this module

v0

v0.20.0

May 13, 2025

Changes in this version

type MySQLDb

+ func (db *MySQLDb) AddEphemeralSuperUser(ed *Editor, username string, host string, password string)

+ func (db *MySQLDb) AddLockedSuperUser(ed *Editor, username string, host string, password string)

type ReplicaSourceInfo

+ Ssl bool

type User

+ IsEphemeral bool

v0.19.0

Dec 19, 2024

Changes in this version

+ const DefaultAuthMethod

type MySQLDb

+ func (as MySQLDb) AuthMethods() []mysql.AuthMethod

+ func (db MySQLDb) DefaultAuthMethodDescription() mysql.AuthMethodDescription

type User

+ AuthString string

v0.18.1

Apr 9, 2024

v0.18.0

Feb 28, 2024

Changes in this version

+ func NewUserProcsIndexedSetTable(set in_mem_table.IndexedSet[*User], lock, rlock sync.Locker) *in_mem_table.MultiIndexedSetTable[*User]

+ func UserToProcsPrivRows(ctx *sql.Context, user *User) ([]sql.Row, error)

type MySQLDb

+ func (db *MySQLDb) RoutineAdminCheck(ctx *sql.Context, operations ...sql.PrivilegedOperation) bool

type PrivilegeSet

+ func (ps PrivilegeSet) AddRoutine(dbName string, procName string, isProc bool, privileges ...sql.PrivilegeType)

+ func (ps PrivilegeSet) ClearRoutine(dbName string, procName string, isProc bool)

+ func (ps PrivilegeSet) RemoveRoutine(dbName string, procName string, isProc bool, privileges ...sql.PrivilegeType)

type PrivilegeSetColumn

+ func (ps PrivilegeSetColumn) HasPrivileges() bool

type PrivilegeSetDatabase

+ func (ps PrivilegeSetDatabase) GetRoutines() []sql.PrivilegeSetRoutine

+ func (ps PrivilegeSetDatabase) Routine(routineName string, isProc bool) sql.PrivilegeSetRoutine

+ type PrivilegeSetRoutine struct

+ func (ps PrivilegeSetRoutine) Count() int

+ func (ps PrivilegeSetRoutine) Equals(otherPs sql.PrivilegeSetRoutine) bool

+ func (ps PrivilegeSetRoutine) Has(privileges ...sql.PrivilegeType) bool

+ func (ps PrivilegeSetRoutine) HasPrivileges() bool

+ func (ps PrivilegeSetRoutine) RoutineName() string

+ func (ps PrivilegeSetRoutine) RoutineType() string

+ func (ps PrivilegeSetRoutine) ToSlice() []sql.PrivilegeType

type PrivilegedDatabase

+ func (pdb PrivilegedDatabase) NeedsToReloadEvents(ctx *sql.Context, token interface{}) (bool, error)

+ func (pdb PrivilegedDatabase) UpdateLastExecuted(ctx *sql.Context, eventName string, lastExecuted time.Time) error

type User

+ func UserAddProcsPrivRow(ctx *sql.Context, row sql.Row, user *User) (*User, error)

+ func UserFromProcsPrivRow(ctx *sql.Context, row sql.Row) (*User, error)

+ func UserRemoveProcsPrivRow(ctx *sql.Context, row sql.Row, user *User) (*User, error)

v0.17.0

Aug 23, 2023

Changes in this version

+ var ReplicaSourceInfoOps = in_mem_table.ValueOps[*ReplicaSourceInfo]

+ var RoleEdgeOps = in_mem_table.ValueOps[*RoleEdge]

+ var UserOps = in_mem_table.ValueOps[*User]

+ func NewReplicaSourceInfoIndexedSetTable(lock, rlock sync.Locker) *in_mem_table.IndexedSetTable[*ReplicaSourceInfo]

+ func NewRoleEdgesIndexedSetTable(lock, rlock sync.Locker) *in_mem_table.IndexedSetTable[*RoleEdge]

+ func NewUserDBIndexedSetTable(set in_mem_table.IndexedSet[*User], lock, rlock sync.Locker) *in_mem_table.MultiIndexedSetTable[*User]

+ func NewUserGlobalGrantsIndexedSetTable(set in_mem_table.IndexedSet[*User], lock, rlock sync.Locker) *in_mem_table.MultiIndexedSetTable[*User]

+ func NewUserIndexedSetTable(lock, rlock sync.Locker) (in_mem_table.IndexedSet[*User], *in_mem_table.IndexedSetTable[*User])

+ func NewUserTablesIndexedSetTable(set in_mem_table.IndexedSet[*User], lock, rlock sync.Locker) *in_mem_table.MultiIndexedSetTable[*User]

+ func ReplicaSourceInfoEquals(left, right *ReplicaSourceInfo) bool

+ func ReplicaSourceInfoToRow(ctx *sql.Context, v *ReplicaSourceInfo) (sql.Row, error)

+ func RoleEdgeEquals(left, right *RoleEdge) bool

+ func RoleEdgeToRow(ctx *sql.Context, r *RoleEdge) (sql.Row, error)

+ func UserEquals(left, right *User) bool

+ func UserToDBRows(ctx *sql.Context, u *User) ([]sql.Row, error)

+ func UserToGlobalGrantsRows(ctx *sql.Context, user *User) ([]sql.Row, error)

+ func UserToRow(ctx *sql.Context, u *User) (sql.Row, error)

+ func UserToTablesRows(ctx *sql.Context, user *User) ([]sql.Row, error)

+ type Editor struct

+ func (ed *Editor) Close()

+ func (ed *Editor) GetReplicaSourceInfo(k ReplicaSourceInfoPrimaryKey) (res *ReplicaSourceInfo, ok bool)

+ func (ed *Editor) GetToUserRoleEdges(key RoleEdgesToKey) []*RoleEdge

+ func (ed *Editor) GetUser(u UserPrimaryKey) (res *User, ok bool)

+ func (ed *Editor) GetUsersByUsername(username string) []*User

+ func (ed *Editor) PutReplicaSourceInfo(rsi *ReplicaSourceInfo)

+ func (ed *Editor) PutRoleEdge(re *RoleEdge)

+ func (ed *Editor) PutUser(u *User)

+ func (ed *Editor) RemoveReplicaSourceInfo(k ReplicaSourceInfoPrimaryKey)

+ func (ed *Editor) RemoveRoleEdge(pk RoleEdgesPrimaryKey)

+ func (ed *Editor) RemoveRoleEdgesFromKey(key RoleEdgesFromKey)

+ func (ed *Editor) RemoveRoleEdgesToKey(key RoleEdgesToKey)

+ func (ed *Editor) RemoveUser(pk UserPrimaryKey)

+ func (ed *Editor) VisitReplicaSourceInfos(cb func(*ReplicaSourceInfo))

+ func (ed *Editor) VisitRoleEdges(cb func(*RoleEdge))

+ func (ed *Editor) VisitUsers(cb func(*User))

type MySQLDb

+ func (db *MySQLDb) Editor() *Editor

+ func (db *MySQLDb) OverwriteUsersAndGrantData(ctx *sql.Context, ed *Editor, buf []byte) (err error)

+ func (db *MySQLDb) Reader() *Reader

+ func (db *MySQLDb) SetEnabled(v bool)

type PrivilegeSet

+ func UserRowToPrivSet(ctx *sql.Context, row sql.Row) PrivilegeSet

type PrivilegedDatabase

+ func (pdb PrivilegedDatabase) CreateFulltextTableNames(ctx *sql.Context, parentTable string, parentIndexName string) (fulltext.IndexTableNames, error)

+ type Reader struct

+ func (r *Reader) Close()

+ func (r *Reader) GetReplicaSourceInfo(k ReplicaSourceInfoPrimaryKey) (res *ReplicaSourceInfo, ok bool)

+ func (r *Reader) GetToUserRoleEdges(key RoleEdgesToKey) []*RoleEdge

+ func (r *Reader) GetUser(u UserPrimaryKey) (res *User, ok bool)

+ func (r *Reader) GetUsersByUsername(username string) []*User

+ func (r *Reader) VisitReplicaSourceInfos(cb func(*ReplicaSourceInfo))

+ func (r *Reader) VisitRoleEdges(cb func(*RoleEdge))

+ func (r *Reader) VisitUsers(cb func(*User))

type ReplicaSourceInfo

+ func ReplicaSourceInfoFromRow(ctx *sql.Context, row sql.Row) (*ReplicaSourceInfo, error)

+ type ReplicaSourceInfoPrimaryKeyer struct

+ func (ReplicaSourceInfoPrimaryKeyer) GetKey(*ReplicaSourceInfo) any

type RoleEdge

+ func RoleEdgeFromRow(ctx *sql.Context, row sql.Row) (*RoleEdge, error)

+ type RoleEdgeFromKeyer struct

+ func (RoleEdgeFromKeyer) GetKey(r *RoleEdge) any

+ type RoleEdgePrimaryKeyer struct

+ func (RoleEdgePrimaryKeyer) GetKey(r *RoleEdge) any

+ type RoleEdgeToKeyer struct

+ func (RoleEdgeToKeyer) GetKey(r *RoleEdge) any

type User

+ func UserAddDBRow(ctx *sql.Context, row sql.Row, user *User) (*User, error)

+ func UserAddGlobalGrantsRow(ctx *sql.Context, row sql.Row, user *User) (*User, error)

+ func UserAddTablesRow(ctx *sql.Context, row sql.Row, user *User) (*User, error)

+ func UserCopy(u *User) *User

+ func UserFromDBRow(ctx *sql.Context, row sql.Row) (*User, error)

+ func UserFromGlobalGrantsRow(ctx *sql.Context, row sql.Row) (*User, error)

+ func UserFromRow(ctx *sql.Context, row sql.Row) (*User, error)

+ func UserFromTablesRow(ctx *sql.Context, row sql.Row) (*User, error)

+ func UserRemoveDBRow(ctx *sql.Context, row sql.Row, user *User) (*User, error)

+ func UserRemoveGlobalGrantsRow(ctx *sql.Context, row sql.Row, user *User) (*User, error)

+ func UserRemoveTablesRow(ctx *sql.Context, row sql.Row, user *User) (*User, error)

+ func UserUpdateWithRow(ctx *sql.Context, row sql.Row, u *User) (*User, error)

+ type UserFetcher interface

+ GetUser func(u UserPrimaryKey) (res *User, ok bool)

+ GetUsersByUsername func(username string) []*User

+ type UserPrimaryKeyer struct

+ func (UserPrimaryKeyer) GetKey(u *User) any

+ type UserSecondaryKeyer struct

+ func (UserSecondaryKeyer) GetKey(u *User) any

v0.16.0

Jun 29, 2023

Changes in this version

type PrivilegedDatabase

+ func (pdb PrivilegedDatabase) AllViews(ctx *sql.Context) ([]sql.ViewDefinition, error)

+ func (pdb PrivilegedDatabase) CreateView(ctx *sql.Context, name string, selectStatement, createViewStmt string) error

+ func (pdb PrivilegedDatabase) DropView(ctx *sql.Context, name string) error

+ func (pdb PrivilegedDatabase) GetViewDefinition(ctx *sql.Context, viewName string) (sql.ViewDefinition, bool, error)

v0.15.0

Apr 18, 2023

Changes in this version

+ type GlobalGrantsConverter struct

+ func (conv GlobalGrantsConverter) AddRowToEntry(ctx *sql.Context, row sql.Row, entry in_mem_table.Entry) (in_mem_table.Entry, error)

+ func (conv GlobalGrantsConverter) EntryToRows(ctx *sql.Context, entry in_mem_table.Entry) ([]sql.Row, error)

+ func (conv GlobalGrantsConverter) RemoveRowFromEntry(ctx *sql.Context, row sql.Row, entry in_mem_table.Entry) (in_mem_table.Entry, error)

+ func (conv GlobalGrantsConverter) RowToKey(ctx *sql.Context, row sql.Row) (in_mem_table.Key, error)

type MySQLDb

+ func (db *MySQLDb) ReplicaSourceInfoTable() *mysqlTable

type PrivilegeSet

+ func NewPrivilegeSetWithAllPrivileges() PrivilegeSet

+ func (ps PrivilegeSet) Count() int

+ func (ps PrivilegeSet) HasDynamic(privileges ...string) bool

+ func (ps PrivilegeSet) ToSliceDynamic(withGrantOption bool) []string

type PrivilegedDatabase

+ func (pdb PrivilegedDatabase) DropEvent(ctx *sql.Context, name string) error

+ func (pdb PrivilegedDatabase) GetEvent(ctx *sql.Context, name string) (sql.EventDefinition, bool, error)

+ func (pdb PrivilegedDatabase) GetEvents(ctx *sql.Context) ([]sql.EventDefinition, error)

+ func (pdb PrivilegedDatabase) GetStoredProcedure(ctx *sql.Context, name string) (sql.StoredProcedureDetails, bool, error)

+ func (pdb PrivilegedDatabase) SaveEvent(ctx *sql.Context, ed sql.EventDefinition) error

+ func (pdb PrivilegedDatabase) UpdateEvent(ctx *sql.Context, ed sql.EventDefinition) error

+ type ReplicaSourceInfo struct

+ ConnectRetryCount uint64

+ ConnectRetryInterval uint32

+ Host string

+ Password string

+ Port uint16

+ User string

+ Uuid string

+ func LoadReplicaSourceInfo(serialReplicaSourceInfo *serial.ReplicaSourceInfo) *ReplicaSourceInfo

+ func NewReplicaSourceInfo() *ReplicaSourceInfo

+ func (r *ReplicaSourceInfo) Copy(_ *sql.Context) in_mem_table.Entry

+ func (r *ReplicaSourceInfo) Equals(_ *sql.Context, otherEntry in_mem_table.Entry) bool

+ func (r *ReplicaSourceInfo) FromJson(_ *sql.Context, jsonStr string) (in_mem_table.Entry, error)

+ func (r *ReplicaSourceInfo) NewFromRow(_ *sql.Context, row sql.Row) (in_mem_table.Entry, error)

+ func (r *ReplicaSourceInfo) ToJson(_ *sql.Context) (string, error)

+ func (r *ReplicaSourceInfo) ToRow(ctx *sql.Context) sql.Row

+ func (r *ReplicaSourceInfo) UpdateFromRow(ctx *sql.Context, row sql.Row) (in_mem_table.Entry, error)

+ type ReplicaSourceInfoPrimaryKey struct

+ Channel string

+ func (r ReplicaSourceInfoPrimaryKey) KeyFromEntry(_ *sql.Context, entry in_mem_table.Entry) (in_mem_table.Key, error)

+ func (r ReplicaSourceInfoPrimaryKey) KeyFromRow(_ *sql.Context, row sql.Row) (in_mem_table.Key, error)

v0.14.0

Nov 1, 2022

Changes in this version

type MySQLDb

+ func (db *MySQLDb) SetPlugins(plugins map[string]PlaintextAuthPlugin)

+ func (db *MySQLDb) VerifyPlugin(plugin string) error

+ type PlaintextAuthPlugin interface

+ Authenticate func(db *MySQLDb, user string, userEntry *User, pass string) (bool, error)

type PrivilegedDatabase

+ func (pdb PrivilegedDatabase) GetCollation(ctx *sql.Context) sql.CollationID

+ func (pdb PrivilegedDatabase) SetCollation(ctx *sql.Context, collation sql.CollationID) error

type User

+ Identity string

+ IsSuperUser bool

v0.12.0

Jun 12, 2022

Changes in this version

+ func NewPrivilegedDatabase(grantTables *MySQLDb, db sql.Database) sql.Database

+ func NewPrivilegedDatabaseProvider(grantTables *MySQLDb, p sql.DatabaseProvider) sql.DatabaseProvider

+ type DbConverter struct

+ func (conv DbConverter) AddRowToEntry(ctx *sql.Context, row sql.Row, entry in_mem_table.Entry) (in_mem_table.Entry, error)

+ func (conv DbConverter) EntryToRows(ctx *sql.Context, entry in_mem_table.Entry) ([]sql.Row, error)

+ func (conv DbConverter) RemoveRowFromEntry(ctx *sql.Context, row sql.Row, entry in_mem_table.Entry) (in_mem_table.Entry, error)

+ func (conv DbConverter) RowToKey(ctx *sql.Context, row sql.Row) (in_mem_table.Key, error)

+ type MySQLDb struct

+ Enabled bool

+ func CreateEmptyMySQLDb() *MySQLDb

+ func (t *MySQLDb) AddRootAccount()

+ func (t *MySQLDb) AddSuperUser(username string, password string)

+ func (t *MySQLDb) AuthMethod(user string) (string, error)

+ func (t *MySQLDb) GetTableInsensitive(ctx *sql.Context, tblName string) (sql.Table, bool, error)

+ func (t *MySQLDb) GetTableNames(ctx *sql.Context) ([]string, error)

+ func (t *MySQLDb) GetUser(user string, host string, roleSearch bool) *User

+ func (t *MySQLDb) LoadData(ctx *sql.Context, buf []byte) error

+ func (t *MySQLDb) LoadPrivilegeData(ctx *sql.Context, users []*User, roleConnections []*RoleEdge) error

+ func (t *MySQLDb) Name() string

+ func (t *MySQLDb) Negotiate(c *mysql.Conn, user string, addr net.Addr) (mysql.Getter, error)

+ func (t *MySQLDb) Persist(ctx *sql.Context) error

+ func (t *MySQLDb) RoleEdgesTable() *mysqlTable

+ func (t *MySQLDb) Salt() ([]byte, error)

+ func (t *MySQLDb) SetPersister(persister MySQLDbPersistence)

+ func (t *MySQLDb) UserActivePrivilegeSet(ctx *sql.Context) PrivilegeSet

+ func (t *MySQLDb) UserHasPrivileges(ctx *sql.Context, operations ...sql.PrivilegedOperation) bool

+ func (t *MySQLDb) UserTable() *mysqlTable

+ func (t *MySQLDb) ValidateCanPersist() error

+ func (t *MySQLDb) ValidateHash(salt []byte, user string, authResponse []byte, addr net.Addr) (mysql.Getter, error)

+ type MySQLDbPersistence interface

+ Persist func(ctx *sql.Context, data []byte) error

+ ValidateCanPersist func() error

+ type MysqlConnectionUser struct

+ Host string

+ User string

+ func (m MysqlConnectionUser) Get() *query.VTGateCallerID

+ type NoopPersister struct

+ func (p *NoopPersister) Persist(ctx *sql.Context, data []byte) error

+ func (p *NoopPersister) ValidateCanPersist() error

+ type PrivilegeSet struct

+ func NewPrivilegeSet() PrivilegeSet

+ func (ps *PrivilegeSet) ClearAll()

+ func (ps *PrivilegeSet) ClearGlobal()

+ func (ps *PrivilegeSet) UnmarshalJSON(jsonData []byte) error

+ func (ps PrivilegeSet) AddColumn(dbName string, tblName string, colName string, privileges ...sql.PrivilegeType)

+ func (ps PrivilegeSet) AddDatabase(dbName string, privileges ...sql.PrivilegeType)

+ func (ps PrivilegeSet) AddGlobalDynamic(privileges ...string)

+ func (ps PrivilegeSet) AddGlobalStatic(privileges ...sql.PrivilegeType)

+ func (ps PrivilegeSet) AddTable(dbName string, tblName string, privileges ...sql.PrivilegeType)

+ func (ps PrivilegeSet) ClearColumn(dbName string, tblName string, colName string)

+ func (ps PrivilegeSet) ClearDatabase(dbName string)

+ func (ps PrivilegeSet) ClearTable(dbName string, tblName string)

+ func (ps PrivilegeSet) Copy() PrivilegeSet

+ func (ps PrivilegeSet) Database(dbName string) PrivilegeSetDatabase

+ func (ps PrivilegeSet) Equals(otherPs PrivilegeSet) bool

+ func (ps PrivilegeSet) GetDatabases() []PrivilegeSetDatabase

+ func (ps PrivilegeSet) GlobalCount() int

+ func (ps PrivilegeSet) Has(privileges ...sql.PrivilegeType) bool

+ func (ps PrivilegeSet) HasPrivileges() bool

+ func (ps PrivilegeSet) MarshalJSON() ([]byte, error)

+ func (ps PrivilegeSet) RemoveColumn(dbName string, tblName string, colName string, privileges ...sql.PrivilegeType)

+ func (ps PrivilegeSet) RemoveDatabase(dbName string, privileges ...sql.PrivilegeType)

+ func (ps PrivilegeSet) RemoveGlobalDynamic(privileges ...string)

+ func (ps PrivilegeSet) RemoveGlobalStatic(privileges ...sql.PrivilegeType)

+ func (ps PrivilegeSet) RemoveTable(dbName string, tblName string, privileges ...sql.PrivilegeType)

+ func (ps PrivilegeSet) StaticCount() int

+ func (ps PrivilegeSet) ToSlice() []sql.PrivilegeType

+ func (ps PrivilegeSet) ToSortedSlice() []sql.PrivilegeType

+ func (ps PrivilegeSet) UnionWith(other PrivilegeSet)

+ type PrivilegeSetColumn struct

+ func (ps PrivilegeSetColumn) Count() int

+ func (ps PrivilegeSetColumn) Equals(otherPs PrivilegeSetColumn) bool

+ func (ps PrivilegeSetColumn) Has(privileges ...sql.PrivilegeType) bool

+ func (ps PrivilegeSetColumn) Name() string

+ func (ps PrivilegeSetColumn) ToSlice() []sql.PrivilegeType

+ func (ps PrivilegeSetColumn) ToSortedSlice() []sql.PrivilegeType

+ type PrivilegeSetDatabase struct

+ func (ps PrivilegeSetDatabase) Count() int

+ func (ps PrivilegeSetDatabase) Equals(otherPs PrivilegeSetDatabase) bool

+ func (ps PrivilegeSetDatabase) GetTables() []PrivilegeSetTable

+ func (ps PrivilegeSetDatabase) Has(privileges ...sql.PrivilegeType) bool

+ func (ps PrivilegeSetDatabase) HasPrivileges() bool

+ func (ps PrivilegeSetDatabase) Name() string

+ func (ps PrivilegeSetDatabase) Table(tblName string) PrivilegeSetTable

+ func (ps PrivilegeSetDatabase) ToSlice() []sql.PrivilegeType

+ func (ps PrivilegeSetDatabase) ToSortedSlice() []sql.PrivilegeType

+ type PrivilegeSetTable struct

+ func (ps PrivilegeSetTable) Column(colName string) PrivilegeSetColumn

+ func (ps PrivilegeSetTable) Count() int

+ func (ps PrivilegeSetTable) Equals(otherPs PrivilegeSetTable) bool

+ func (ps PrivilegeSetTable) GetColumns() []PrivilegeSetColumn

+ func (ps PrivilegeSetTable) Has(privileges ...sql.PrivilegeType) bool

+ func (ps PrivilegeSetTable) HasPrivileges() bool

+ func (ps PrivilegeSetTable) Name() string

+ func (ps PrivilegeSetTable) ToSlice() []sql.PrivilegeType

+ func (ps PrivilegeSetTable) ToSortedSlice() []sql.PrivilegeType

+ type PrivilegedDatabase struct

+ func (pdb PrivilegedDatabase) CopyTableData(ctx *sql.Context, sourceTable string, destinationTable string) (uint64, error)

+ func (pdb PrivilegedDatabase) CreateTable(ctx *sql.Context, name string, schema sql.PrimaryKeySchema) error

+ func (pdb PrivilegedDatabase) CreateTrigger(ctx *sql.Context, definition sql.TriggerDefinition) error

+ func (pdb PrivilegedDatabase) DropStoredProcedure(ctx *sql.Context, name string) error

+ func (pdb PrivilegedDatabase) DropTable(ctx *sql.Context, name string) error

+ func (pdb PrivilegedDatabase) DropTrigger(ctx *sql.Context, name string) error

+ func (pdb PrivilegedDatabase) GetAllTemporaryTables(ctx *sql.Context) ([]sql.Table, error)

+ func (pdb PrivilegedDatabase) GetExternalStoredProcedures(ctx *sql.Context) ([]sql.ExternalStoredProcedureDetails, error)

+ func (pdb PrivilegedDatabase) GetStoredProcedures(ctx *sql.Context) ([]sql.StoredProcedureDetails, error)

+ func (pdb PrivilegedDatabase) GetTableInsensitive(ctx *sql.Context, tblName string) (sql.Table, bool, error)

+ func (pdb PrivilegedDatabase) GetTableInsensitiveAsOf(ctx *sql.Context, tblName string, asOf interface{}) (sql.Table, bool, error)

+ func (pdb PrivilegedDatabase) GetTableNames(ctx *sql.Context) ([]string, error)

+ func (pdb PrivilegedDatabase) GetTableNamesAsOf(ctx *sql.Context, asOf interface{}) ([]string, error)

+ func (pdb PrivilegedDatabase) GetTriggers(ctx *sql.Context) ([]sql.TriggerDefinition, error)

+ func (pdb PrivilegedDatabase) IsReadOnly() bool

+ func (pdb PrivilegedDatabase) Name() string

+ func (pdb PrivilegedDatabase) RenameTable(ctx *sql.Context, oldName, newName string) error

+ func (pdb PrivilegedDatabase) SaveStoredProcedure(ctx *sql.Context, spd sql.StoredProcedureDetails) error

+ func (pdb PrivilegedDatabase) Unwrap() sql.Database

+ type PrivilegedDatabaseProvider struct

+ func (pdp PrivilegedDatabaseProvider) AllDatabases(ctx *sql.Context) []sql.Database

+ func (pdp PrivilegedDatabaseProvider) Database(ctx *sql.Context, name string) (sql.Database, error)

+ func (pdp PrivilegedDatabaseProvider) HasDatabase(ctx *sql.Context, name string) bool

+ type RoleEdge struct

+ FromHost string

+ FromUser string

+ ToHost string

+ ToUser string

+ WithAdminOption bool

+ func LoadRoleEdge(serialRoleEdge *serial.RoleEdge) *RoleEdge

+ func (r *RoleEdge) Copy(ctx *sql.Context) in_mem_table.Entry

+ func (r *RoleEdge) Equals(ctx *sql.Context, otherEntry in_mem_table.Entry) bool

+ func (r *RoleEdge) FromString(quote string) string

+ func (r *RoleEdge) NewFromRow(ctx *sql.Context, row sql.Row) (in_mem_table.Entry, error)

+ func (r *RoleEdge) ToJson(ctx *sql.Context) (string, error)

+ func (r *RoleEdge) ToRow(ctx *sql.Context) sql.Row

+ func (r *RoleEdge) ToString(quote string) string

+ func (r *RoleEdge) UpdateFromRow(ctx *sql.Context, row sql.Row) (in_mem_table.Entry, error)

+ func (r RoleEdge) FromJson(ctx *sql.Context, jsonStr string) (in_mem_table.Entry, error)

+ type RoleEdgesFromKey struct

+ FromHost string

+ FromUser string

+ func (k RoleEdgesFromKey) KeyFromEntry(ctx *sql.Context, entry in_mem_table.Entry) (in_mem_table.Key, error)

+ func (k RoleEdgesFromKey) KeyFromRow(ctx *sql.Context, row sql.Row) (in_mem_table.Key, error)

+ type RoleEdgesPrimaryKey struct

+ FromHost string

+ FromUser string

+ ToHost string

+ ToUser string

+ func (k RoleEdgesPrimaryKey) KeyFromEntry(ctx *sql.Context, entry in_mem_table.Entry) (in_mem_table.Key, error)

+ func (k RoleEdgesPrimaryKey) KeyFromRow(ctx *sql.Context, row sql.Row) (in_mem_table.Key, error)

+ type RoleEdgesToKey struct

+ ToHost string

+ ToUser string

+ func (k RoleEdgesToKey) KeyFromEntry(ctx *sql.Context, entry in_mem_table.Entry) (in_mem_table.Key, error)

+ func (k RoleEdgesToKey) KeyFromRow(ctx *sql.Context, row sql.Row) (in_mem_table.Key, error)

+ type TablesPrivConverter struct

+ func (conv TablesPrivConverter) AddRowToEntry(ctx *sql.Context, row sql.Row, entry in_mem_table.Entry) (in_mem_table.Entry, error)

+ func (conv TablesPrivConverter) EntryToRows(ctx *sql.Context, entry in_mem_table.Entry) ([]sql.Row, error)

+ func (conv TablesPrivConverter) RemoveRowFromEntry(ctx *sql.Context, row sql.Row, entry in_mem_table.Entry) (in_mem_table.Entry, error)

+ func (conv TablesPrivConverter) RowToKey(ctx *sql.Context, row sql.Row) (in_mem_table.Key, error)

+ type User struct

+ Attributes *string

+ Host string

+ IsRole bool

+ Locked bool

+ Password string

+ PasswordLastChanged time.Time

+ Plugin string

+ PrivilegeSet PrivilegeSet

+ User string

+ func LoadUser(serialUser *serial.User) *User

+ func (u *User) Copy(ctx *sql.Context) in_mem_table.Entry

+ func (u *User) Equals(ctx *sql.Context, otherEntry in_mem_table.Entry) bool

+ func (u *User) NewFromRow(ctx *sql.Context, row sql.Row) (in_mem_table.Entry, error)

+ func (u *User) ToJson(ctx *sql.Context) (string, error)

+ func (u *User) ToRow(ctx *sql.Context) sql.Row

+ func (u *User) UpdateFromRow(ctx *sql.Context, row sql.Row) (in_mem_table.Entry, error)

+ func (u User) FromJson(ctx *sql.Context, jsonStr string) (in_mem_table.Entry, error)

+ func (u User) UserHostToString(quote string) string

+ type UserPrimaryKey struct

+ Host string

+ User string

+ func (u UserPrimaryKey) KeyFromEntry(ctx *sql.Context, entry in_mem_table.Entry) (in_mem_table.Key, error)

+ func (u UserPrimaryKey) KeyFromRow(ctx *sql.Context, row sql.Row) (in_mem_table.Key, error)

+ type UserSecondaryKey struct

+ User string

+ func (u UserSecondaryKey) KeyFromEntry(ctx *sql.Context, entry in_mem_table.Entry) (in_mem_table.Key, error)

+ func (u UserSecondaryKey) KeyFromRow(ctx *sql.Context, row sql.Row) (in_mem_table.Key, error)

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