Documentation ¶
Index ¶
- func AddColumn(table string, cluster string, col schema.Column) (string, error)
- func CreateTable(table *schema.Table, cluster string, engine *spec.Engine) (string, error)
- func DropColumn(table string, cluster string, col schema.Column) string
- func DropTable(table *schema.Table, cluster string) string
- func GetTablesSchema(database string) (query string, params []any)
- func Insert(table *schema.Table) string
- func Read(table *schema.Table) string
- func ScanTableSchemas(rows driver.Rows, messages message.WriteMigrateTables) (schema.Tables, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateTable ¶
func GetTablesSchema ¶
func ScanTableSchemas ¶
ScanTableSchemas doesn't close rows, so that's on caller.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.