postgres

func (*PostgresAdapter) Close ¶

func (adapter *PostgresAdapter) Close() error

Close the adapter.

func (*PostgresAdapter) Create ¶

func (adapter *PostgresAdapter) Create() error

Create an initial database schema.

func (*PostgresAdapter) DBX ¶

func (adapter *PostgresAdapter) DBX() Ext

DBX returns sqlx.Ext

func (*PostgresAdapter) Find ¶

func (adapter *PostgresAdapter) Find(ctx context.Context, dest interface{}) error

Find finds a single entity based on the EntityID()

func (*PostgresAdapter) Get ¶

func (adapter *PostgresAdapter) Get(ctx context.Context, dest interface{}, qstr string, args ...interface{}) error

Get wraps sqlx.Get

func (*PostgresAdapter) Insert ¶

func (adapter *PostgresAdapter) Insert(ctx context.Context, ent interface{}) (int, error)

Insert builds and executes an insert statement for the given entity.

func (*PostgresAdapter) MultiInsert ¶

func (adapter *PostgresAdapter) MultiInsert(ctx context.Context, ents []interface{}) ([]int, error)

MultiInsert builds and executes a multi-insert statement for the given entities.

func (*PostgresAdapter) Open ¶

func (adapter *PostgresAdapter) Open() error

Open the adapter.

func (*PostgresAdapter) OpenDB ¶ added in v1.2.0

func (adapter *PostgresAdapter) OpenDB() (*sqlx.DB, error)

func (*PostgresAdapter) Select ¶

func (adapter *PostgresAdapter) Select(ctx context.Context, dest interface{}, qstr string, args ...interface{}) error

Select wraps sqlx.Select

func (*PostgresAdapter) Sqrl ¶

func (adapter *PostgresAdapter) Sqrl() sq.StatementBuilderType

Sqrl returns a properly configured Squirrel StatementBuilder.

func (*PostgresAdapter) TableExists ¶

func (adapter *PostgresAdapter) TableExists(t string) (bool, error)

TableExists returns true if the requested table exists

func (*PostgresAdapter) Tx ¶

func (adapter *PostgresAdapter) Tx(cb func(Adapter) error) error

Tx runs a callback inside a transaction.

func (*PostgresAdapter) Update ¶

func (adapter *PostgresAdapter) Update(ctx context.Context, ent interface{}, columns ...string) error

Update a single entity.