db

type DBColumn struct {
	Table *DBTable
	// contains filtered or unexported fields
}

type DBCommandInterface interface {
	Execute(query string, params ...interface{}) (*sql.Result, error)
	Query(query string, params ...interface{}) (*DBTable, error)
	QueryFirst(query string, params ...interface{}) (*DBRow, error)
}

type DBConnectionInterface interface {
	Open() error
	Close() error
	// contains filtered or unexported methods
}

type DBRow struct {
	Table *DBTable
	// contains filtered or unexported fields
}

type DBTable struct {
	// contains filtered or unexported fields
}

type DataFetcher[T any] interface {
	// Fetch fetches the entity records by the given limit and offset.
	Fetch(limit, offset int) ([]T, error)
}

type DataReader[T any, K any] interface {
	// GetById gets the entity record by the id value.
	// For composite primary keys, a struct can be used as a parameter.
	GetById(id K) (T, error)

	// Retrieve retrieves all the records of the entity from the database.
	Retrieve() ([]T, error)
}

type DataWriter[T any, K any] interface {
	// Insert inserts a new record into the database and returns the primary key value.
	// For composite primary keys, a struct can be used as a result.
	Insert(entity T) (K, error)

	// Update updates the given entity by the id value.
	// For composite primary keys, a struct can be used as a parameter.
	Update(id K, entity T) (bool, error)

	// Delete deletes the database entity record by the id value.
	// For composite primary keys, a struct can be used as a parameter.
	Delete(id K) (bool, error)
}

type ExistenceChecker[T any] interface {
	// CheckExistence checks the existence of a record by the id column.
	// For composite primary keys, a struct can be used as a parameter.
	CheckExistence(id T) (bool, error)
}

type MockConn struct {
	// contains filtered or unexported fields
}

type MockConnector struct {
	// contains filtered or unexported fields
}

type MockDriver struct {
	// contains filtered or unexported fields
}

type Repository[T any, K any] interface {
	DataReader[T, K]
	DataFetcher[T]
	ExistenceChecker[K]
	DataWriter[T, K]
}