adapter

type Adapter interface {
	// RegisterSchema provides the compiled schema to the adapter, allowing
	// it to map fields, understand constraints, and prepare statements or tables.
	RegisterSchema(ctx context.Context, s *schema.Schema) error

	// Create inserts a single record into the given model. It returns the persisted
	// data (including database defaults or auto-generated IDs).
	// Returns ErrConflict on unique constraint violations.
	Create(ctx context.Context, model string, data map[string]any) (map[string]any, error)

	// FindOne retrieves the first record matching all conditions, or ErrNotFound if none match.
	FindOne(ctx context.Context, model string, where []Condition) (map[string]any, error)

	// FindMany retrieves all records matching the query criteria.
	FindMany(ctx context.Context, q Query) ([]map[string]any, error)

	// Update modifies records matching the conditions and returns the number of rows affected.
	Update(ctx context.Context, model string, where []Condition, update map[string]any) (int64, error)

	// Delete removes records matching the conditions and returns the number of rows affected.
	Delete(ctx context.Context, model string, where []Condition) (int64, error)

	// Count returns the number of records matching the given conditions.
	Count(ctx context.Context, model string, where []Condition) (int64, error)

	// Transaction executes fn atomically within a database transaction.
	// Nested transactions join the parent transaction.
	Transaction(ctx context.Context, fn func(ctx context.Context, tx Adapter) error) error
}

type Condition struct {
	Field    string
	Operator Operator
	Value    any
}

type Operator string

type Query struct {
	Model  string
	Where  []Condition
	Limit  int
	Offset int
	SortBy string
	Desc   bool
}

type SchemaExporter interface {
	// ExportSchema returns the raw DDL statements required to provision the registered schema.
	ExportSchema(ctx context.Context) ([]string, error)
}