dialect

Documentation

Index

• type ClickhouseDialect
  • func NewClickhouseDialect(clusterName, engine string) *ClickhouseDialect
  • func (c *ClickhouseDialect) QueryCreateMigrateSchema(schemaName string) string
  • func (c *ClickhouseDialect) QueryCreateMigrateTable(schemaName, tableName string) string
  • func (c *ClickhouseDialect) QueryDeleteMigrate(schemaName, tableName string) string
  • func (c *ClickhouseDialect) QueryInsertMigrate(schemaName, tableName string) string
  • func (c *ClickhouseDialect) QuerySelectMigrate(schemaName, tableName string) string
• type Dialect
• type MySQLDialect
  • func NewMySQLDialect(engine, encoding string) *MySQLDialect
  • func (d *MySQLDialect) QueryCreateMigrateSchema(schemaName string) string
  • func (d *MySQLDialect) QueryCreateMigrateTable(schemaName, tableName string) string
  • func (d *MySQLDialect) QueryDeleteMigrate(schemaName, tableName string) string
  • func (d *MySQLDialect) QueryInsertMigrate(schemaName, tableName string) string
  • func (d *MySQLDialect) QuerySelectMigrate(schemaName, tableName string) string
• type OracleDialect
  • func NewOracleDialect() *OracleDialect
  • func (d *OracleDialect) QueryCreateMigrateSchema(schemaName string) string
  • func (d *OracleDialect) QueryCreateMigrateTable(schemaName, tableName string) string
  • func (d *OracleDialect) QueryDeleteMigrate(schemaName, tableName string) string
  • func (d *OracleDialect) QueryInsertMigrate(schemaName, tableName string) string
  • func (d *OracleDialect) QuerySelectMigrate(schemaName, tableName string) string
• type PostgresDialect
  • func NewPostgresDialect() *PostgresDialect
  • func (d *PostgresDialect) QueryCreateMigrateSchema(schemaName string) string
  • func (d *PostgresDialect) QueryCreateMigrateTable(schemaName, tableName string) string
  • func (d *PostgresDialect) QueryDeleteMigrate(schemaName, tableName string) string
  • func (d *PostgresDialect) QueryInsertMigrate(schemaName, tableName string) string
  • func (d *PostgresDialect) QuerySelectMigrate(schemaName, tableName string) string
• type SnowflakeDialect
  • func NewSnowflakeDialect() *SnowflakeDialect
  • func (d *SnowflakeDialect) QueryCreateMigrateSchema(schemaName string) string
  • func (d *SnowflakeDialect) QueryCreateMigrateTable(schemaName, tableName string) string
  • func (d *SnowflakeDialect) QueryDeleteMigrate(schemaName, tableName string) string
  • func (d *SnowflakeDialect) QueryInsertMigrate(schemaName, tableName string) string
  • func (d *SnowflakeDialect) QuerySelectMigrate(schemaName, tableName string) string
• type SqlServerDialect
  • func NewSqlServerDialect() *SqlServerDialect
  • func (d *SqlServerDialect) QueryCreateMigrateSchema(schemaName string) string
  • func (d *SqlServerDialect) QueryCreateMigrateTable(schemaName, tableName string) string
  • func (d *SqlServerDialect) QueryDeleteMigrate(schemaName, tableName string) string
  • func (d *SqlServerDialect) QueryInsertMigrate(schemaName, tableName string) string
  • func (d *SqlServerDialect) QuerySelectMigrate(schemaName, tableName string) string
• type SqliteDialect
  • func NewSqliteDialect() *SqliteDialect
  • func (d *SqliteDialect) QueryCreateMigrateSchema(_ string) string
  • func (d *SqliteDialect) QueryCreateMigrateTable(schemaName, tableName string) string
  • func (d *SqliteDialect) QueryDeleteMigrate(schemaName, tableName string) string
  • func (d *SqliteDialect) QueryInsertMigrate(schemaName, tableName string) string
  • func (d *SqliteDialect) QuerySelectMigrate(schemaName, tableName string) string

Types

type ClickhouseDialect

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

func NewClickhouseDialect

func NewClickhouseDialect(clusterName, engine string) *ClickhouseDialect

func (*ClickhouseDialect) QueryCreateMigrateSchema

func (c *ClickhouseDialect) QueryCreateMigrateSchema(schemaName string) string

func (*ClickhouseDialect) QueryCreateMigrateTable

func (c *ClickhouseDialect) QueryCreateMigrateTable(schemaName, tableName string) string

func (*ClickhouseDialect) QueryDeleteMigrate

func (c *ClickhouseDialect) QueryDeleteMigrate(schemaName, tableName string) string

func (*ClickhouseDialect) QueryInsertMigrate

func (c *ClickhouseDialect) QueryInsertMigrate(schemaName, tableName string) string

func (*ClickhouseDialect) QuerySelectMigrate

func (c *ClickhouseDialect) QuerySelectMigrate(schemaName, tableName string) string

type Dialect

type Dialect interface {
	// QueryCreateMigrateSchema returns the query - create schema if not exists
	QueryCreateMigrateSchema(schemaName string) string
	// QueryCreateMigrateTable returns the query - create table if not exists
	QueryCreateMigrateTable(schemaName, tableName string) string
	// QueryDeleteMigrate returns the query - delete migration by id
	QueryDeleteMigrate(schemaName, tableName string) string
	// QuerySelectMigrate returns the query - select all migrations order by id ASC
	QuerySelectMigrate(schemaName, tableName string) string
	// QueryInsertMigrate returns the query - insert migration
	QueryInsertMigrate(schemaName, tableName string) string
}

The Dialect interface encapsulates behaviors that differ across SQL databases.

type MySQLDialect

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

MySQLDialect Implementation of Dialect for MySQL databases.

func NewMySQLDialect

func NewMySQLDialect(engine, encoding string) *MySQLDialect

func (*MySQLDialect) QueryCreateMigrateSchema

func (d *MySQLDialect) QueryCreateMigrateSchema(schemaName string) string

func (*MySQLDialect) QueryCreateMigrateTable

func (d *MySQLDialect) QueryCreateMigrateTable(schemaName, tableName string) string

func (*MySQLDialect) QueryDeleteMigrate

func (d *MySQLDialect) QueryDeleteMigrate(schemaName, tableName string) string

func (*MySQLDialect) QueryInsertMigrate

func (d *MySQLDialect) QueryInsertMigrate(schemaName, tableName string) string

func (*MySQLDialect) QuerySelectMigrate

func (d *MySQLDialect) QuerySelectMigrate(schemaName, tableName string) string

type OracleDialect

type OracleDialect struct{}

OracleDialect Implementation of Dialect for Oracle databases.

func NewOracleDialect

func NewOracleDialect() *OracleDialect

func (*OracleDialect) QueryCreateMigrateSchema

func (d *OracleDialect) QueryCreateMigrateSchema(schemaName string) string

func (*OracleDialect) QueryCreateMigrateTable

func (d *OracleDialect) QueryCreateMigrateTable(schemaName, tableName string) string

func (*OracleDialect) QueryDeleteMigrate

func (d *OracleDialect) QueryDeleteMigrate(schemaName, tableName string) string

func (*OracleDialect) QueryInsertMigrate

func (d *OracleDialect) QueryInsertMigrate(schemaName, tableName string) string

func (*OracleDialect) QuerySelectMigrate

func (d *OracleDialect) QuerySelectMigrate(schemaName, tableName string) string

type PostgresDialect

type PostgresDialect struct {
}

PostgresDialect Implementation of Dialect for PostgreSQL databases.

func NewPostgresDialect

func NewPostgresDialect() *PostgresDialect

func (*PostgresDialect) QueryCreateMigrateSchema

func (d *PostgresDialect) QueryCreateMigrateSchema(schemaName string) string

func (*PostgresDialect) QueryCreateMigrateTable

func (d *PostgresDialect) QueryCreateMigrateTable(schemaName, tableName string) string

func (*PostgresDialect) QueryDeleteMigrate

func (d *PostgresDialect) QueryDeleteMigrate(schemaName, tableName string) string

func (*PostgresDialect) QueryInsertMigrate

func (d *PostgresDialect) QueryInsertMigrate(schemaName, tableName string) string

func (*PostgresDialect) QuerySelectMigrate

func (d *PostgresDialect) QuerySelectMigrate(schemaName, tableName string) string

type SnowflakeDialect

type SnowflakeDialect struct {
}

func NewSnowflakeDialect

func NewSnowflakeDialect() *SnowflakeDialect

func (*SnowflakeDialect) QueryCreateMigrateSchema

func (d *SnowflakeDialect) QueryCreateMigrateSchema(schemaName string) string

func (*SnowflakeDialect) QueryCreateMigrateTable

func (d *SnowflakeDialect) QueryCreateMigrateTable(schemaName, tableName string) string

func (*SnowflakeDialect) QueryDeleteMigrate

func (d *SnowflakeDialect) QueryDeleteMigrate(schemaName, tableName string) string

func (*SnowflakeDialect) QueryInsertMigrate

func (d *SnowflakeDialect) QueryInsertMigrate(schemaName, tableName string) string

func (*SnowflakeDialect) QuerySelectMigrate

func (d *SnowflakeDialect) QuerySelectMigrate(schemaName, tableName string) string

type SqlServerDialect

type SqlServerDialect struct {
}

func NewSqlServerDialect

func NewSqlServerDialect() *SqlServerDialect

func (*SqlServerDialect) QueryCreateMigrateSchema

func (d *SqlServerDialect) QueryCreateMigrateSchema(schemaName string) string

func (*SqlServerDialect) QueryCreateMigrateTable

func (d *SqlServerDialect) QueryCreateMigrateTable(schemaName, tableName string) string

func (*SqlServerDialect) QueryDeleteMigrate

func (d *SqlServerDialect) QueryDeleteMigrate(schemaName, tableName string) string

func (*SqlServerDialect) QueryInsertMigrate

func (d *SqlServerDialect) QueryInsertMigrate(schemaName, tableName string) string

func (*SqlServerDialect) QuerySelectMigrate

func (d *SqlServerDialect) QuerySelectMigrate(schemaName, tableName string) string

type SqliteDialect

type SqliteDialect struct {
}

func NewSqliteDialect

func NewSqliteDialect() *SqliteDialect

func (*SqliteDialect) QueryCreateMigrateSchema

func (d *SqliteDialect) QueryCreateMigrateSchema(_ string) string

func (*SqliteDialect) QueryCreateMigrateTable

func (d *SqliteDialect) QueryCreateMigrateTable(schemaName, tableName string) string

func (*SqliteDialect) QueryDeleteMigrate

func (d *SqliteDialect) QueryDeleteMigrate(schemaName, tableName string) string

func (*SqliteDialect) QueryInsertMigrate

func (d *SqliteDialect) QueryInsertMigrate(schemaName, tableName string) string

func (*SqliteDialect) QuerySelectMigrate

func (d *SqliteDialect) QuerySelectMigrate(schemaName, tableName string) string