mysql

Documentation

Index

• func AddForeignKeyStatement(tableName string, schemaForeignKey *schemasv1alpha2.SQLTableForeignKey) string
• func AddIndexStatement(tableName string, schemaIndex *schemasv1alpha2.SQLTableIndex) string
• func AlterColumnStatement(tableName string, primaryKeys []string, ...) (string, error)
• func CreateTableStatement(tableName string, tableSchema *schemasv1alpha2.SQLTableSchema) (string, error)
• func DatabaseNameFromURI(uri string) (string, error)
• func DeployMysqlTable(uri string, tableName string, mysqlTableSchema *schemasv1alpha2.SQLTableSchema) error
• func InsertColumnStatement(tableName string, desiredColumn *schemasv1alpha2.SQLTableColumn) (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
• type AlterAddConstrantStatement
  • func (s AlterAddConstrantStatement) String() string
• type AlterDropColumnStatement
  • func (s AlterDropColumnStatement) String() string
• type AlterModifyColumnStatement
  • func (s AlterModifyColumnStatement) String() string
• type AlterRemoveConstrantStatement
  • func (s AlterRemoveConstrantStatement) String() string
• type MysqlConnection
  • func Connect(uri string) (*MysqlConnection, error)
  • func (m *MysqlConnection) CheckAlive(namespace string, instanceName string) (bool, error)
  • func (m *MysqlConnection) DatabaseName() string
  • func (m *MysqlConnection) EngineVersion() string
  • func (m *MysqlConnection) GetConnection() *sql.Conn
  • 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() ([]string, error)

Functions

func AddForeignKeyStatement

func AddForeignKeyStatement(tableName string, schemaForeignKey *schemasv1alpha2.SQLTableForeignKey) string

func AddIndexStatement

func AddIndexStatement(tableName string, schemaIndex *schemasv1alpha2.SQLTableIndex) string

func AlterColumnStatement

func AlterColumnStatement(tableName string, primaryKeys []string, desiredColumns []*schemasv1alpha2.SQLTableColumn, existingColumn *types.Column) (string, error)

func CreateTableStatement

func CreateTableStatement(tableName string, tableSchema *schemasv1alpha2.SQLTableSchema) (string, error)

func DatabaseNameFromURI

func DatabaseNameFromURI(uri string) (string, error)

func DeployMysqlTable

func DeployMysqlTable(uri string, tableName string, mysqlTableSchema *schemasv1alpha2.SQLTableSchema) error

func InsertColumnStatement

func InsertColumnStatement(tableName string, desiredColumn *schemasv1alpha2.SQLTableColumn) (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 *schemasv1alpha2.SQLTableIndex) string

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) String

func (s AlterDropColumnStatement) String() string

type AlterModifyColumnStatement

type AlterModifyColumnStatement struct {
	TableName string
	Column    types.Column
}

func (AlterModifyColumnStatement) String

func (s AlterModifyColumnStatement) String() 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) CheckAlive

func (m *MysqlConnection) CheckAlive(namespace string, instanceName string) (bool, error)

func (*MysqlConnection) DatabaseName

func (m *MysqlConnection) DatabaseName() string

func (*MysqlConnection) EngineVersion

func (m *MysqlConnection) EngineVersion() string

func (*MysqlConnection) GetConnection

func (m *MysqlConnection) GetConnection() *sql.Conn

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() ([]string, error)