Package dev.dokimos.server.service

Class DatasetService

java.lang.Object

dev.dokimos.server.service.DatasetService

@Service
public class DatasetService
extends Object

Service for server-owned versioned datasets. Datasets are mutable shells; versions are immutable.

Constructor Summary

Constructors

Constructor	Description
DatasetService(DatasetRepository datasetRepository, DatasetVersionRepository versionRepository, DatasetItemRepository itemRepository, ItemResultRepository itemResultRepository)

Method Summary

Modifier and Type	Method	Description
Dataset	createDataset(String name, String description)	Creates a dataset with a globally unique name.
DatasetVersion	createVersion(String datasetName, String description, List<CreateVersionRequest.ItemPayload> items, String createdBy)	Creates a new immutable version of the dataset and inserts all items in one transaction.
void	deleteDataset(String name)	Deletes a dataset.
Dataset	getDataset(String name)	Returns the dataset with the given name.
DatasetDetails	getDatasetDetails(String name)	Returns full dataset details including the version list, newest first.
DatasetVersion	getLatestVersion(String datasetName)	Returns the latest version of the dataset.
DatasetVersion	getVersion(String datasetName, int version)	Returns a specific version of the dataset.
List<DatasetSummary>	listDatasets()	Returns dataset summaries with the latest version number and item count for each.
org.springframework.data.domain.Page<DatasetItem>	listItems(DatasetVersion version, org.springframework.data.domain.Pageable pageable)	Overload for callers that have already resolved a DatasetVersion; avoids the double-fetch path through getVersion(java.lang.String, int).
org.springframework.data.domain.Page<DatasetItem>	listItems(String datasetName, int version, org.springframework.data.domain.Pageable pageable)	Returns items for the given version ordered by ordinal, paginated.
DatasetVersionDetails	promote(PromoteRequest req, String createdBy)	Promotes run item results into a new version of an existing dataset.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DatasetService

public DatasetService(DatasetRepository datasetRepository,
 DatasetVersionRepository versionRepository,
 DatasetItemRepository itemRepository,
 ItemResultRepository itemResultRepository)

Method Details

createDataset

@Transactional
public Dataset createDataset(String name,
 String description)

Creates a dataset with a globally unique name. Has no versions until createVersion(java.lang.String, java.lang.String, java.util.List<dev.dokimos.server.dto.v1.CreateVersionRequest.ItemPayload>, java.lang.String) is called.

Throws:

IllegalStateException - if a dataset with the same name already exists (mapped to 409)

getDataset

@Transactional(readOnly=true)
public Dataset getDataset(String name)

Returns the dataset with the given name.

Throws:

IllegalArgumentException - if no such dataset exists (mapped to 404)

listDatasets

@Transactional(readOnly=true)
public List<DatasetSummary> listDatasets()

Returns dataset summaries with the latest version number and item count for each. Collapses to two queries (one for datasets, one for the latest version row per dataset) regardless of dataset count.

getDatasetDetails

@Transactional(readOnly=true)
public DatasetDetails getDatasetDetails(String name)

Returns full dataset details including the version list, newest first.

deleteDataset

@Transactional
public void deleteDataset(String name)

Deletes a dataset. The FK cascade removes its versions and items; runs that referenced any of those versions have their dataset_version_id set to NULL via the SET NULL FK so the historical run is preserved unlinked.

Throws:

IllegalArgumentException - if no such dataset exists (mapped to 404)

createVersion

@Transactional
public DatasetVersion createVersion(String datasetName,
 String description,
 List<CreateVersionRequest.ItemPayload> items,
 String createdBy)

Creates a new immutable version of the dataset and inserts all items in one transaction. The pessimistic write lock on the parent dataset row serializes concurrent version creations so the next = max(version) + 1 read is consistent; the (dataset_id, version) unique constraint is the backstop if the lock is bypassed. Item ordinals follow the input order (0..N-1).

Throws:

IllegalArgumentException - if no such dataset exists or items is empty (the latter is also caught by bean validation, but the service enforces it for non-controller callers)

promote

@Transactional
public DatasetVersionDetails promote(PromoteRequest req,
 String createdBy)

Promotes run item results into a new version of an existing dataset. Each item's inputs become the new dataset item's inputs, its metadata is carried over, and its expected output is used unless the request supplies an override. Item order is preserved. Delegates to createVersion(java.lang.String, java.lang.String, java.util.List<dev.dokimos.server.dto.v1.CreateVersionRequest.ItemPayload>, java.lang.String) so the version-numbering and locking semantics are identical to a direct create.

Throws:

IllegalArgumentException - if any referenced item result or the dataset is missing (mapped to 404)

getVersion

@Transactional(readOnly=true)
public DatasetVersion getVersion(String datasetName,
 int version)

Returns a specific version of the dataset.

Throws:

IllegalArgumentException - if the dataset or version is missing

getLatestVersion

@Transactional(readOnly=true)
public DatasetVersion getLatestVersion(String datasetName)

Returns the latest version of the dataset.

Throws:

IllegalArgumentException - if the dataset has no versions

listItems

@Transactional(readOnly=true)
public org.springframework.data.domain.Page<DatasetItem> listItems(String datasetName,
 int version,
 org.springframework.data.domain.Pageable pageable)

Returns items for the given version ordered by ordinal, paginated.

listItems

@Transactional(readOnly=true)
public org.springframework.data.domain.Page<DatasetItem> listItems(DatasetVersion version,
 org.springframework.data.domain.Pageable pageable)

Overload for callers that have already resolved a DatasetVersion; avoids the double-fetch path through getVersion(java.lang.String, int).