sql

Documentation

Index

• Variables
• type SQL
  • func New(ctx context.Context, db *sql.DB) (*SQL, error)
  • func (s *SQL) Create(ctx context.Context, rs ...orbital.Entity) ([]orbital.Entity, error)
  • func (s *SQL) Find(ctx context.Context, q query.Query) (orbital.FindResult, error)
  • func (s *SQL) List(ctx context.Context, q query.Query) (orbital.ListResult, error)
  • func (s *SQL) Transaction(ctx context.Context, txFunc orbital.TransactionFunc) error
  • func (s *SQL) Update(ctx context.Context, rs ...orbital.Entity) ([]orbital.Entity, error)

Variables

var (
	ErrNoColumn = errors.New("no column found")
	ErrNoEntity = errors.New("no entities provided")
)

Types

type SQL

type SQL struct {
	// contains filtered or unexported fields
}

SQL is a SQL store implementation of the orbital.Store interface.

func New

func New(ctx context.Context, db *sql.DB) (*SQL, error)

New initializes a new SQL store and sets up required tables.

func (*SQL) Create

func (s *SQL) Create(ctx context.Context, rs ...orbital.Entity) ([]orbital.Entity, error)

Create implements orbital.Store.

func (*SQL) Find

func (s *SQL) Find(ctx context.Context, q query.Query) (orbital.FindResult, error)

Find implements orbital.Store.

func (*SQL) List

func (s *SQL) List(ctx context.Context, q query.Query) (orbital.ListResult, error)

List implements orbital.Store.

func (*SQL) Transaction

func (s *SQL) Transaction(ctx context.Context, txFunc orbital.TransactionFunc) error

Transaction implements orbital.Store.

func (*SQL) Update

func (s *SQL) Update(ctx context.Context, rs ...orbital.Entity) ([]orbital.Entity, error)

Update implements orbital.Store.