core

type DataAccess[E Entity] interface {
	Get(ctx context.Context, id any) (*E, error)
	Delete(ctx context.Context, id any) (int64, error)
	Query(ctx context.Context, query Query) ([]E, error)
	Count(ctx context.Context, query Query) (int64, error)
	DeleteByQuery(ctx context.Context, query Query) (int64, error)
	Page(ctx context.Context, query Query) (PageList[E], error)
	Create(ctx context.Context, entity *E) (int64, error)
	CreateMulti(ctx context.Context, entities []E) (int64, error)
	Update(ctx context.Context, entity E) (int64, error)
	Patch(ctx context.Context, entity Entity) (int64, error)
	PatchByQuery(ctx context.Context, entity E, query Query) (int64, error)
}

type Entity interface {
	GetId() any

	// SetId set id to self.
	// self: the pointer points to the current entity.
	// id: type could be int, int64 or string so far.
	SetId(self any, id any) error
}

type EntityPath struct {
	Path       []string
	Base       Relation
	Relations  []Relation
	EntityType reflect.Type
}

type FieldMetadata struct {
	Field      reflect.StructField
	IsId       bool
	ColumnName string
	EntityPath *EntityPath
}

type Int64Id struct {
	Id int64 `json:"id,omitempty"`
}

type IntId struct {
	Id int `json:"id,omitempty"`
}

type PageList[D any] struct {
	List  []D   `json:"list"`
	Total int64 `json:"total"`
}

type PageQuery struct {
	Page int    `json:"page,omitempty"`
	Size int    `json:"size,omitempty"`
	Sort string `json:"sort,omitempty"`
}

type Query interface {
	GetPageNumber() int
	GetPageSize() int
	CalcOffset() int
	GetSort() string
	NeedPaging() bool
}

type Relation struct {
	Fk1, Fk2, At string
}

type Response struct {
	Data    any     `json:"data,omitempty"`
	Success bool    `json:"success"`
	Error   *string `json:"error,omitempty"`
}

type RollbackError struct {
	Err    error
	Origin error
}

type TransactionContext interface {
	context.Context
	driver.Tx
	Parent() context.Context
	SavePoint(name string) error
	RollbackTo(name string) error
}

type TransactionManager interface {
	GetClient() any
	StartTransaction(ctx context.Context) (TransactionContext, error)
	SubmitTransaction(ctx context.Context, callback func(tc TransactionContext) error) error
}

type TxDataAccess[E Entity] struct {
	TransactionManager
	DataAccess[E]
}