mysql

Documentation

Index

• Constants
• func LoadPtTemplateFromFile(fileName string) error
• func NewDriverManagerFunc(log *logrus.Entry, dbType string, config *driver.Config, ...) (driver.DriverManager, error)
• type Config
• type DriverManager
  • func (d *DriverManager) Close(ctx context.Context)
  • func (d *DriverManager) GetAnalysisDriver() (driver.AnalysisDriver, error)
  • func (d *DriverManager) GetAuditDriver() (driver.Driver, error)
  • func (d *DriverManager) GetSQLQueryDriver() (driver.SQLQueryDriver, error)
• type MysqlDriverImpl
  • func NewInspect(log *logrus.Entry, cfg *driver.Config) (*MysqlDriverImpl, error)
  • func (i *MysqlDriverImpl) Audit(ctx context.Context, sql string) (*driver.AuditResult, error)
  • func (i *MysqlDriverImpl) CheckExplain(node ast.Node) error
  • func (i *MysqlDriverImpl) CheckInvalid(node ast.Node) error
  • func (i *MysqlDriverImpl) CheckInvalidOffline(node ast.Node) error
  • func (i *MysqlDriverImpl) Close(ctx context.Context)
  • func (i *MysqlDriverImpl) Context() *session.Context
  • func (i *MysqlDriverImpl) Exec(ctx context.Context, query string) (_driver.Result, error)
  • func (i *MysqlDriverImpl) GenRollbackSQL(ctx context.Context, sql string) (string, string, error)
  • func (i *MysqlDriverImpl) GenerateDDLStmtRollbackSql(node ast.Node) (rollbackSql, unableRollbackReason string, err error)
  • func (i *MysqlDriverImpl) GenerateDMLStmtRollbackSql(node ast.Node) (rollbackSql, unableRollbackReason string, err error)
  • func (i *MysqlDriverImpl) GenerateRollbackSql(node ast.Node) (string, string, error)
  • func (i *MysqlDriverImpl) IsExecutedSQL() bool
  • func (i *MysqlDriverImpl) IsOfflineAudit() bool
  • func (i *MysqlDriverImpl) Logger() *logrus.Entry
  • func (i *MysqlDriverImpl) Parse(ctx context.Context, sqlText string) ([]driver.Node, error)
  • func (i *MysqlDriverImpl) ParseSql(sql string) ([]ast.Node, error)
  • func (i *MysqlDriverImpl) Ping(ctx context.Context) error
  • func (i *MysqlDriverImpl) Schemas(ctx context.Context) ([]string, error)
  • func (i *MysqlDriverImpl) Tx(ctx context.Context, queries ...string) ([]_driver.Result, error)

Constants

const (
	SchemaNotExistMessage              = "schema %s 不存在"
	SchemaExistMessage                 = "schema %s 已存在"
	TableNotExistMessage               = "表 %s 不存在"
	TableExistMessage                  = "表 %s 已存在"
	ColumnNotExistMessage              = "字段 %s 不存在"
	ColumnExistMessage                 = "字段 %s 已存在"
	ColumnIsAmbiguousMessage           = "字段 %s 指代不明"
	IndexNotExistMessage               = "索引 %s 不存在"
	IndexExistMessage                  = "索引 %s 已存在"
	DuplicateColumnsMessage            = "字段名 %s 重复"
	DuplicateIndexesMessage            = "索引名 %s 重复"
	MultiPrimaryKeyMessage             = "主键只能设置一个"
	KeyedColumnNotExistMessage         = "索引字段 %s 不存在"
	PrimaryKeyExistMessage             = "已经存在主键，不能再添加"
	PrimaryKeyNotExistMessage          = "当前没有主键，不能执行删除"
	ColumnsValuesNotMatchMessage       = "指定的值列数与字段列数不匹配"
	DuplicatePrimaryKeyedColumnMessage = "主键字段 %s 重复"
	DuplicateIndexedColumnMessage      = "索引 %s 字段 %s重复"
)

const (
	PTOSCNoUniqueIndexOrPrimaryKey          = "至少要包含主键或者唯一键索引才能使用 pt-online-schema-change"
	PTOSCAvoidUniqueIndex                   = "" /* 127-byte string literal not displayed */
	PTOSCAvoidRenameTable                   = "pt-online-schema-change 不支持使用rename table 来重命名表"
	PTOSCAvoidNoDefaultValueOnNotNullColumn = "非空字段必须设置默认值，不然 pt-online-schema-change 会执行失败"
)

const (
	NotSupportStatementRollback               = "暂不支持回滚该类型的语句"
	NotSupportMultiTableStatementRollback     = "暂不支持回滚多表的 DML 语句"
	NotSupportOnDuplicatStatementRollback     = "暂不支持回滚 ON DUPLICATE 语句"
	NotSupportSubQueryStatementRollback       = "暂不支持回滚带子查询的语句"
	NotSupportNoPrimaryKeyTableRollback       = "不支持回滚没有主键的表的DML语句"
	NotSupportInsertWithoutPrimaryKeyRollback = "不支持回滚 INSERT 没有指定主键的语句"
	NotSupportParamMarkerStatementRollback    = "不支持回滚包含指纹的语句"
	NotSupportExceedMaxRowsRollback           = "预计影响行数超过配置的最大值，不生成回滚语句"
)

const CheckInvalidErrorFormat = "预检查失败: %v"

Functions

func LoadPtTemplateFromFile

func LoadPtTemplateFromFile(fileName string) error

func NewDriverManagerFunc

func NewDriverManagerFunc(log *logrus.Entry, dbType string, config *driver.Config, client *driver.PluginClient) (driver.DriverManager, error)

Types

type Config

type Config struct {
	DMLRollbackMaxRows int64
	DDLOSCMinSize      int64
	DDLGhostMinSize    int64
	// contains filtered or unexported fields
}

type DriverManager

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

func (*DriverManager) Close

func (d *DriverManager) Close(ctx context.Context)

func (*DriverManager) GetAnalysisDriver

func (d *DriverManager) GetAnalysisDriver() (driver.AnalysisDriver, error)

func (*DriverManager) GetAuditDriver

func (d *DriverManager) GetAuditDriver() (driver.Driver, error)

func (*DriverManager) GetSQLQueryDriver

func (d *DriverManager) GetSQLQueryDriver() (driver.SQLQueryDriver, error)

type MysqlDriverImpl

type MysqlDriverImpl struct {
	// Ctx is SQL session.
	Ctx *session.Context

	// HasInvalidSql represent one of the commit sql base-validation failed.
	HasInvalidSql bool
	// contains filtered or unexported fields
}

MysqlDriverImpl implements driver.Driver interface

func NewInspect

func NewInspect(log *logrus.Entry, cfg *driver.Config) (*MysqlDriverImpl, error)

func (*MysqlDriverImpl) Audit

func (i *MysqlDriverImpl) Audit(ctx context.Context, sql string) (*driver.AuditResult, error)

func (*MysqlDriverImpl) CheckExplain

func (i *MysqlDriverImpl) CheckExplain(node ast.Node) error

func (*MysqlDriverImpl) CheckInvalid

func (i *MysqlDriverImpl) CheckInvalid(node ast.Node) error

func (*MysqlDriverImpl) CheckInvalidOffline

func (i *MysqlDriverImpl) CheckInvalidOffline(node ast.Node) error

func (*MysqlDriverImpl) Close

func (i *MysqlDriverImpl) Close(ctx context.Context)

func (*MysqlDriverImpl) Context

func (i *MysqlDriverImpl) Context() *session.Context

func (*MysqlDriverImpl) Exec

func (i *MysqlDriverImpl) Exec(ctx context.Context, query string) (_driver.Result, error)

func (*MysqlDriverImpl) GenRollbackSQL

func (i *MysqlDriverImpl) GenRollbackSQL(ctx context.Context, sql string) (string, string, error)

func (*MysqlDriverImpl) GenerateDDLStmtRollbackSql

func (i *MysqlDriverImpl) GenerateDDLStmtRollbackSql(node ast.Node) (rollbackSql, unableRollbackReason string, err error)

func (*MysqlDriverImpl) GenerateDMLStmtRollbackSql

func (i *MysqlDriverImpl) GenerateDMLStmtRollbackSql(node ast.Node) (rollbackSql, unableRollbackReason string, err error)

func (*MysqlDriverImpl) GenerateRollbackSql

func (i *MysqlDriverImpl) GenerateRollbackSql(node ast.Node) (string, string, error)

func (*MysqlDriverImpl) IsExecutedSQL

func (i *MysqlDriverImpl) IsExecutedSQL() bool

func (*MysqlDriverImpl) IsOfflineAudit

func (i *MysqlDriverImpl) IsOfflineAudit() bool

func (*MysqlDriverImpl) Logger

func (i *MysqlDriverImpl) Logger() *logrus.Entry

func (*MysqlDriverImpl) Parse

func (i *MysqlDriverImpl) Parse(ctx context.Context, sqlText string) ([]driver.Node, error)

func (*MysqlDriverImpl) ParseSql

func (i *MysqlDriverImpl) ParseSql(sql string) ([]ast.Node, error)

func (*MysqlDriverImpl) Ping

func (i *MysqlDriverImpl) Ping(ctx context.Context) error

func (*MysqlDriverImpl) Schemas

func (i *MysqlDriverImpl) Schemas(ctx context.Context) ([]string, error)

func (*MysqlDriverImpl) Tx

func (i *MysqlDriverImpl) Tx(ctx context.Context, queries ...string) ([]_driver.Result, error)