sqlapi

type DB interface {
	Transactional
	ReaderWriter
}

type LogEntry struct {
	Query    func() string
	Rows     int64
	Err      error
	Time     time.Time
	Duration time.Duration
}

type LogFunc func(context.Context, LogEntry)

type NoRows struct {
	Err error
}

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

type Reader interface {
	Read(ctx context.Context, q Query) Rows
}

type ReaderWriter interface {
	Reader
	Writer
}

type Result struct {
	LastInsertId int64
	RowsAffected int64
	Error        error
}

type Rows interface {
	Error() error
	Scan(output interface{}) error
}

type Transactional interface {
	InTransaction(perform func(ReaderWriter) error) error
}

type Writer interface {
	Write(ctx context.Context, q Query) Result
}