Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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
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

mysql

package module

Go to main page

Versions in this module

v1

v1.6.2

Aug 24, 2022

Changes in this version

+ func RegisterATResource(dsn string)

+ func RegisterXAResource(db *sql.DB)

+ type ResourceManager struct

+ func (resourceManager ResourceManager) Commit(ctx context.Context, bs *api.BranchSession) (api.BranchSession_BranchStatus, error)

+ func (resourceManager ResourceManager) Rollback(ctx context.Context, bs *api.BranchSession) (api.BranchSession_BranchStatus, error)

v1.6.1

Jul 29, 2022

v1.6.0

Jun 9, 2022

Changes in this version

+ const ARRAY

+ const BIGINT

+ const BINARY

+ const BIT

+ const BLOB

+ const BOOLEAN

+ const CHAR

+ const CLOB

+ const DATALINK

+ const DATE

+ const DECIMAL

+ const DISTINCT

+ const DOUBLE

+ const DeleteSqlTemplate

+ const DeleteUndoLogByCreateSql

+ const DeleteUndoLogSql

+ const FLOAT

+ const GlobalLock

+ const INTEGER

+ const InsertSqlTemplate

+ const InsertUndoLogSql

+ const JAVA_OBJECT

+ const LONGNVARCHAR

+ const LONGVARBINARY

+ const LONGVARCHAR

+ const NCHAR

+ const NCLOB

+ const NULL

+ const NUMERIC

+ const NVARCHAR

+ const OTHER

+ const REAL

+ const REF

+ const REF_CURSOR

+ const ROWID

+ const SMALLINT

+ const SQLXML

+ const STRUCT

+ const SelectSqlTemplate

+ const SelectUndoLogSql

+ const TIME

+ const TIMESTAMP

+ const TIMESTAMP_WITH_TIMEZONE

+ const TIME_WITH_TIMEZONE

+ const TINYINT

+ const UpdateSqlTemplate

+ const VARBINARY

+ const VARCHAR

+ const XID

+ var EXPIRE_TIME = 15 * time.Minute

+ var ErrBusyBuffer = errors.New("busy buffer")

+ var ErrCleartextPassword = errors.New(...)

+ var ErrInvalidConn = errors.New("invalid connection")

+ var ErrMalformPkt = errors.New("malformed packet")

+ var ErrNativePassword = errors.New("this user requires mysql native password authentication.")

+ var ErrNoTLS = errors.New("TLS requested but server does not support TLS")

+ var ErrOldPassword = errors.New(...)

+ var ErrOldProtocol = errors.New("MySQL server does not support required protocol 41+")

+ var ErrPktSync = errors.New("commands out of sync. You can't run this command now")

+ var ErrPktSyncMul = errors.New("commands out of sync. Did you run multiple statements at once?")

+ var ErrPktTooLarge = errors.New(...)

+ var ErrUnknownPlugin = errors.New("this authentication plugin is not supported")

+ var File_table_records_proto protoreflect.FileDescriptor

+ var File_undo_log_proto protoreflect.FileDescriptor

+ var SqlDataTypes = map[string]int32

+ func DeleteBuildUndoSql(undoLog sqlUndoLog) string

+ func DeregisterLocalFile(filePath string)

+ func DeregisterReaderHandler(name string)

+ func DeregisterServerPubKey(name string)

+ func DeregisterTLSConfig(key string)

+ func GetColumns(conn *mysqlConn, dbName, tableName string) ([]schema.ColumnMeta, error)

+ func GetIndexes(conn *mysqlConn, dbName, tableName string) ([]schema.IndexMeta, error)

+ func GetSqlDataType(dataType string) int32

+ func InitTableMetaCache(dbName string)

+ func InsertBuildUndoSql(undoLog sqlUndoLog) string

+ func NewConnector(cfg *Config) (driver.Connector, error)

+ func RegisterDial(network string, dial DialFunc)

+ func RegisterDialContext(net string, dial DialContextFunc)

+ func RegisterLocalFile(filePath string)

+ func RegisterReaderHandler(name string, handler func() io.Reader)

+ func RegisterResource(dsn string)

+ func RegisterServerPubKey(name string, pubKey *rsa.PublicKey)

+ func RegisterTLSConfig(key string, config *tls.Config) error

+ func SetLogger(logger Logger) error

+ func UpdateBuildUndoSql(undoLog sqlUndoLog) string

+ type BuildUndoSql func(undoLog sqlUndoLog) string

+ type Config struct

+ Addr string

+ AllowAllFiles bool

+ AllowCleartextPasswords bool

+ AllowNativePasswords bool

+ AllowOldPasswords bool

+ CheckConnLiveness bool

+ ClientFoundRows bool

+ Collation string

+ ColumnsWithAlias bool

+ DBName string

+ InterpolateParams bool

+ Loc *time.Location

+ MaxAllowedPacket int

+ MultiStatements bool

+ Net string

+ Params map[string]string

+ ParseTime bool

+ Passwd string

+ ReadTimeout time.Duration

+ RejectReadOnly bool

+ ServerPubKey string

+ TLSConfig string

+ Timeout time.Duration

+ User string

+ WriteTimeout time.Duration

+ func NewConfig() *Config

+ func ParseDSN(dsn string) (cfg *Config, err error)

+ func (cfg *Config) Clone() *Config

+ func (cfg *Config) FormatDSN() string

+ type DataSourceManager struct

+ ResourceCache map[string]*connector

+ func GetDataSourceManager() DataSourceManager

+ func (resourceManager DataSourceManager) Commit(ctx context.Context, request *api.BranchSession) (api.BranchSession_BranchStatus, error)

+ func (resourceManager DataSourceManager) GetConnection(resourceID string) *mysqlConn

+ func (resourceManager DataSourceManager) Rollback(ctx context.Context, request *api.BranchSession) (api.BranchSession_BranchStatus, error)

+ type DialContextFunc func(ctx context.Context, addr string) (net.Conn, error)

+ type DialFunc func(addr string) (net.Conn, error)

+ type Logger interface

+ Print func(v ...interface{})

+ type MySQLDriver struct

+ func (d MySQLDriver) Open(dsn string) (driver.Conn, error)

+ func (d MySQLDriver) OpenConnector(dsn string) (driver.Connector, error)

+ type MySQLError struct

+ Message string

+ Number uint16

+ SQLState [5]byte

+ func (me *MySQLError) Error() string

+ func (me *MySQLError) Is(err error) bool

+ type NullTime sql.NullTime

+ func (nt *NullTime) Scan(value interface{}) (err error)

+ func (nt NullTime) Value() (driver.Value, error)

+ type PbBranchUndoLog struct

+ BranchSessionID int64

+ SqlUndoLogs []*PbSqlUndoLog

+ XID string

+ func (*PbBranchUndoLog) Descriptor() ([]byte, []int)

+ func (*PbBranchUndoLog) ProtoMessage()

+ func (x *PbBranchUndoLog) GetBranchSessionID() int64

+ func (x *PbBranchUndoLog) GetSqlUndoLogs() []*PbSqlUndoLog

+ func (x *PbBranchUndoLog) GetXID() string

+ func (x *PbBranchUndoLog) ProtoReflect() protoreflect.Message

+ func (x *PbBranchUndoLog) Reset()

+ func (x *PbBranchUndoLog) String() string

+ type PbField struct

+ KeyType int32

+ Name string

+ Type int32

+ Value []byte

+ func (*PbField) Descriptor() ([]byte, []int)

+ func (*PbField) ProtoMessage()

+ func (x *PbField) GetKeyType() int32

+ func (x *PbField) GetName() string

+ func (x *PbField) GetType() int32

+ func (x *PbField) GetValue() []byte

+ func (x *PbField) ProtoReflect() protoreflect.Message

+ func (x *PbField) Reset()

+ func (x *PbField) String() string

+ type PbRow struct

+ Fields []*PbField

+ func (*PbRow) Descriptor() ([]byte, []int)

+ func (*PbRow) ProtoMessage()

+ func (x *PbRow) GetFields() []*PbField

+ func (x *PbRow) ProtoReflect() protoreflect.Message

+ func (x *PbRow) Reset()

+ func (x *PbRow) String() string

+ type PbSqlUndoLog struct

+ AfterImage *PbTableRecords

+ BeforeImage *PbTableRecords

+ LockKey string

+ SchemaName string

+ SqlType int32

+ TableName string

+ func (*PbSqlUndoLog) Descriptor() ([]byte, []int)

+ func (*PbSqlUndoLog) ProtoMessage()

+ func (x *PbSqlUndoLog) GetAfterImage() *PbTableRecords

+ func (x *PbSqlUndoLog) GetBeforeImage() *PbTableRecords

+ func (x *PbSqlUndoLog) GetLockKey() string

+ func (x *PbSqlUndoLog) GetSchemaName() string

+ func (x *PbSqlUndoLog) GetSqlType() int32

+ func (x *PbSqlUndoLog) GetTableName() string

+ func (x *PbSqlUndoLog) ProtoReflect() protoreflect.Message

+ func (x *PbSqlUndoLog) Reset()

+ func (x *PbSqlUndoLog) String() string

+ type PbTableRecords struct

+ Rows []*PbRow

+ TableName string

+ func (*PbTableRecords) Descriptor() ([]byte, []int)

+ func (*PbTableRecords) ProtoMessage()

+ func (x *PbTableRecords) GetRows() []*PbRow

+ func (x *PbTableRecords) GetTableName() string

+ func (x *PbTableRecords) ProtoReflect() protoreflect.Message

+ func (x *PbTableRecords) Reset()

+ func (x *PbTableRecords) String() string

+ type ProtoBufUndoLogParser struct

+ func (parser ProtoBufUndoLogParser) Decode(data []byte) *branchUndoLog

+ func (parser ProtoBufUndoLogParser) Encode(branchUndoLog *branchUndoLog) []byte

+ func (parser ProtoBufUndoLogParser) GetDefaultContent() []byte

+ func (parser ProtoBufUndoLogParser) GetName() string

+ type RawBytes []byte

+ type SQLType byte

+ const SQLType_ALTER

+ const SQLType_ALTER_TABLE

+ const SQLType_CREATE

+ const SQLType_CREATE_INDEX

+ const SQLType_CREATE_TABLE

+ const SQLType_DEBUG

+ const SQLType_DELETE

+ const SQLType_DESC

+ const SQLType_DROP

+ const SQLType_DROP_INDEX

+ const SQLType_DROP_TABLE

+ const SQLType_DUMP

+ const SQLType_EXPLAIN

+ const SQLType_INSERT

+ const SQLType_LOAD

+ const SQLType_MERGE

+ const SQLType_MULTI_DELETE

+ const SQLType_MULTI_UPDATE

+ const SQLType_PROCEDURE

+ const SQLType_RELOAD

+ const SQLType_RENAME

+ const SQLType_REPLACE

+ const SQLType_SAVE_POINT

+ const SQLType_SELECT

+ const SQLType_SELECT_FOR_UPDATE

+ const SQLType_SELECT_FROM_UPDATE

+ const SQLType_SELECT_UNION

+ const SQLType_SET

+ const SQLType_SHOW

+ const SQLType_TRUNCATE

+ const SQLType_UPDATE

+ func (sqlType SQLType) String() string

+ type Scanner interface

+ Scan func(src interface{}) error

+ type SqlDataType int32

+ type State byte

+ const GlobalFinished

+ const Normal

+ func (state State) String() string

+ type TableMetaCache struct

+ func GetTableMetaCache(dbName string) *TableMetaCache

+ func (cache *TableMetaCache) FetchSchema(conn *mysqlConn, tableName string) (schema.TableMeta, error)

+ func (cache *TableMetaCache) GetCacheKey(tableName string) string

+ func (cache *TableMetaCache) GetTableMeta(conn *mysqlConn, tableName string) (schema.TableMeta, error)

+ func (cache *TableMetaCache) Refresh(conn *mysqlConn, resourceID string)

+ type UndoExecutor struct

+ func NewMysqlUndoExecutor(undoLog sqlUndoLog) UndoExecutor

+ func (executor UndoExecutor) Execute(conn *mysqlConn) error

+ type UndoLogManager struct

+ func GetUndoLogManager() UndoLogManager

+ func (manager UndoLogManager) BatchDeleteUndoLog(conn *mysqlConn, xids []string, branchSessionIDs []int64) error

+ func (manager UndoLogManager) DeleteUndoLog(conn *mysqlConn, xid string, branchSessionID int64) error

+ func (manager UndoLogManager) DeleteUndoLogByLogCreated(conn *mysqlConn, logCreated time.Time, limitRows int) (sql.Result, error)

+ func (manager UndoLogManager) FlushUndoLogs(conn *mysqlConn) error

+ func (manager UndoLogManager) Undo(conn *mysqlConn, xid string, branchSessionID int64, resourceID string) ([]string, error)

+ type UndoLogParser interface

+ Decode func(data []byte) *branchUndoLog

+ Encode func(branchUndoLog *branchUndoLog) []byte

+ GetDefaultContent func() []byte

+ GetName func() string

+ func GetUndoLogParser() UndoLogParser

v1.6.0-rc1

Jul 13, 2022