sqlx

Documentation

Index

• Variables
• type BulkInserter
  • func NewBulkInserter(sqlConn SqlConn, stmt string) (*BulkInserter, error)
  • func (bi *BulkInserter) Flush()
  • func (bi *BulkInserter) Insert(args ...interface{}) error
  • func (bi *BulkInserter) SetResultHandler(handler ResultHandler)
  • func (bi *BulkInserter) UpdateOrDelete(fn func())
  • func (bi *BulkInserter) UpdateStmt(stmt string) error
• type ResultHandler
• type Session
• type SqlConn
  • func NewMysql(datasource string, opts ...SqlOption) SqlConn
  • func NewSqlConn(driverName, datasource string, opts ...SqlOption) SqlConn
• type SqlOption
• type StmtSession

Variables

var (
	ErrNotMatchDestination  = errors.New("not matching destination to scan")
	ErrNotReadableValue     = errors.New("value not addressable or interfaceable")
	ErrNotSettable          = errors.New("passed in variable is not settable")
	ErrUnsupportedValueType = errors.New("unsupported unmarshal type")
)

var ErrNotFound = sql.ErrNoRows

Types

type BulkInserter

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

func NewBulkInserter

func NewBulkInserter(sqlConn SqlConn, stmt string) (*BulkInserter, error)

func (*BulkInserter) Flush

func (bi *BulkInserter) Flush()

func (*BulkInserter) Insert

func (bi *BulkInserter) Insert(args ...interface{}) error

func (*BulkInserter) SetResultHandler

func (bi *BulkInserter) SetResultHandler(handler ResultHandler)

func (*BulkInserter) UpdateOrDelete

func (bi *BulkInserter) UpdateOrDelete(fn func())

func (*BulkInserter) UpdateStmt

func (bi *BulkInserter) UpdateStmt(stmt string) error

type ResultHandler

type ResultHandler func(sql.Result, error)

type Session

type Session interface {
	Exec(query string, args ...interface{}) (sql.Result, error)
	Prepare(query string) (StmtSession, error)
	QueryRow(v interface{}, query string, args ...interface{}) error
	QueryRowPartial(v interface{}, query string, args ...interface{}) error
	QueryRows(v interface{}, query string, args ...interface{}) error
	QueryRowsPartial(v interface{}, query string, args ...interface{}) error
}

Session stands for raw connections or transaction sessions

type SqlConn

type SqlConn interface {
	Session
	Transact(func(session Session) error) error
}

SqlConn only stands for raw connections, so Transact method can be called.

func NewMysql

func NewMysql(datasource string, opts ...SqlOption) SqlConn

func NewSqlConn

func NewSqlConn(driverName, datasource string, opts ...SqlOption) SqlConn

type SqlOption

type SqlOption func(*commonSqlConn)

type StmtSession

type StmtSession interface {
	Close() error
	Exec(args ...interface{}) (sql.Result, error)
	QueryRow(v interface{}, args ...interface{}) error
	QueryRowPartial(v interface{}, args ...interface{}) error
	QueryRows(v interface{}, args ...interface{}) error
	QueryRowsPartial(v interface{}, args ...interface{}) error
}