mysql

Documentation

Index

• Constants
• type Config
  • func (c Config) ConnectionString() (string, error)
  • func (c *Config) Parse(input json.RawMessage) error
  • func (c Config) TLS() (string, error)
• type DB
  • func NewDB(configJSON json.RawMessage) (*DB, error)
  • func (db *DB) CurrentCatalog(ctx context.Context) (string, error)

Constants

const (
	DatabaseType = "mysql"
)

Types

type Config

type Config struct {
	Host     string `json:"host"`
	Port     int    `json:"port"`
	DBName   string `json:"dbname"`
	User     string `json:"user"`
	Password string `json:"password"`
	SSLMode  string `json:"sslmode"`

	TunnelInfo *sshtunnel.Config `json:"tunnel_info,omitempty"`

	// SkipHostValidation is used to skip host validation during tests
	SkipHostValidation bool `json:"skipHostValidation"`
	UseLegacyMappings  bool `json:"useLegacyMappings"`
}

func (Config) ConnectionString

func (c Config) ConnectionString() (string, error)

func (*Config) Parse

func (c *Config) Parse(input json.RawMessage) error

func (Config) TLS

func (c Config) TLS() (string, error)

type DB

type DB struct {
	*base.DB
}

func NewDB

func NewDB(configJSON json.RawMessage) (*DB, error)

NewDB creates a new mysql db client

func (*DB) CurrentCatalog

func (db *DB) CurrentCatalog(ctx context.Context) (string, error)

CurrentCatalog returns an error because it is not supported by MySQL