datastore

Documentation

Index

• func NewDB() *sql.DB
• type SQLHandler
  • func NewSQLHandler(conn *sql.DB) *SQLHandler
  • func (sqlHandler *SQLHandler) Exec(statiment string, args ...interface{}) (gateway.Result, error)
  • func (sqlHandler *SQLHandler) Query(statement string, args ...interface{}) (gateway.Row, error)
• type SQLResult
  • func (r SQLResult) LastInsertId() (int64, error)
  • func (r *SQLResult) RowsAffected() (int64, error)
• type SQLRow
  • func (r SQLRow) Close() error
  • func (r SQLRow) Next() bool
  • func (r SQLRow) Scan(dest ...interface{}) error

Functions

func NewDB

func NewDB() *sql.DB

Types

type SQLHandler

type SQLHandler struct {
	Conn *sql.DB
}

SQLHandler is a handler responsible for connection to DB.

func NewSQLHandler

func NewSQLHandler(conn *sql.DB) *SQLHandler

NewSQLHandler create a new sqlhandler.

func (*SQLHandler) Exec

func (sqlHandler *SQLHandler) Exec(statiment string, args ...interface{}) (gateway.Result, error)

Exec execute a query that insert or update sql.

func (*SQLHandler) Query

func (sqlHandler *SQLHandler) Query(statement string, args ...interface{}) (gateway.Row, error)

Query exetutes a query that returns rows.

type SQLResult

type SQLResult struct {
	Result sql.Result
}

SQLResult ...

func (SQLResult) LastInsertId

func (r SQLResult) LastInsertId() (int64, error)

LastInsertId ...

func (*SQLResult) RowsAffected

func (r *SQLResult) RowsAffected() (int64, error)

RowsAffected ...

type SQLRow

type SQLRow struct {
	Rows *sql.Rows
}

SQLRow is an implementation of presenters.Row.

func (SQLRow) Close

func (r SQLRow) Close() error

Close ...

func (SQLRow) Next

func (r SQLRow) Next() bool

Next ...

func (SQLRow) Scan

func (r SQLRow) Scan(dest ...interface{}) error

Scan ...