mysql

Documentation

Index

• func AddForeignKeyStatement(tableName string, schemaForeignKey *schemasv1alpha4.MysqlTableForeignKey) string
• func AddIndexStatement(tableName string, schemaIndex *schemasv1alpha4.MysqlTableIndex) string
• func AlterColumnStatements(tableName string, primaryKeys []string, ...) ([]string, error)
• func CreateTableStatements(tableName string, tableSchema *schemasv1alpha4.MysqlTableSchema) ([]string, error)
• func DatabaseNameFromURI(uri string) (string, error)
• func DeployMysqlStatements(uri string, statements []string) error
• func HostnameFromURI(uri string) (string, error)
• func InsertColumnStatement(tableName string, desiredColumn *schemasv1alpha4.MysqlTableColumn) (string, error)
• func PasswordFromURI(uri string) (string, error)
• func PlanMysqlTable(uri string, tableName string, ...) ([]string, error)
• func PlanMysqlView(uri string, viewName string, ...) ([]string, error)
• func PortFromURI(uri string) (string, error)
• func RemoveForeignKeyStatement(tableName string, foreignKey *types.ForeignKey) string
• func RemoveIndexStatement(tableName string, index *types.Index) string
• func RenameIndexStatement(tableName string, index *types.Index, ...) string
• func SeedDataStatements(tableName string, seedData *schemasv1alpha4.SeedData) ([]string, error)
• func UsernameFromURI(uri string) (string, error)
• type AlterAddConstrantStatement
  • func (s AlterAddConstrantStatement) String() string
• type AlterDropColumnStatement
  • func (s AlterDropColumnStatement) DDL() []string
• type AlterModifyColumnStatement
  • func (s AlterModifyColumnStatement) DDL() []string
• type AlterRemoveConstrantStatement
  • func (s AlterRemoveConstrantStatement) String() string
• type MysqlConnection
  • func Connect(uri string) (*MysqlConnection, error)
  • func (m *MysqlConnection) Close() error
  • func (m *MysqlConnection) DatabaseName() string
  • func (m *MysqlConnection) EngineVersion() string
  • func (m *MysqlConnection) GetDB() *sql.DB
  • func (m *MysqlConnection) GetTablePrimaryKey(tableName string) (*types.KeyConstraint, error)
  • func (m *MysqlConnection) GetTableSchema(tableName string) ([]*types.Column, error)
  • func (m *MysqlConnection) ListTableForeignKeys(databaseName string, tableName string) ([]*types.ForeignKey, error)
  • func (m *MysqlConnection) ListTableIndexes(databaseName string, tableName string) ([]*types.Index, error)
  • func (m *MysqlConnection) ListTables() ([]*types.Table, error)

Functions

func AddForeignKeyStatement

func AddForeignKeyStatement(tableName string, schemaForeignKey *schemasv1alpha4.MysqlTableForeignKey) string

func AddIndexStatement

func AddIndexStatement(tableName string, schemaIndex *schemasv1alpha4.MysqlTableIndex) string

func AlterColumnStatements

func AlterColumnStatements(tableName string, primaryKeys []string, desiredColumns []*schemasv1alpha4.MysqlTableColumn, existingColumn *types.Column, defaultCharset string, defaultCollation string) ([]string, error)

func CreateTableStatements

func CreateTableStatements(tableName string, tableSchema *schemasv1alpha4.MysqlTableSchema) ([]string, error)

func DatabaseNameFromURI

func DatabaseNameFromURI(uri string) (string, error)

func DeployMysqlStatements

func DeployMysqlStatements(uri string, statements []string) error

func HostnameFromURI

func HostnameFromURI(uri string) (string, error)

func InsertColumnStatement

func InsertColumnStatement(tableName string, desiredColumn *schemasv1alpha4.MysqlTableColumn) (string, error)

func PasswordFromURI

func PasswordFromURI(uri string) (string, error)

func PlanMysqlTable

func PlanMysqlTable(uri string, tableName string, mysqlTableSchema *schemasv1alpha4.MysqlTableSchema, seedData *schemasv1alpha4.SeedData) ([]string, error)

func PlanMysqlView

func PlanMysqlView(uri string, viewName string, mysqlViewSchema *schemasv1alpha4.NotImplementedViewSchema) ([]string, error)

func PortFromURI

func PortFromURI(uri string) (string, error)

func RemoveForeignKeyStatement

func RemoveForeignKeyStatement(tableName string, foreignKey *types.ForeignKey) string

func RemoveIndexStatement

func RemoveIndexStatement(tableName string, index *types.Index) string

func RenameIndexStatement

func RenameIndexStatement(tableName string, index *types.Index, schemaIndex *schemasv1alpha4.MysqlTableIndex) string

func SeedDataStatements

func SeedDataStatements(tableName string, seedData *schemasv1alpha4.SeedData) ([]string, error)

func UsernameFromURI

func UsernameFromURI(uri string) (string, error)

Types

type AlterAddConstrantStatement

type AlterAddConstrantStatement struct {
	TableName  string
	Constraint types.KeyConstraint
}

func (AlterAddConstrantStatement) String

func (s AlterAddConstrantStatement) String() string

type AlterDropColumnStatement

type AlterDropColumnStatement struct {
	TableName string
	Column    types.Column
}

func (AlterDropColumnStatement) DDL

func (s AlterDropColumnStatement) DDL() []string

type AlterModifyColumnStatement

type AlterModifyColumnStatement struct {
	TableName      string
	ExistingColumn types.Column
	Column         types.Column
}

func (AlterModifyColumnStatement) DDL

func (s AlterModifyColumnStatement) DDL() []string

type AlterRemoveConstrantStatement

type AlterRemoveConstrantStatement struct {
	TableName  string
	Constraint types.KeyConstraint
}

func (AlterRemoveConstrantStatement) String

func (s AlterRemoveConstrantStatement) String() string

type MysqlConnection

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

func Connect

func Connect(uri string) (*MysqlConnection, error)

func (*MysqlConnection) Close

func (m *MysqlConnection) Close() error

func (*MysqlConnection) DatabaseName

func (m *MysqlConnection) DatabaseName() string

func (*MysqlConnection) EngineVersion

func (m *MysqlConnection) EngineVersion() string

func (*MysqlConnection) GetDB

func (m *MysqlConnection) GetDB() *sql.DB

func (*MysqlConnection) GetTablePrimaryKey

func (m *MysqlConnection) GetTablePrimaryKey(tableName string) (*types.KeyConstraint, error)

func (*MysqlConnection) GetTableSchema

func (m *MysqlConnection) GetTableSchema(tableName string) ([]*types.Column, error)

func (*MysqlConnection) ListTableForeignKeys

func (m *MysqlConnection) ListTableForeignKeys(databaseName string, tableName string) ([]*types.ForeignKey, error)

func (*MysqlConnection) ListTableIndexes

func (m *MysqlConnection) ListTableIndexes(databaseName string, tableName string) ([]*types.Index, error)

func (*MysqlConnection) ListTables

func (m *MysqlConnection) ListTables() ([]*types.Table, error)