sql

package

v0.0.27 Latest Latest Go to latest Published: Mar 8, 2024 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mariadb-operator/mariadb-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func BuildDSN(opts Opts) (string, error)
func Connect(dsn string) (*sql.DB, error)
func ConnectWithOpts(opts Opts) (*sql.DB, error)
type ChangeMasterOpts
type Client
type CreateUserOpts
type DatabaseOpts
type GrantOption
- func WithGrantOption() GrantOption
type Opt
type Opts

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrWaitReplicaTimeout = errors.New("timeout waiting for replica to be synced")
)

Functions ¶

func BuildDSN ¶

func BuildDSN(opts Opts) (string, error)

func Connect ¶

func Connect(dsn string) (*sql.DB, error)

func ConnectWithOpts ¶

func ConnectWithOpts(opts Opts) (*sql.DB, error)

Types ¶

type ChangeMasterOpts ¶

type ChangeMasterOpts struct {
	Connection string
	Host       string
	User       string
	Password   string
	Gtid       string
	Retries    int
}

type Client ¶

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

func NewClient ¶

func NewClient(clientOpts ...Opt) (*Client, error)

func NewClientWithMariaDB ¶

func NewClientWithMariaDB(ctx context.Context, mariadb *mariadbv1alpha1.MariaDB, refResolver *refresolver.RefResolver,
	clientOpts ...Opt) (*Client, error)

func NewInternalClientWithPodIndex ¶

func NewInternalClientWithPodIndex(ctx context.Context, mariadb *mariadbv1alpha1.MariaDB, refResolver *refresolver.RefResolver,
	podIndex int, clientOpts ...Opt) (*Client, error)

func NewLocalClientWithPodEnv ¶ added in v0.0.26

func NewLocalClientWithPodEnv(ctx context.Context, env *environment.PodEnvironment, clientOpts ...Opt) (*Client, error)

func (*Client) AlterUser ¶

func (c *Client) AlterUser(ctx context.Context, username, password string) error

func (*Client) ChangeMaster ¶

func (c *Client) ChangeMaster(ctx context.Context, opts *ChangeMasterOpts) error

func (*Client) Close ¶

func (c *Client) Close() error

func (*Client) CreateDatabase ¶

func (c *Client) CreateDatabase(ctx context.Context, database string, opts DatabaseOpts) error

func (*Client) CreateUser ¶

func (c *Client) CreateUser(ctx context.Context, accountName string, opts CreateUserOpts) error

func (*Client) DisableReadOnly ¶

func (c *Client) DisableReadOnly(ctx context.Context) error

func (*Client) DropDatabase ¶

func (c *Client) DropDatabase(ctx context.Context, database string) error

func (*Client) DropUser ¶

func (c *Client) DropUser(ctx context.Context, accountName string) error

func (*Client) EnableReadOnly ¶

func (c *Client) EnableReadOnly(ctx context.Context) error

func (*Client) Exec ¶

func (c *Client) Exec(ctx context.Context, sql string, args ...any) error

func (*Client) ExecFlushingPrivileges ¶

func (c *Client) ExecFlushingPrivileges(ctx context.Context, sql string, args ...any) error

func (*Client) FlushPrivileges ¶

func (c *Client) FlushPrivileges(ctx context.Context) error

func (*Client) GaleraClusterSize ¶

func (c *Client) GaleraClusterSize(ctx context.Context) (int, error)

func (*Client) GaleraClusterStatus ¶

func (c *Client) GaleraClusterStatus(ctx context.Context) (string, error)

func (*Client) GaleraLocalState ¶

func (c *Client) GaleraLocalState(ctx context.Context) (string, error)

func (*Client) Grant ¶

func (c *Client) Grant(
	ctx context.Context,
	privileges []string,
	database string,
	table string,
	accountName string,
	opts ...GrantOption,
) error

func (*Client) IsSystemVariableEnabled ¶ added in v0.0.25

func (c *Client) IsSystemVariableEnabled(ctx context.Context, variable string) (bool, error)

func (*Client) LockTablesWithReadLock ¶ added in v0.0.24

func (c *Client) LockTablesWithReadLock(ctx context.Context) error

func (*Client) MaxScaleConfigSyncVersion ¶ added in v0.0.25

func (c *Client) MaxScaleConfigSyncVersion(ctx context.Context) (int, error)

func (*Client) ResetAllSlaves ¶

func (c *Client) ResetAllSlaves(ctx context.Context) error

func (*Client) ResetMaster ¶

func (c *Client) ResetMaster(ctx context.Context) error

func (*Client) ResetSlavePos ¶

func (c *Client) ResetSlavePos(ctx context.Context) error

func (*Client) Revoke ¶

func (c *Client) Revoke(
	ctx context.Context,
	privileges []string,
	database string,
	table string,
	accountName string,
	opts ...GrantOption,
) error

func (*Client) SetSystemVariable ¶

func (c *Client) SetSystemVariable(ctx context.Context, variable string, value string) error

func (*Client) SetSystemVariables ¶

func (c *Client) SetSystemVariables(ctx context.Context, keyVal map[string]string) error

func (*Client) StartSlave ¶

func (c *Client) StartSlave(ctx context.Context, connName string) error

func (*Client) StatusVariable ¶

func (c *Client) StatusVariable(ctx context.Context, variable string) (string, error)

func (*Client) StatusVariableInt ¶

func (c *Client) StatusVariableInt(ctx context.Context, variable string) (int, error)

func (*Client) StopAllSlaves ¶

func (c *Client) StopAllSlaves(ctx context.Context) error

func (*Client) SystemVariable ¶

func (c *Client) SystemVariable(ctx context.Context, variable string) (string, error)

func (*Client) TruncateMaxScaleConfig ¶ added in v0.0.25

func (c *Client) TruncateMaxScaleConfig(ctx context.Context) error

func (*Client) UnlockTables ¶ added in v0.0.24

func (c *Client) UnlockTables(ctx context.Context) error

func (*Client) UserExists ¶

func (c *Client) UserExists(ctx context.Context, username string) (bool, error)

func (*Client) WaitForReplicaGtid ¶

func (c *Client) WaitForReplicaGtid(ctx context.Context, gtid string, timeout time.Duration) error

type CreateUserOpts ¶

type CreateUserOpts struct {
	IdentifiedBy       string
	MaxUserConnections int32
}

type DatabaseOpts ¶

type DatabaseOpts struct {
	CharacterSet string
	Collate      string
}

type GrantOption ¶

type GrantOption func(*grantOpts)

func WithGrantOption ¶

func WithGrantOption() GrantOption

type Opt ¶

type Opt func(*Opts)

func WitHost ¶

func WitHost(host string) Opt

func WithDatabase ¶

func WithDatabase(database string) Opt

func WithParams ¶

func WithParams(params map[string]string) Opt

func WithPassword ¶

func WithPassword(password string) Opt

func WithPort ¶

func WithPort(port int32) Opt

func WithTimeout ¶ added in v0.0.24

func WithTimeout(d time.Duration) Opt

func WithUsername ¶

func WithUsername(username string) Opt

type Opts ¶

type Opts struct {
	Username string
	Password string
	Host     string
	Port     int32
	Database string
	Params   map[string]string
	Timeout  *time.Duration
}

Source Files ¶

View all Source files

sql.go

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