mysql

package

Go to main page

Versions in this module

v1

v1.0.6

May 14, 2024

v1.0.5

Oct 27, 2023

Changes in this version

type BaseExecutor

+ func (executor *BaseExecutor) Begin(conn *Conn, stmt *query.Begin) (*Result, error)

+ func (executor *BaseExecutor) Commit(conn *Conn, stmt *query.Commit) (*Result, error)

+ func (executor *BaseExecutor) Rollback(conn *Conn, stmt *query.Rollback) (*Result, error)

type Conn

+ func (conn *Conn) SetDeadline(t time.Time) error

+ func (conn *Conn) SetReadDeadline(t time.Time) error

+ func (conn *Conn) SetWriteDeadline(t time.Time) error

+ type TCLExecutor interface

+ Begin func(*Conn, *query.Begin) (*Result, error)

+ Commit func(*Conn, *query.Commit) (*Result, error)

+ Rollback func(*Conn, *query.Rollback) (*Result, error)

v1.0.4

Oct 3, 2023

Changes in this version

type Conn

+ func (conn *Conn) UUID() uuid.UUID

v1.0.3

May 13, 2023

v1.0.2

May 4, 2023

Changes in this version

type Conn

+ func NewConnWith(ctx tracer.Context, c *vitessmy.Conn) *Conn

v1.0.1

May 4, 2023

Changes in this version

type Conn

+ func (conn *Conn) SetSpanContext(span tracer.SpanContext)

+ func (conn *Conn) SpanContext() tracer.SpanContext

v1.0.0

May 3, 2023

Changes in this version

type Config

+ Address string

+ func (config *Config) SetAddress(host string)

v0

v0.9.4

Apr 23, 2023

Changes in this version

type Server

+ func (server *Server) SetTracer(t tracer.Tracer)

v0.9.3

Apr 1, 2023

Changes in this version

+ const PackageName

+ const Version

v0.9.2

Mar 28, 2023

Changes in this version

type Conn

+ func (conn *Conn) ID() uint32

+ func (conn *Conn) SetDatabase(name string)

type Value

+ func NewNullValue() Value

+ func NewValueWith(typ vitesspq.Type, val []byte) (Value, error)

v0.9.1

Feb 24, 2023

Changes in this version

+ type AuthHandler interface

+ func NewDefaultAuthHandler() AuthHandler

+ type BaseExecutor struct

+ func NewBaseExecutor() *BaseExecutor

+ func (executor *BaseExecutor) AlterDatabase(ctx context.Context, conn *Conn, stmt *query.Database) (*Result, error)

+ func (executor *BaseExecutor) AlterTable(ctx context.Context, conn *Conn, stmt *query.Schema) (*Result, error)

+ func (executor *BaseExecutor) CreateDatabase(ctx context.Context, conn *Conn, stmt *query.Database) (*Result, error)

+ func (executor *BaseExecutor) CreateTable(ctx context.Context, conn *Conn, stmt *query.Schema) (*Result, error)

+ func (executor *BaseExecutor) Delete(ctx context.Context, conn *Conn, stmt *query.Delete) (*Result, error)

+ func (executor *BaseExecutor) DropDatabase(ctx context.Context, conn *Conn, stmt *query.Database) (*Result, error)

+ func (executor *BaseExecutor) DropTable(ctx context.Context, conn *Conn, stmt *query.Schema) (*Result, error)

+ func (executor *BaseExecutor) Insert(ctx context.Context, conn *Conn, stmt *query.Insert) (*Result, error)

+ func (executor *BaseExecutor) RenameTable(ctx context.Context, conn *Conn, stmt *query.Schema) (*Result, error)

+ func (executor *BaseExecutor) Select(ctx context.Context, conn *Conn, stmt *query.Select) (*Result, error)

+ func (executor *BaseExecutor) ShowDatabases(ctx context.Context, conn *Conn) (*Result, error)

+ func (executor *BaseExecutor) ShowTables(ctx context.Context, conn *Conn, database string) (*Result, error)

+ func (executor *BaseExecutor) TruncateTable(ctx context.Context, conn *Conn, stmt *query.Schema) (*Result, error)

+ func (executor *BaseExecutor) Update(ctx context.Context, conn *Conn, stmt *query.Update) (*Result, error)

+ type BindVariable = vitesspq.BindVariable

+ type Client struct

+ func NewClient() *Client

+ func (client *Client) Close() error

+ func (client *Client) Open() error

+ func (client *Client) Query(query string, args ...interface{}) (*sql.Rows, error)

+ type Config struct

+ Database string

+ Host string

+ Port int

+ func NewDefaultConfig() *Config

+ func (config *Config) SetDatabase(db string)

+ func (config *Config) SetHost(host string)

+ func (config *Config) SetPort(port int)

+ type Conn struct

+ Database string

+ Timestamp time.Time

+ UID uint32

+ func NewConnWithConn(c *vitessmy.Conn) *Conn

+ type ConnMap struct

+ func NewConnMap() ConnMap

+ func (cm ConnMap) AddConn(c *Conn)

+ func (cm ConnMap) DeleteConnByUID(cid uint32)

+ func (cm ConnMap) GetConnByUID(cid uint32) (*Conn, bool)

+ func (cm ConnMap) Length() int

+ type DAOExecutor interface

+ ShowDatabases func(context.Context, *Conn) (*Result, error)

+ ShowTables func(context.Context, *Conn, string) (*Result, error)

+ type DCOExecutor interface

+ type DDOExecutor interface

+ AlterDatabase func(context.Context, *Conn, *query.Database) (*Result, error)

+ AlterTable func(context.Context, *Conn, *query.Schema) (*Result, error)

+ CreateDatabase func(context.Context, *Conn, *query.Database) (*Result, error)

+ CreateTable func(context.Context, *Conn, *query.Schema) (*Result, error)

+ DropDatabase func(context.Context, *Conn, *query.Database) (*Result, error)

+ DropTable func(context.Context, *Conn, *query.Schema) (*Result, error)

+ RenameTable func(context.Context, *Conn, *query.Schema) (*Result, error)

+ TruncateTable func(context.Context, *Conn, *query.Schema) (*Result, error)

+ type DMOExecutor interface

+ Delete func(context.Context, *Conn, *query.Delete) (*Result, error)

+ Insert func(context.Context, *Conn, *query.Insert) (*Result, error)

+ Select func(context.Context, *Conn, *query.Select) (*Result, error)

+ Update func(context.Context, *Conn, *query.Update) (*Result, error)

+ type Field = vitesspq.Field

+ type Listener struct

+ func NewListener(protocol, address string, authServer AuthHandler, handler QueryHandler, ...) (*Listener, error)

+ type MySQLClient struct

+ func NewMySQLClient() *MySQLClient

+ func (client *MySQLClient) Close() error

+ func (client *MySQLClient) Open(dbName string) error

+ func (client *MySQLClient) Query(query string, args ...interface{}) (driver.Rows, error)

+ type PrepareData = vitessmy.PrepareData

+ type QueryExecutor interface

+ type QueryHandler interface

+ type Result = vitessst.Result

+ func NewResult() *Result

+ func NewResultWithRows(db *query.Database, schema *query.Schema, rows *query.Rows) (*Result, error)

+ func NewResultWithRowsAffected(n uint64) *Result

+ type Server struct

+ func NewServer() *Server

+ func (server *Server) ComInitDB(c *vitessmy.Conn, schemaName string)

+ func (server *Server) ComPrepare(c *vitessmy.Conn, query string, bindVars map[string]*BindVariable) ([]*Field, error)

+ func (server *Server) ComQuery(c *vitessmy.Conn, q string, callback func(*Result) error) error

+ func (server *Server) ComResetConnection(c *vitessmy.Conn)

+ func (server *Server) ComStmtExecute(c *vitessmy.Conn, prepare *PrepareData, callback func(*Result) error) error

+ func (server *Server) ConnectionClosed(c *vitessmy.Conn)

+ func (server *Server) NewConnection(c *vitessmy.Conn)

+ func (server *Server) Restart() error

+ func (server *Server) SetAuthHandler(h AuthHandler)

+ func (server *Server) SetQueryExecutor(e QueryExecutor)

+ func (server *Server) Start() error

+ func (server *Server) Stop() error

+ func (server *Server) WarningCount(c *vitessmy.Conn) uint16

+ type Value = vitessst.Value

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL