Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

ddl

package

Go to main page

Versions in this module

v1

v1.1.0-alpha

Oct 31, 2017

v1.0.9

Apr 20, 2018

v1.0.7

Jan 19, 2018

Changes in this version

type DDL

+ GetHook func() Callback

v1.0.0

Oct 16, 2017

Changes in this version

+ const DDLAllSchemaVersions

+ const DDLGlobalSchemaVersion

+ const DDLOwnerKey

+ const InitialVersion

+ var CheckVersFirstWaitTime = 50 * time.Millisecond

+ var EnableSplitTableRegion = false

+ var ErrCantDropFieldOrKey = terror.ClassDDL.New(codeCantDropFieldOrKey, "can't drop field; check that column/key exists")

+ var ErrCantRemoveAllFields = terror.ClassDDL.New(codeCantRemoveAllFields, "can't delete all columns with ALTER TABLE")

+ var ErrColumnBadNull = terror.ClassDDL.New(codeBadNull, "column cann't be null")

+ var ErrInvalidColumnState = terror.ClassDDL.New(codeInvalidColumnState, "invalid column state")

+ var ErrInvalidDBState = terror.ClassDDL.New(codeInvalidDBState, "invalid database state")

+ var ErrInvalidForeignKeyState = terror.ClassDDL.New(codeInvalidForeignKeyState, "invalid foreign key state")

+ var ErrInvalidIndexState = terror.ClassDDL.New(codeInvalidIndexState, "invalid index state")

+ var ErrInvalidOnUpdate = terror.ClassDDL.New(codeInvalidOnUpdate, "invalid ON UPDATE clause for the column")

+ var ErrInvalidTableState = terror.ClassDDL.New(codeInvalidTableState, "invalid table state")

+ var ErrTooLongIdent = terror.ClassDDL.New(codeTooLongIdent, "Identifier name too long")

+ var ErrUnsupportedModifyPrimaryKey = terror.ClassDDL.New(codeUnsupportedModifyPrimaryKey, "unsupported %s primary key")

+ var ErrWrongColumnName = terror.ClassDDL.New(codeWrongColumnName, mysql.MySQLErrName[mysql.ErrWrongColumnName])

+ var ErrWrongDBName = terror.ClassDDL.New(codeWrongDBName, mysql.MySQLErrName[mysql.ErrWrongDBName])

+ var ErrWrongNameForIndex = terror.ClassDDL.New(codeWrongNameForIndex, mysql.MySQLErrName[mysql.ErrWrongNameForIndex])

+ var ErrWrongTableName = terror.ClassDDL.New(codeWrongTableName, mysql.MySQLErrName[mysql.ErrWrongTableName])

+ var RunWorker = true

+ var SyncerSessionTTL = 10 * 60

+ var TableColumnCountLimit = 512

+ type BaseCallback struct

+ func (c *BaseCallback) OnChanged(err error) error

+ func (c *BaseCallback) OnJobRunBefore(job *model.Job)

+ func (c *BaseCallback) OnJobUpdated(job *model.Job)

+ func (c *BaseCallback) OnWatched(ctx goctx.Context)

+ type Callback interface

+ OnChanged func(err error) error

+ OnJobRunBefore func(job *model.Job)

+ OnJobUpdated func(job *model.Job)

+ OnWatched func(ctx goctx.Context)

+ type DDL interface

+ AlterTable func(ctx context.Context, tableIdent ast.Ident, spec []*ast.AlterTableSpec) error

+ CreateIndex func(ctx context.Context, tableIdent ast.Ident, unique bool, indexName model.CIStr, ...) error

+ CreateSchema func(ctx context.Context, name model.CIStr, charsetInfo *ast.CharsetOpt) error

+ CreateTable func(ctx context.Context, ident ast.Ident, cols []*ast.ColumnDef, ...) error

+ CreateTableWithLike func(ctx context.Context, ident, referIdent ast.Ident) error

+ DropIndex func(ctx context.Context, tableIdent ast.Ident, indexName model.CIStr) error

+ DropSchema func(ctx context.Context, schema model.CIStr) error

+ DropTable func(ctx context.Context, tableIdent ast.Ident) (err error)

+ GetInformationSchema func() infoschema.InfoSchema

+ GetLease func() time.Duration

+ GetScope func(status string) variable.ScopeFlag

+ OwnerManager func() owner.Manager

+ RegisterEventCh func(chan<- *Event)

+ RenameTable func(ctx context.Context, oldTableIdent, newTableIdent ast.Ident) error

+ SchemaSyncer func() SchemaSyncer

+ SetHook func(h Callback)

+ SetLease func(ctx goctx.Context, lease time.Duration)

+ Stats func(vars *variable.SessionVars) (map[string]interface{}, error)

+ Stop func() error

+ TruncateTable func(ctx context.Context, tableIdent ast.Ident) error

+ WorkerVars func() *variable.SessionVars

+ func NewDDL(ctx goctx.Context, etcdCli *clientv3.Client, store kv.Storage, ...) DDL

+ type Event struct

+ ColumnInfo *model.ColumnInfo

+ IndexInfo *model.IndexInfo

+ TableInfo *model.TableInfo

+ Tp model.ActionType

+ func (e *Event) String() string

+ type SchemaSyncer interface

+ Done func() <-chan struct{}

+ GlobalVersionCh func() clientv3.WatchChan

+ Init func(ctx goctx.Context) error

+ MustGetGlobalVersion func(ctx goctx.Context) (int64, error)

+ OwnerCheckAllVersions func(ctx goctx.Context, latestVer int64) error

+ OwnerUpdateGlobalVersion func(ctx goctx.Context, version int64) error

+ RemoveSelfVersionPath func() error

+ Restart func(ctx goctx.Context) error

+ UpdateSelfVersion func(ctx goctx.Context, version int64) error

+ func NewMockSchemaSyncer() SchemaSyncer

+ func NewSchemaSyncer(etcdCli *clientv3.Client, id string) SchemaSyncer