propose

Documentation

Index

• Variables
• type Conn
  • func New(ctx context.Context, parent Parent, s *query.Session, opts ...Option) *Conn
  • func (c *Conn) Begin() (driver.Tx, error)
  • func (c *Conn) BeginTx(ctx context.Context, txOptions driver.TxOptions) (iface.Tx, error)
  • func (c *Conn) Close() (finalErr error)
  • func (c *Conn) Exec(ctx context.Context, sql string, params *params.Params) (result driver.Result, finalErr error)
  • func (c *Conn) Explain(ctx context.Context, sql string, _ *params.Params) (ast string, plan string, _ error)
  • func (c *Conn) ID() string
  • func (c *Conn) IsValid() bool
  • func (c *Conn) NodeID() uint32
  • func (c *Conn) Ping(ctx context.Context) (finalErr error)
  • func (c *Conn) Query(ctx context.Context, sql string, params *params.Params) (result driver.RowsNextResultSet, finalErr error)
• type Option
  • func WithFakeTx() Option
  • func WithOnClose(onClose func()) Option
• type Parent

Variables

var (
	ErrUnsupported = driver.ErrSkip
)

Types

type Conn

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

func New

func New(ctx context.Context, parent Parent, s *query.Session, opts ...Option) *Conn

func (*Conn) Begin

func (c *Conn) Begin() (driver.Tx, error)

func (*Conn) BeginTx

func (c *Conn) BeginTx(ctx context.Context, txOptions driver.TxOptions) (iface.Tx, error)

func (*Conn) Close

func (c *Conn) Close() (finalErr error)

func (*Conn) Exec

func (c *Conn) Exec(ctx context.Context, sql string, params *params.Params) (
	result driver.Result, finalErr error,
)

func (*Conn) Explain

func (c *Conn) Explain(ctx context.Context, sql string, _ *params.Params) (ast string, plan string, _ error)

func (*Conn) ID

func (c *Conn) ID() string

func (*Conn) IsValid

func (c *Conn) IsValid() bool

func (*Conn) NodeID

func (c *Conn) NodeID() uint32

func (*Conn) Ping

func (c *Conn) Ping(ctx context.Context) (finalErr error)

func (*Conn) Query

func (c *Conn) Query(ctx context.Context, sql string, params *params.Params) (
	result driver.RowsNextResultSet, finalErr error,
)

type Option

type Option func(c *Conn)

func WithFakeTx

func WithFakeTx() Option

func WithOnClose

func WithOnClose(onClose func()) Option

type Parent

type Parent interface {
	Query() *query.Client
}