dbwrapper

Documentation

Index

• Constants
• type Columns
• type DBWrapper
  • func New(dbname, id string, functions []string, channels *callback.CallbackChannels) *DBWrapper
  • func (w *DBWrapper) Close() error
  • func (w *DBWrapper) Execute(ctx context.Context, sql string, params ...interface{}) (insertId int64, affected int64, err error)
  • func (w *DBWrapper) Open(driverName string) error
  • func (w *DBWrapper) Query(ctx context.Context, sql string, params ...interface{}) ([]string, []string, []*pb.Row, error)
• type RowFields
• type Rows

Constants

const DefaultDBName = "test"

Types

type Columns

type Columns []string

type DBWrapper

type DBWrapper struct {
	Name     string
	Database *sql.DB
	Channels *callback.CallbackChannels
}

func New

func New(dbname, id string, functions []string, channels *callback.CallbackChannels) *DBWrapper

func (*DBWrapper) Close

func (w *DBWrapper) Close() error

func (*DBWrapper) Execute

func (w *DBWrapper) Execute(ctx context.Context, sql string, params ...interface{}) (insertId int64, affected int64, err error)

func (*DBWrapper) Open

func (w *DBWrapper) Open(driverName string) error

func (*DBWrapper) Query

func (w *DBWrapper) Query(ctx context.Context, sql string, params ...interface{}) ([]string, []string, []*pb.Row, error)

type RowFields

type RowFields *[]string

type Rows

type Rows []RowFields