2018-06-27 12:29:21 +02:00
|
|
|
package eu.eudat.logic.managers;
|
2018-01-17 13:03:51 +01:00
|
|
|
|
2018-06-27 12:29:21 +02:00
|
|
|
import eu.eudat.logic.builders.model.criteria.ExternalDatasetCriteriaBuilder;
|
|
|
|
import eu.eudat.logic.builders.model.models.DataTableDataBuilder;
|
2018-03-21 11:57:56 +01:00
|
|
|
import eu.eudat.data.dao.entities.ExternalDatasetDao;
|
|
|
|
import eu.eudat.data.entities.ExternalDataset;
|
|
|
|
import eu.eudat.data.dao.criteria.ExternalDatasetCriteria;
|
2019-03-05 16:33:59 +01:00
|
|
|
import eu.eudat.logic.services.operations.DatabaseRepository;
|
2018-06-27 12:29:21 +02:00
|
|
|
import eu.eudat.models.data.externaldataset.ExternalDatasetListingModel;
|
2018-03-21 13:11:02 +01:00
|
|
|
import eu.eudat.data.query.items.table.externaldataset.ExternalDatasetTableRequest;
|
2018-06-27 12:29:21 +02:00
|
|
|
import eu.eudat.models.data.helpers.common.DataTableData;
|
|
|
|
import eu.eudat.logic.proxy.config.exceptions.HugeResultSet;
|
|
|
|
import eu.eudat.logic.proxy.config.exceptions.NoURLFound;
|
|
|
|
import eu.eudat.logic.proxy.fetching.RemoteFetcher;
|
2018-01-17 13:03:51 +01:00
|
|
|
import eu.eudat.queryable.QueryableList;
|
2018-06-27 12:29:21 +02:00
|
|
|
import eu.eudat.logic.services.ApiContext;
|
2019-03-05 16:33:59 +01:00
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
2019-02-01 17:56:55 +01:00
|
|
|
import org.springframework.stereotype.Component;
|
2018-01-17 13:03:51 +01:00
|
|
|
|
|
|
|
import java.util.List;
|
|
|
|
import java.util.UUID;
|
|
|
|
|
2019-02-01 17:56:55 +01:00
|
|
|
@Component
|
2018-01-17 13:03:51 +01:00
|
|
|
public class ExternalDatasetManager {
|
|
|
|
|
2019-03-05 16:33:59 +01:00
|
|
|
private ApiContext apiContext;
|
|
|
|
private DatabaseRepository databaseRepository;
|
|
|
|
private RemoteFetcher remoteFetcher;
|
|
|
|
@Autowired
|
|
|
|
public ExternalDatasetManager(ApiContext apiContext) {
|
|
|
|
this.apiContext = apiContext;
|
|
|
|
this.databaseRepository = apiContext.getOperationsContext().getDatabaseRepository();
|
|
|
|
this.remoteFetcher = apiContext.getOperationsContext().getRemoteFetcher();
|
|
|
|
}
|
|
|
|
|
|
|
|
public DataTableData<ExternalDatasetListingModel> getPaged(ExternalDatasetTableRequest externalDatasetTableRequest) throws Exception {
|
2018-03-05 17:18:45 +01:00
|
|
|
QueryableList<ExternalDataset> items = apiContext.getOperationsContext().getDatabaseRepository().getExternalDatasetDao().getWithCriteria(externalDatasetTableRequest.getCriteria());
|
2018-01-17 13:03:51 +01:00
|
|
|
QueryableList<ExternalDataset> pagedItems = PaginationManager.applyPaging(items, externalDatasetTableRequest);
|
2018-02-21 11:07:31 +01:00
|
|
|
List<ExternalDatasetListingModel> externalDatasetListingmodels = pagedItems.select(item -> new ExternalDatasetListingModel().fromDataModel(item));
|
2018-03-05 17:18:45 +01:00
|
|
|
return apiContext.getOperationsContext().getBuilderFactory().getBuilder(DataTableDataBuilder.class).data(externalDatasetListingmodels).totalCount(items.count()).build();
|
2018-01-17 13:03:51 +01:00
|
|
|
}
|
|
|
|
|
2019-03-05 16:33:59 +01:00
|
|
|
public List<ExternalDatasetListingModel> getWithExternal(String query) throws HugeResultSet, NoURLFound, InstantiationException, IllegalAccessException {
|
2018-03-05 17:18:45 +01:00
|
|
|
ExternalDatasetCriteria criteria = apiContext.getOperationsContext().getBuilderFactory().getBuilder(ExternalDatasetCriteriaBuilder.class).like(query).build();
|
2018-03-21 11:57:56 +01:00
|
|
|
QueryableList<eu.eudat.data.entities.ExternalDataset> items = apiContext.getOperationsContext().getDatabaseRepository().getExternalDatasetDao().getWithCriteria(criteria);
|
2018-02-21 11:07:31 +01:00
|
|
|
List<ExternalDatasetListingModel> externalDatasets = items.select(item -> new ExternalDatasetListingModel().fromDataModel(item));
|
2018-01-17 13:03:51 +01:00
|
|
|
return externalDatasets;
|
|
|
|
}
|
|
|
|
|
2019-03-05 16:33:59 +01:00
|
|
|
public ExternalDatasetListingModel getSingle(UUID id) throws HugeResultSet, NoURLFound, InstantiationException, IllegalAccessException {
|
|
|
|
ExternalDataset externalDataset = databaseRepository.getExternalDatasetDao().find(id);
|
2018-01-17 13:03:51 +01:00
|
|
|
ExternalDatasetListingModel externalDatasetModel = new ExternalDatasetListingModel();
|
|
|
|
externalDatasetModel.fromDataModel(externalDataset);
|
|
|
|
return externalDatasetModel;
|
|
|
|
}
|
2018-09-04 11:36:18 +02:00
|
|
|
|
2019-03-05 16:33:59 +01:00
|
|
|
public ExternalDataset create(eu.eudat.models.data.externaldataset.ExternalDatasetModel externalDatasetModel) throws Exception {
|
2018-09-04 11:36:18 +02:00
|
|
|
ExternalDataset externalDataset = externalDatasetModel.toDataModel();
|
|
|
|
return apiContext.getOperationsContext().getDatabaseRepository().getExternalDatasetDao().createOrUpdate(externalDataset);
|
|
|
|
}
|
2018-01-17 13:03:51 +01:00
|
|
|
}
|