interfaces

type BulkRepo interface {
	BulkInsert(tableName string, records []map[string]interface{}) ([]map[string]interface{}, error)
	BulkUpdate(tableName string, updates []map[string]interface{}, whereColumn string) (int64, error)
	BulkDelete(tableName string, ids []interface{}, idColumn string) (int64, error)
	Upsert(tableName string, data map[string]interface{}, conflictColumns, updateColumns []string) (map[string]interface{}, error)
}

type CoreRepo interface {
	Ping() (bool, error)
	ListCollections(schema string) ([]models.Table, error)
	ExecuteQuery(name string, params models.QueryParams) (any, error)
	ExecuteFunction(ctx context.Context, name string, args map[string]interface{}) (any, error)
	ExecuteRawSQL(ctx context.Context, sql string) error
}

type DB interface {
	Exec(query string, args ...any) (sql.Result, error)
	Query(query string, args ...any) (*sql.Rows, error)
	QueryRow(query string, args ...any) *sql.Row
	Close() error
	Ping() error
	Begin() (*sql.Tx, error)
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	Driver() driver.Driver
}

type DBStats struct {
	OpenConnections int
	InUse           int
	Idle            int
}

type DDLRepo interface {
	CreateCollection(req models.CreateTableRequest) error
	AddField(collection string, req models.AddColumnRequest) error
	AlterCollection(collection string, req models.AlterTableRequest) error
	CheckTableExists(tableName string) (bool, error)
}

type DMLRepo interface {
	Insert(collection string, data map[string]any) (any, error)
	Update(collection string, id any, data map[string]any) (any, error)
	Delete(collection string, id any) error
}

type DatabaseRepo interface {
	CoreRepo
	DDLRepo
	DMLRepo
	BulkRepo
	RelationshipRepo
	PerformanceRepo
	MigrationRepo
}

type MigrationRepo interface {
	GetMigrationHistory() ([]map[string]interface{}, error)
	RecordMigration(name, sql, checksum string) error
}

type PerformanceRepo interface {
	CreateIndex(tableName, indexName, columns string) error
	GetPerformanceMetrics() (map[string]interface{}, error)
	AnalyzeQuery(query string) ([]string, error)
}

type RelationshipRepo interface {
	CreateForeignKeyConstraint(relationship *models.RelationshipDefinition) error
	DropRelationshipConstraints(relationship *models.RelationshipDefinition) error
	CreateJoinTable(relationship *models.RelationshipDefinition, joinTable models.CreateJoinTableRequest) error
	DropJoinTable(tableName string) error
	SetOneToOneRelation(relationship *models.RelationshipDefinition, sourceID interface{}, targetID interface{}) error
	SetOneToManyRelation(relationship *models.RelationshipDefinition, sourceID interface{}, targetIDs []interface{}) error
	SetOneToManyRelations(relationship *models.RelationshipDefinition, sourceID interface{}, targetIDs []interface{}) error
	SetManyToManyRelations(relationship *models.RelationshipDefinition, sourceID interface{}, targetIDs []interface{}, data map[string]interface{}) ([]map[string]interface{}, error)
	RemoveOneToManyRelations(relationship *models.RelationshipDefinition, sourceID interface{}, targetIDs []interface{}) (int, error)
	RemoveManyToManyRelations(relationship *models.RelationshipDefinition, sourceID interface{}, targetIDs []interface{}) (int, error)
	GetRelationshipData(ctx context.Context, relationship *models.RelationshipDefinition, sourceID string, params models.QueryParams) ([]map[string]interface{}, error)
}