godb

Aug 3, 2022

Changes in this version

+ type Builder struct

+ Args []interface{}

+ Dialect Dialect

+ Where []string

+ func (b *Builder) AddToArgs(vals ...interface{}) *Builder

+ func (b *Builder) BuildWhere(join string) string

+ func (b *Builder) WhereDistinct(field string, val interface{}) *Builder

+ func (b *Builder) WhereExact(field string, val interface{}) *Builder

+ func (b *Builder) WhereGreater(field string, val interface{}) *Builder

+ func (b *Builder) WhereGreaterEq(field string, val interface{}) *Builder

+ func (b *Builder) WhereIn(field string, vals ...interface{}) *Builder

+ func (b *Builder) WhereLess(field string, val interface{}) *Builder

+ func (b *Builder) WhereLessEq(field string, val interface{}) *Builder

+ func (b *Builder) WhereLike(field string, vals ...string) *Builder

+ func (b *Builder) WhereNotDistinct(field string, val interface{}) *Builder

+ func (b *Builder) WhereNotExact(field string, val interface{}) *Builder

+ func (b *Builder) WhereNotIn(field string, vals ...interface{}) *Builder

+ func (b *Builder) WhereNotLike(field string, vals ...string) *Builder

+ func (b *Builder) WhereNotNull(field string) *Builder

+ func (b *Builder) WhereNull(field string) *Builder

Jun 24, 2022

Changes in this version

type MSSQLDatastore

+ func (m *MSSQLDatastore) BeginTx(ctx context.Context) (Transaction, error)

Jun 21, 2022

Changes in this version

type MSSQLTx

+ func (*MSSQLTx) Shutdown(context.Context) error

+ func (*MSSQLTx) Stats(context.Context) sql.DBStats

+ func (m *MSSQLTx) FetchJSON(ctx context.Context, query string, args ...interface{}) ([]byte, error)

+ func (m *MSSQLTx) FetchJSONWithMetrics(ctx context.Context, r metrics.Recorder, query string, args ...interface{}) ([]byte, error)

+ func (m *MSSQLTx) Ping(ctx context.Context) error

type PostgresTx

+ func (*PostgresTx) Shutdown(context.Context) error

+ func (*PostgresTx) Stats(context.Context) sql.DBStats

+ func (p *PostgresTx) FetchJSON(ctx context.Context, query string, args ...interface{}) ([]byte, error)

+ func (p *PostgresTx) FetchJSONWithMetrics(ctx context.Context, r metrics.Recorder, query string, args ...interface{}) ([]byte, error)

+ func (p *PostgresTx) Ping(ctx context.Context) error

Jun 21, 2022

Changes in this version

+ type MSSQLTx struct

+ func (p *MSSQLTx) Commit() error

+ func (p *MSSQLTx) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (p *MSSQLTx) ExecWithMetrics(ctx context.Context, r metrics.Recorder, query string, args ...interface{}) (sql.Result, error)

+ func (p *MSSQLTx) Fetch(ctx context.Context, query string, container interface{}, args ...interface{}) error

+ func (p *MSSQLTx) FetchWithMetrics(ctx context.Context, r metrics.Recorder, query string, container interface{}, ...) error

+ func (p *MSSQLTx) Rollback() error

Jun 7, 2022

Changes in this version

+ func NewBuilder(d Dialect) *builder

+ type Dialect string

+ const DialectMSSQL

+ const DialectPostgres

+ type Join string

Oct 25, 2021

Changes in this version

+ type Pinger interface

+ Ping func(context.Context) error

Oct 11, 2021

Changes in this version

type AsyncMockDB

+ func (db *AsyncMockDB) Stats(context.Context) sql.DBStats

type MSSQLDatastore

+ func (m *MSSQLDatastore) Stats(context.Context) sql.DBStats

type MockDB

+ func (db *MockDB) Stats(context.Context) sql.DBStats

type MySQLDatastore

+ func (m *MySQLDatastore) Stats(context.Context) sql.DBStats

type PostgresDatastore

+ func (p *PostgresDatastore) Stats(context.Context) sql.DBStats

type SQLiteDatastore

+ func (s *SQLiteDatastore) Stats(context.Context) sql.DBStats

Jun 3, 2021

Changes in this version

type PostgresDatastore

+ func (p *PostgresDatastore) BeginTx(ctx context.Context) (Transaction, error)

+ type PostgresTx struct

+ func (p *PostgresTx) Commit() error

+ func (p *PostgresTx) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (p *PostgresTx) ExecWithMetrics(ctx context.Context, r metrics.Recorder, query string, args ...interface{}) (sql.Result, error)

+ func (p *PostgresTx) Fetch(ctx context.Context, query string, container interface{}, args ...interface{}) error

+ func (p *PostgresTx) FetchWithMetrics(ctx context.Context, r metrics.Recorder, query string, container interface{}, ...) error

+ func (p *PostgresTx) Rollback() error

+ type Transaction interface

+ Commit func() error

+ Rollback func() error

+ type TransactionDB interface

+ BeginTx func(context.Context) (Transaction, error)

Mar 24, 2021

Changes in this version

+ var ErrNotFound = errors.New("not found")

Mar 23, 2021

Changes in this version

+ var ErrEmptyObject = errors.New("godb empty object")

Mar 19, 2021

Changes in this version

+ type JSONApi struct

+ func NewJSONApi(baseURL, pingPath string, requestTimeout time.Duration) *JSONApi

+ func (h *JSONApi) Fetch(ctx context.Context, requestURI string, container interface{}, ...) error

+ func (h *JSONApi) FetchJSON(ctx context.Context, requestURI string, args ...interface{}) ([]byte, error)

+ func (h *JSONApi) FetchJSONWithMetrics(ctx context.Context, r metrics.Recorder, requestURI string, ...) ([]byte, error)

+ func (h *JSONApi) FetchWithMetrics(ctx context.Context, r metrics.Recorder, requestURI string, ...) error

+ func (h *JSONApi) Ping(ctx context.Context) error

Mar 10, 2021

Changes in this version

+ var QueryLimit = 5 * time.Minute

+ func UnmarshalWithMetrics(r metrics.Recorder, rows *sql.Rows, v interface{}) error

+ type AsyncMockDB struct

+ CallCount int

+ ExecCount int

+ ExecPointer int

+ Expected []DBResult

+ FetchCount int

+ FetchJSONCount int

+ FetchJSONPointer int

+ FetchPointer int

+ func NewAsyncMockDB(t *testing.T) *AsyncMockDB

+ func (db *AsyncMockDB) AssertNoCalls()

+ func (db *AsyncMockDB) Exec(ctx context.Context, q string, args ...interface{}) (sql.Result, error)

+ func (db *AsyncMockDB) ExecWithMetrics(ctx context.Context, r metrics.Recorder, q string, args ...interface{}) (sql.Result, error)

+ func (db *AsyncMockDB) Fetch(ctx context.Context, q string, c interface{}, args ...interface{}) error

+ func (db *AsyncMockDB) FetchJSON(ctx context.Context, q string, args ...interface{}) ([]byte, error)

+ func (db *AsyncMockDB) FetchJSONWithMetrics(ctx context.Context, r metrics.Recorder, q string, args ...interface{}) ([]byte, error)

+ func (db *AsyncMockDB) FetchWithMetrics(ctx context.Context, r metrics.Recorder, q string, c interface{}, ...) error

+ func (db *AsyncMockDB) Ping(ctx context.Context) error

+ func (db *AsyncMockDB) Shutdown(ctx context.Context) error

+ type DBResult struct

+ Args []interface{}

+ Content []byte

+ Error error

+ Query string

+ Result SQLResult

+ type Executer interface

+ Exec func(context.Context, string, ...interface{}) (sql.Result, error)

+ ExecWithMetrics func(context.Context, metrics.Recorder, string, ...interface{}) (sql.Result, error)

+ Ping func(context.Context) error

+ type Fetcher interface

+ Fetch func(context.Context, string, interface{}, ...interface{}) error

+ FetchWithMetrics func(context.Context, metrics.Recorder, string, interface{}, ...interface{}) error

+ Ping func(context.Context) error

+ type JSONFetcher interface

+ FetchJSON func(context.Context, string, ...interface{}) ([]byte, error)

+ FetchJSONWithMetrics func(context.Context, metrics.Recorder, string, ...interface{}) ([]byte, error)

+ Ping func(context.Context) error

type MSSQLDatastore

+ func (m *MSSQLDatastore) ExecWithMetrics(ctx context.Context, r metrics.Recorder, query string, args ...interface{}) (sql.Result, error)

+ func (m *MSSQLDatastore) FetchJSONWithMetrics(ctx context.Context, r metrics.Recorder, query string, args ...interface{}) ([]byte, error)

+ func (m *MSSQLDatastore) FetchWithMetrics(ctx context.Context, r metrics.Recorder, query string, container interface{}, ...) error

+ type MockDB struct

+ ExecCount int

+ ExecExpected []DBResult

+ ExecPointer int

+ FetchCount int

+ FetchExpected []DBResult

+ FetchJSONCount int

+ FetchJSONExpected []DBResult

+ FetchJSONPointer int

+ FetchPointer int

+ func NewMockDB(t *testing.T) *MockDB

+ func (db *MockDB) AssertNoCalls()

+ func (db *MockDB) Exec(ctx context.Context, q string, args ...interface{}) (sql.Result, error)

+ func (db *MockDB) ExecWithMetrics(ctx context.Context, r metrics.Recorder, q string, args ...interface{}) (sql.Result, error)

+ func (db *MockDB) Fetch(ctx context.Context, q string, c interface{}, args ...interface{}) error

+ func (db *MockDB) FetchJSON(ctx context.Context, q string, args ...interface{}) ([]byte, error)

+ func (db *MockDB) FetchJSONWithMetrics(ctx context.Context, r metrics.Recorder, q string, args ...interface{}) ([]byte, error)

+ func (db *MockDB) FetchWithMetrics(ctx context.Context, r metrics.Recorder, q string, c interface{}, ...) error

+ func (db *MockDB) OnConsecutiveFetch(fc []DBResult)

+ func (db *MockDB) Ping(context.Context) error

+ func (db *MockDB) Shutdown(context.Context) error

type MySQLDatastore

+ func (m *MySQLDatastore) ExecWithMetrics(ctx context.Context, r metrics.Recorder, query string, args ...interface{}) (sql.Result, error)

+ func (m *MySQLDatastore) FetchJSONWithMetrics(ctx context.Context, r metrics.Recorder, query string, args ...interface{}) ([]byte, error)

+ func (m *MySQLDatastore) FetchWithMetrics(ctx context.Context, r metrics.Recorder, query string, container interface{}, ...) error

type PostgresDatastore

+ func (p *PostgresDatastore) ExecWithMetrics(ctx context.Context, r metrics.Recorder, query string, args ...interface{}) (sql.Result, error)

+ func (p *PostgresDatastore) FetchJSONWithMetrics(ctx context.Context, r metrics.Recorder, query string, args ...interface{}) ([]byte, error)

+ func (p *PostgresDatastore) FetchWithMetrics(ctx context.Context, r metrics.Recorder, query string, container interface{}, ...) error

+ type SQLResult struct

+ Affected int64

+ AffectedErr error

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

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

type SQLiteDatastore

+ func (s *SQLiteDatastore) ExecWithMetrics(ctx context.Context, r metrics.Recorder, query string, args ...interface{}) (sql.Result, error)

+ func (s *SQLiteDatastore) FetchJSONWithMetrics(ctx context.Context, r metrics.Recorder, query string, args ...interface{}) ([]byte, error)

+ func (s *SQLiteDatastore) FetchWithMetrics(ctx context.Context, r metrics.Recorder, query string, container interface{}, ...) error

Jan 5, 2021

Changes in this version

+ type MySQLDatastore struct

+ func NewMySQLDatastore(user, pass, dbName, host, port string) *MySQLDatastore

+ func NewMySQLDatastoreCS(connectString string) *MySQLDatastore

+ func (p *MySQLDatastore) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (p *MySQLDatastore) Fetch(query string, container interface{}, args ...interface{}) error

+ func (p *MySQLDatastore) FetchJSON(query string, args ...interface{}) ([]byte, error)

+ func (p *MySQLDatastore) Ping() error

+ func (p *MySQLDatastore) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (p *MySQLDatastore) Shutdown() error

Apr 20, 2020

Changes in this version

+ func ToJSON(rows *sql.Rows) ([]byte, error)

+ func Unmarshal(rows *sql.Rows, v interface{}) error

+ type Database interface

+ Exec func(string, ...interface{}) (sql.Result, error)

+ Fetch func(string, interface{}, ...interface{}) error

+ FetchJSON func(string, ...interface{}) ([]byte, error)

+ Ping func() error

+ Query func(string, ...interface{}) (*sql.Rows, error)

+ Shutdown func() error

+ type MSSQLDatastore struct

+ func NewMSSQLDatastore(user, pass, dbName, host, port, appname string) *MSSQLDatastore

+ func NewMSSQLDatastoreCS(connectString string) *MSSQLDatastore

+ func (m *MSSQLDatastore) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (m *MSSQLDatastore) Fetch(query string, container interface{}, args ...interface{}) error

+ func (m *MSSQLDatastore) FetchJSON(query string, args ...interface{}) ([]byte, error)

+ func (m *MSSQLDatastore) Ping() error

+ func (m *MSSQLDatastore) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (m *MSSQLDatastore) Shutdown() error

+ type PostgresDatastore struct

+ func NewPostgresDatastore(user, pass, dbName, host, port string) *PostgresDatastore

+ func NewPostgresDatastoreCS(connectString string) *PostgresDatastore

+ func (p *PostgresDatastore) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (p *PostgresDatastore) Fetch(query string, container interface{}, args ...interface{}) error

+ func (p *PostgresDatastore) FetchJSON(query string, args ...interface{}) ([]byte, error)

+ func (p *PostgresDatastore) Ping() error

+ func (p *PostgresDatastore) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (p *PostgresDatastore) Shutdown() error

+ type SQLiteDatastore struct

+ func NewSQLiteDatastore(file string) *SQLiteDatastore

+ func (s *SQLiteDatastore) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (s *SQLiteDatastore) Fetch(query string, container interface{}, args ...interface{}) error

+ func (s *SQLiteDatastore) FetchJSON(query string, args ...interface{}) ([]byte, error)

+ func (s *SQLiteDatastore) Ping() error

+ func (s *SQLiteDatastore) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (s *SQLiteDatastore) Shutdown() error