dal

type Database struct {
	// Endpoint of database
	Endpoint string `flag:""`
	// auto migrate before run
	EnableMigrate bool `flag:",omitempty"`
	// contains filtered or unexported fields
}

type DeleteFunc func()

type ModelWithAutoIncrement interface {
	SetAutoIncrementID(u int64)
}

type ModelWithCreationTime interface {
	MarkCreatedAt()
}

type ModelWithSoftDelete interface {
	MarkDeletedAt()
	SoftDeleteFieldAndZeroValue() (string, driver.Value)
}

type ModelWithUpdationTime interface {
	MarkUpdatedAt()
}

type Mutation[T any] interface {
	IncludesZero(zeroFields ...sqlbuilder.Column) Mutation[T]

	ForDelete(opts ...OptionFunc) Mutation[T]
	ForUpdateSet(assignments ...sqlbuilder.Assignment) Mutation[T]

	Where(where sqlbuilder.SqlExpr) Mutation[T]

	OnConflict(cols sqlbuilder.ColumnCollection) Mutation[T]
	DoNothing() Mutation[T]
	DoUpdateSet(cols ...sqlbuilder.Column) Mutation[T]
	DoWith(func(onConflictAddition sqlbuilder.OnConflictAddition) sqlbuilder.Addition) Mutation[T]

	Returning(cols ...sqlbuilder.SqlExpr) Mutation[T]
	Scan(recv any) Mutation[T]

	Save(ctx context.Context) error
}

type OptionFunc func(m featureSettings)

type Querier interface {
	sqlbuilder.SqlExpr

	ExistsTable(table sqlbuilder.Table) bool
	Apply(patchers ...QuerierPatcher) Querier

	With(t sqlbuilder.Table, build sqlbuilder.BuildSubQuery, modifiers ...string) Querier
	AsTemporaryTable(tableName string) TemporaryTable

	Join(t sqlbuilder.Table, on sqlbuilder.SqlExpr) Querier
	CrossJoin(t sqlbuilder.Table, on sqlbuilder.SqlExpr) Querier
	LeftJoin(t sqlbuilder.Table, on sqlbuilder.SqlExpr) Querier
	RightJoin(t sqlbuilder.Table, on sqlbuilder.SqlExpr) Querier
	FullJoin(t sqlbuilder.Table, on sqlbuilder.SqlExpr) Querier

	Where(where sqlbuilder.SqlExpr) Querier
	WhereAnd(where sqlbuilder.SqlExpr) Querier
	WhereOr(where sqlbuilder.SqlExpr) Querier

	OrderBy(orders ...*sqlbuilder.Order) Querier

	GroupBy(cols ...sqlbuilder.SqlExpr) Querier
	Having(where sqlbuilder.SqlExpr) Querier

	Limit(v int64) Querier
	Offset(v int64) Querier

	Distinct(extras ...sqlbuilder.SqlExpr) Querier
	Select(projects ...sqlbuilder.SqlExpr) Querier

	Scan(v any) Querier

	Find(ctx context.Context) error
	Count(ctx context.Context) (int, error)
}

type QuerierPatcher interface {
	Apply(q Querier) Querier
}

type ScanIterator = scanner.ScanIterator

type Session interface {
	// Name of database
	Name() string
	T(m any) sqlbuilder.Table
	Tx(ctx context.Context, fn func(ctx context.Context) error) error

	Adapter() adapter.Adapter
}

type SoftDeleteValueGetter interface {
	GetDeletedAt() driver.Value
}

type TableWrapper interface {
	Unwrap() sqlbuilder.Model
}

type TemporaryTable interface {
	sqlbuilder.Table
	TableWrapper
	QuerierPatcher
}