connection

Documentation

Index

• type Connection
• type DefaultConnection
  • func (conn *DefaultConnection) Exec(ctx context.Context, sqlStr string, params ...interface{}) (common.Result, error)
  • func (conn *DefaultConnection) Prepare(sqlStr string) (statement.Statement, error)
  • func (conn *DefaultConnection) Query(ctx context.Context, result reflection.Object, sqlStr string, ...) error
• type DefaultStatement
  • func (s *DefaultStatement) Close()
  • func (s *DefaultStatement) Exec(ctx context.Context, params ...interface{}) (common.Result, error)
  • func (s *DefaultStatement) Query(ctx context.Context, result reflection.Object, params ...interface{}) error

Types

type Connection

type Connection interface {
	Prepare(sql string) (statement.Statement, error)
	Query(ctx context.Context, result reflection.Object, sql string, params ...interface{}) error
	Exec(ctx context.Context, sql string, params ...interface{}) (common.Result, error)
}

type DefaultConnection

type DefaultConnection sql.DB

func (*DefaultConnection) Exec

func (conn *DefaultConnection) Exec(ctx context.Context, sqlStr string, params ...interface{}) (common.Result, error)

func (*DefaultConnection) Prepare

func (conn *DefaultConnection) Prepare(sqlStr string) (statement.Statement, error)

func (*DefaultConnection) Query

func (conn *DefaultConnection) Query(ctx context.Context, result reflection.Object, sqlStr string, params ...interface{}) error

type DefaultStatement

type DefaultStatement sql.Stmt

func (*DefaultStatement) Close

func (s *DefaultStatement) Close()

func (*DefaultStatement) Exec

func (s *DefaultStatement) Exec(ctx context.Context, params ...interface{}) (common.Result, error)

func (*DefaultStatement) Query

func (s *DefaultStatement) Query(ctx context.Context, result reflection.Object, params ...interface{}) error