meta

Documentation

Index

• Variables
• type JobListKeyType
• type Meta
  • func NewMeta(txn kv.Transaction) *Meta
  • func NewSnapshotMeta(snapshot kv.Snapshot) *Meta
  • func (m *Meta) AddHistoryDDLJob(job *model.Job) error
  • func (m *Meta) CreateDatabase(dbInfo *model.DBInfo) error
  • func (m *Meta) CreateTable(dbID int64, tableInfo *model.TableInfo) error
  • func (m *Meta) DDLJobQueueLen() (int64, error)
  • func (m *Meta) DeQueueDDLJob() (*model.Job, error)
  • func (m *Meta) DropDatabase(dbID int64) error
  • func (m *Meta) DropTable(dbID int64, tblID int64, delAutoID bool) error
  • func (m *Meta) EnQueueDDLJob(job *model.Job) error
  • func (m *Meta) FinishBootstrap(version int64) error
  • func (m *Meta) GenAutoTableID(dbID, tableID, step int64) (int64, error)
  • func (m *Meta) GenAutoTableIDIDKeyValue(dbID, tableID, autoID int64) (key, value []byte)
  • func (m *Meta) GenGlobalID() (int64, error)
  • func (m *Meta) GenSchemaVersion() (int64, error)
  • func (m *Meta) GetAllDDLJobs() ([]*model.Job, error)
  • func (m *Meta) GetAllHistoryDDLJobs() ([]*model.Job, error)
  • func (m *Meta) GetAutoTableID(dbID int64, tableID int64) (int64, error)
  • func (m *Meta) GetBootstrapVersion() (int64, error)
  • func (m *Meta) GetDDLJob(index int64) (*model.Job, error)
  • func (m *Meta) GetDDLReorgHandle(job *model.Job) (int64, error)
  • func (m *Meta) GetDatabase(dbID int64) (*model.DBInfo, error)
  • func (m *Meta) GetGlobalID() (int64, error)
  • func (m *Meta) GetHistoryDDLJob(id int64) (*model.Job, error)
  • func (m *Meta) GetSchemaDiff(schemaVersion int64) (*model.SchemaDiff, error)
  • func (m *Meta) GetSchemaVersion() (int64, error)
  • func (m *Meta) GetTable(dbID int64, tableID int64) (*model.TableInfo, error)
  • func (m *Meta) ListDatabases() ([]*model.DBInfo, error)
  • func (m *Meta) ListTables(dbID int64) ([]*model.TableInfo, error)
  • func (m *Meta) RemoveDDLReorgHandle(job *model.Job) error
  • func (m *Meta) SetJobListKey(key []byte)
  • func (m *Meta) SetSchemaDiff(diff *model.SchemaDiff) error
  • func (m *Meta) UpdateDDLJob(index int64, job *model.Job, updateRawArgs bool) error
  • func (m *Meta) UpdateDDLReorgHandle(job *model.Job, handle int64) error
  • func (m *Meta) UpdateDatabase(dbInfo *model.DBInfo) error
  • func (m *Meta) UpdateTable(dbID int64, tableInfo *model.TableInfo) error

Variables

var (

	// ErrDBExists is the error for db exists.
	ErrDBExists = terror.ClassMeta.New(codeDatabaseExists, "database already exists")
	// ErrDBNotExists is the error for db not exists.
	ErrDBNotExists = terror.ClassMeta.New(codeDatabaseNotExists, "database doesn't exist")
	// ErrTableExists is the error for table exists.
	ErrTableExists = terror.ClassMeta.New(codeTableExists, "table already exists")
	// ErrTableNotExists is the error for table not exists.
	ErrTableNotExists = terror.ClassMeta.New(codeTableNotExists, "table doesn't exist")
)

Types

type JobListKeyType

type JobListKeyType []byte

JobListKeyType is a key type of the DDL job queue.

var (
	// DefaultJobListKey keeps all actions of DDL jobs.
	DefaultJobListKey JobListKeyType = mDDLJobListKey
	// AddIndexJobListKey only keeps the action of adding index.
	AddIndexJobListKey JobListKeyType = mDDLJobAddIdxList
)

type Meta

type Meta struct {
	StartTS uint64 // StartTS is the txn's start TS.
	// contains filtered or unexported fields
}

Meta is for handling meta information in a transaction.

func NewMeta

func NewMeta(txn kv.Transaction) *Meta

NewMeta creates a Meta in transaction txn.

func NewSnapshotMeta

func NewSnapshotMeta(snapshot kv.Snapshot) *Meta

NewSnapshotMeta creates a Meta with snapshot.

func (*Meta) AddHistoryDDLJob

func (m *Meta) AddHistoryDDLJob(job *model.Job) error

AddHistoryDDLJob adds DDL job to history.

func (*Meta) CreateDatabase

func (m *Meta) CreateDatabase(dbInfo *model.DBInfo) error

CreateDatabase creates a database with db info.

func (*Meta) CreateTable

func (m *Meta) CreateTable(dbID int64, tableInfo *model.TableInfo) error

CreateTable creates a table with tableInfo in database.

func (*Meta) DDLJobQueueLen

func (m *Meta) DDLJobQueueLen() (int64, error)

DDLJobQueueLen returns the DDL job queue length.

func (*Meta) DeQueueDDLJob

func (m *Meta) DeQueueDDLJob() (*model.Job, error)

DeQueueDDLJob pops a DDL job from the list.

func (*Meta) DropDatabase

func (m *Meta) DropDatabase(dbID int64) error

DropDatabase drops whole database.

func (*Meta) DropTable

func (m *Meta) DropTable(dbID int64, tblID int64, delAutoID bool) error

DropTable drops table in database. If delAutoID is true, it will delete the auto_increment id key-value of the table. For rename table, we do not need to rename auto_increment id key-value.

func (*Meta) EnQueueDDLJob

func (m *Meta) EnQueueDDLJob(job *model.Job) error

EnQueueDDLJob adds a DDL job to the list.

func (*Meta) FinishBootstrap

func (m *Meta) FinishBootstrap(version int64) error

FinishBootstrap finishes bootstrap.

func (*Meta) GenAutoTableID

func (m *Meta) GenAutoTableID(dbID, tableID, step int64) (int64, error)

GenAutoTableID adds step to the auto ID of the table and returns the sum.

func (*Meta) GenAutoTableIDIDKeyValue

func (m *Meta) GenAutoTableIDIDKeyValue(dbID, tableID, autoID int64) (key, value []byte)

GenAutoTableIDIDKeyValue generate meta key by dbID, tableID and coresponding value by autoID.

func (*Meta) GenGlobalID

func (m *Meta) GenGlobalID() (int64, error)

GenGlobalID generates next id globally.

func (*Meta) GenSchemaVersion

func (m *Meta) GenSchemaVersion() (int64, error)

GenSchemaVersion generates next schema version.

func (*Meta) GetAllDDLJobs

func (m *Meta) GetAllDDLJobs() ([]*model.Job, error)

GetAllDDLJobs gets all DDL Jobs.

func (*Meta) GetAllHistoryDDLJobs

func (m *Meta) GetAllHistoryDDLJobs() ([]*model.Job, error)

GetAllHistoryDDLJobs gets all history DDL jobs.

func (*Meta) GetAutoTableID

func (m *Meta) GetAutoTableID(dbID int64, tableID int64) (int64, error)

GetAutoTableID gets current auto id with table id.

func (*Meta) GetBootstrapVersion

func (m *Meta) GetBootstrapVersion() (int64, error)

GetBootstrapVersion returns the version of the server which boostrap the store. If the store is not bootstraped, the version will be zero.

func (*Meta) GetDDLJob

func (m *Meta) GetDDLJob(index int64) (*model.Job, error)

GetDDLJob returns the DDL job with index.

func (*Meta) GetDDLReorgHandle

func (m *Meta) GetDDLReorgHandle(job *model.Job) (int64, error)

GetDDLReorgHandle gets the latest processed handle.

func (*Meta) GetDatabase

func (m *Meta) GetDatabase(dbID int64) (*model.DBInfo, error)

GetDatabase gets the database value with ID.

func (*Meta) GetGlobalID

func (m *Meta) GetGlobalID() (int64, error)

GetGlobalID gets current global id.

func (*Meta) GetHistoryDDLJob

func (m *Meta) GetHistoryDDLJob(id int64) (*model.Job, error)

GetHistoryDDLJob gets a history DDL job.

func (*Meta) GetSchemaDiff

func (m *Meta) GetSchemaDiff(schemaVersion int64) (*model.SchemaDiff, error)

GetSchemaDiff gets the modification information on a given schema version.

func (*Meta) GetSchemaVersion

func (m *Meta) GetSchemaVersion() (int64, error)

GetSchemaVersion gets current global schema version.

func (*Meta) GetTable

func (m *Meta) GetTable(dbID int64, tableID int64) (*model.TableInfo, error)

GetTable gets the table value in database with tableID.

func (*Meta) ListDatabases

func (m *Meta) ListDatabases() ([]*model.DBInfo, error)

ListDatabases shows all databases.

func (*Meta) ListTables

func (m *Meta) ListTables(dbID int64) ([]*model.TableInfo, error)

ListTables shows all tables in database.

func (*Meta) RemoveDDLReorgHandle

func (m *Meta) RemoveDDLReorgHandle(job *model.Job) error

RemoveDDLReorgHandle removes the job reorganization handle.

func (*Meta) SetJobListKey

func (m *Meta) SetJobListKey(key []byte)

SetJobListKey sets the job list key.

func (*Meta) SetSchemaDiff

func (m *Meta) SetSchemaDiff(diff *model.SchemaDiff) error

SetSchemaDiff sets the modification information on a given schema version.

func (*Meta) UpdateDDLJob

func (m *Meta) UpdateDDLJob(index int64, job *model.Job, updateRawArgs bool) error

UpdateDDLJob updates the DDL job with index. updateRawArgs is used to determine whether to update the raw args when encode the job.

func (*Meta) UpdateDDLReorgHandle

func (m *Meta) UpdateDDLReorgHandle(job *model.Job, handle int64) error

UpdateDDLReorgHandle saves the job reorganization latest processed handle for later resuming.

func (*Meta) UpdateDatabase

func (m *Meta) UpdateDatabase(dbInfo *model.DBInfo) error

UpdateDatabase updates a database with db info.

func (*Meta) UpdateTable

func (m *Meta) UpdateTable(dbID int64, tableInfo *model.TableInfo) error

UpdateTable updates the table with table info.