package db

import (
	"context"
	"github.com/olivere/elastic/v7"
	"gorm.io/gorm"
)

type Sql interface {
	Db() *gorm.DB
	Name() string
}

type SqlDatabase interface {
	Get(dbname string) (Sql, error)
	Do(dbname string, c func(db Sql) error) error
	Close(dbname string)
	CloseAll()
	Select(name string)
}

type EsDatabase interface {
	Get(dbname string) (*elastic.Client, error)
	Do(name string, call func(es *elastic.Client) error) error
	Close(name string) error
	CloseAll()
	Select(name string)
}

type ConditionCallback func(ctx context.Context, data interface{}, db *gorm.DB) *gorm.DB