orm

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

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

type ConnectionPgx interface {
	PgxDBRunner
	DB() PgxDBProxy
	Builder() sqlf.Builder
	Begin(ctx context.Context) (TxPgxProxy, error)
	BeginTx(ctx context.Context, opts pgx.TxOptions) (TxPgxProxy, error)
}

type DefaultScoper interface {
	DefaultScope() error
}

type HookAfterDelete interface {
	AfterDelete(ctx context.Context, err error)
}

type HookAfterInsert interface {
	AfterInsert(ctx context.Context, err error, fields ...SchemaField)
}

type HookAfterSave interface {
	AfterSave(ctx context.Context, err error, fields ...SchemaField)
}

type HookAfterUpdate interface {
	AfterUpdate(ctx context.Context, err error, fields ...SchemaField)
}

type HookBeforeDelete interface {
	BeforeDelete(ctx context.Context) error
}

type HookBeforeInsert interface {
	BeforeInsert(ctx context.Context, fields ...SchemaField) error
}

type HookBeforeSave interface {
	BeforeSave(ctx context.Context, fields ...SchemaField) error
}

type HookBeforeUpdate interface {
	BeforeUpdate(ctx context.Context, fields ...SchemaField) error
}

type JoinType int

type PgxDBProxy interface {
	PgxDBRunner
	Begin(ctx context.Context) (pgx.Tx, error)
	BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)
}

type PgxDBRunner interface {
	PgxExecer
	PgxQueryer
	PgxRowQueryer
	PgxPreparer
}

type PgxExecer interface {
	Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
}

type PgxPreparer interface {
	Prepare(ctx context.Context, name, sql string) (sd *pgconn.StatementDescription, err error)
}

type PgxQueryer interface {
	Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)
	QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, f func(pgx.QueryFuncRow) error) (pgconn.CommandTag, error)
}

type PgxRowQueryer interface {
	QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row
}

type Query interface {
	sqlf.FastSqlizer
	sqlf.Sqlizer

	// Select defines what are the fields that this query should return. If this method is called twice, the second time
	// will override all values from the first call. If you want to stack fields, use `AddSelect` instead.
	Select(fields ...SchemaField)
	// AddSelect adds the passed fields to the select list.
	AddSelect(fields ...SchemaField)
	// GetSelect returns the fields that where selected.
	GetSelect() []SchemaField
	// From defines the FROM clause for the Query
	From(schema Schema)
	// Join adds a join to the Query.
	Join(joinType JoinType, schema Schema, condition string, params ...interface{})
	// Join adds a inner join to the Query.
	InnerJoin(schema Schema, condition string, params ...interface{})
	// Join adds a left join to the Query.
	LeftJoin(schema Schema, condition string, params ...interface{})
	// Join adds a right join to the Query.
	RightJoin(schema Schema, condition string, params ...interface{})
	// Join adds a full join to the Query.
	FullJoin(schema Schema, condition string, params ...interface{})
	// Where define the where condition for the Query.
	Where(condition string, params ...interface{})
	// WhereCriteria define the where condition for the Query using criteria.
	WhereCriteria(conditions ...sqlf.FastSqlizer)
	// Skip sets the skip option for the Query.
	Skip(skip int)
	// Limit defines the pagination for the Query.
	Limit(limit int)
	// GroupBy defines the GROUP BY clause for the Query.
	GroupBy(fields ...interface{})
	// GroupByX defines the GROUP BY with the HAVING clause for the Query.
	GroupByX(func(sqlf.GroupBy))
	// OrderBy defines the ORDER BY for the Query.
	OrderBy(fields ...interface{})
	// OrderBy defines the ORDER BY for the Query.
	OrderByX(f func(sqlf.OrderBy))
}

type Record interface {
	GetID() interface{}
	TableName() string
	IsPersisted() bool
	IsWritable() bool
}

type ResultSet interface {
	Next() bool
	Scan(args ...interface{}) error
	Err() error
}

type ResultSetPgx interface {
	ResultSet
	Close()
	FieldDescriptions() []pgproto3.FieldDescription
}

type Schema interface {
	// Table returns the table name for this schema.
	Table() string
	// Alias returns the alias name for the table. By default, its implementation
	// should return the table name.
	Alias() string
	// As returns a new Schema with an SQL alias set.
	As(alias string) Schema
	// Columns list all columns from this schema.
	Columns() []SchemaField
}

type SchemaField interface {
	fmt.Stringer
	// Name returns the name of the field
	Name() string
	// QualifiedName returns the field name together with the Schema table name.
	QualifiedName(Schema) string
}

type TxPgxProxy interface {
	PgxDBRunner
	Commit(context.Context) error
	Rollback(context.Context) error
}