Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Versions API improvements (9763) #9883

Merged
merged 31 commits into from
Oct 18, 2023
Merged
Show file tree
Hide file tree
Changes from 10 commits
Commits
Show all changes
31 commits
Select commit Hold shift + click to select a range
a835f5d
added pagination to the /versions api. dropped the files section from…
landreev Aug 18, 2023
de35ae7
added left join hints to the full filemetadatas lookup. #9763
landreev Aug 21, 2023
4cd62eb
(ongoing experiments; a lot of these changes are temporary and will b…
landreev Aug 22, 2023
1c93978
Merge branch 'develop' into 9763-lookup-optimizations
landreev Aug 22, 2023
4c28979
work in progress.
landreev Aug 29, 2023
ccd6b7d
made the "includeFiles" option true by default, cleaned up the ".find…
landreev Aug 30, 2023
2d27c03
intermediate changes for the adjusted citation date. #9763
landreev Aug 31, 2023
e08f26a
Merge branch 'develop' into 9763-lookup-optimizations
landreev Aug 31, 2023
7b1e799
Additional changes needed for the optimized "embargo publication date…
landreev Sep 6, 2023
fd30fd5
removing a comment (#9763)
landreev Sep 6, 2023
b74affc
a short release note (#9763)
landreev Sep 6, 2023
2324fe1
changed the guide to reflect the fact that the includeFiles flag defa…
landreev Sep 6, 2023
35835e4
extended the release note. (#9763)
landreev Sep 6, 2023
9a9d7d6
cosmetic change in the release note (#9763)
landreev Sep 6, 2023
d465b20
cosmetic change, comment text (#9763)
landreev Sep 6, 2023
ee36dee
removed a noisy logging line that got checked in by mistake in an ear…
landreev Sep 6, 2023
77dc0b5
Merge branch 'develop' into 9763-lookup-optimizations
landreev Sep 11, 2023
bfe7f9c
RestAssured tests for the new functionality added to the /versions ap…
landreev Sep 13, 2023
8e894c3
added another test, for the pagination functionality in the /versions…
landreev Sep 13, 2023
b9e99f3
typo in a comment. #9763
landreev Sep 13, 2023
f164a68
more typos in comments. (#9763)
landreev Sep 13, 2023
66ab0c0
Merge branch 'develop' into 9763-lookup-optimizations
landreev Oct 11, 2023
b5be877
Merge branch 'develop' into 9763-lookup-optimizations
landreev Oct 11, 2023
18cdf13
stripping more dead code in the version service bean (my experimental…
landreev Oct 11, 2023
381ddf5
more commented-out code that needed to be removed before finalizing t…
landreev Oct 11, 2023
4377e12
Merge branch 'develop' into 9763-lookup-optimizations
landreev Oct 11, 2023
4b5ad8f
rename sql script #9763
pdurbin Oct 13, 2023
402ccfb
Merge branch 'develop' into 9763-lookup-optimizations #9763
pdurbin Oct 13, 2023
f47867e
renaming the flyway script since 6.0.0.1 has already been merged. (#9…
landreev Oct 15, 2023
a1349ba
Merge branch '9763-lookup-optimizations' of https://github.com/IQSS/d…
landreev Oct 15, 2023
037e2d9
Merge branch 'develop' into 9763-lookup-optimizations
landreev Oct 15, 2023
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 8 additions & 1 deletion doc/sphinx-guides/source/api/native-api.rst
Original file line number Diff line number Diff line change
Expand Up @@ -830,7 +830,7 @@ The fully expanded example above (without environment variables) looks like this

.. code-block:: bash

curl "https://demo.dataverse.org/api/datasets/24/versions"
curl "https://demo.dataverse.org/api/datasets/24/versions?includeFiles=true"

It returns a list of versions with their metadata, and file list:

Expand Down Expand Up @@ -883,6 +883,10 @@ It returns a list of versions with their metadata, and file list:
]
}

The optional ``includeFiles`` parameter specifies whether the files should be listed in the output. It defaults to ``false``. (Note that for a dataset with a large number of versions and/or files having the files included can dramatically increase the volume of the output). A separate ``/files`` API can be used for listing the files, or a subset thereof in a given version.
pdurbin marked this conversation as resolved.
Show resolved Hide resolved

The optional ``offset`` and ``limit`` parameters can be used to specify the range of the versions list to be shown. This can be used to paginate through the list in a dataset with a large number of versions.


Get Version of a Dataset
~~~~~~~~~~~~~~~~~~~~~~~~
Expand All @@ -903,6 +907,9 @@ The fully expanded example above (without environment variables) looks like this

curl "https://demo.dataverse.org/api/datasets/24/versions/1.0"

The optional ``includeFiles`` parameter specifies whether the files should be listed in the output (defaults to ``false``). Note that a separate ``/files`` API can be used for listing the files, or a subset thereof in a given version.


.. _export-dataset-metadata-api:

Export Metadata of a Dataset in Various Formats
Expand Down
33 changes: 29 additions & 4 deletions src/main/java/edu/harvard/iq/dataverse/Dataset.java
Original file line number Diff line number Diff line change
Expand Up @@ -158,6 +158,22 @@ public void setCitationDateDatasetFieldType(DatasetFieldType citationDateDataset
this.citationDateDatasetFieldType = citationDateDatasetFieldType;
}

// Per DataCite best practices, the citation date of a dataset may need
// to be adjusted to reflect the latest embargo availability date of any
// file within the first published version.
// If any files are embargoed in the first version, we will find calculate
// the date and cache it here.
private Timestamp embargoCitationDate;

public Timestamp getEmbargoCitationDate() {
return embargoCitationDate;
}

public void setEmbargoCitationDate(Timestamp embargoCitationDate) {
this.embargoCitationDate = embargoCitationDate;
}



@ManyToOne
@JoinColumn(name="template_id",nullable = true)
Expand Down Expand Up @@ -676,11 +692,20 @@ public Timestamp getCitationDate() {
Timestamp citationDate = null;
//Only calculate if this dataset doesn't use an alternate date field for publication date
if (citationDateDatasetFieldType == null) {
List<DatasetVersion> versions = this.versions;
// @todo: remove this commented-out code once/if the PR passes review - L.A.
//List<DatasetVersion> versions = this.versions;
// TODo - is this ever not version 1.0 (or draft if not published yet)
DatasetVersion oldest = versions.get(versions.size() - 1);
//DatasetVersion oldest = versions.get(versions.size() - 1);
// - I believe the answer is yes, the oldest versions will always be
// either 1.0 or draft - L.A.
citationDate = super.getPublicationDate();
if (oldest.isPublished()) {
if (embargoCitationDate != null) {
if (citationDate.compareTo(embargoCitationDate) < 0) {
return embargoCitationDate;
}
}
// @todo: remove this commented-out code once/if the PR passes review - L.A.
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Yes, good to remove commented out code.

/*if (oldest.isPublished()) {
List<FileMetadata> fms = oldest.getFileMetadatas();
for (FileMetadata fm : fms) {
Embargo embargo = fm.getDataFile().getEmbargo();
Expand All @@ -691,7 +716,7 @@ public Timestamp getCitationDate() {
}
}
}
}
}*/
}
return citationDate;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -137,7 +137,7 @@ public Dataset findDeep(Object pk) {
.setHint("eclipselink.left-join-fetch", "o.files.roleAssignments")
.getSingleResult();
}

public List<Dataset> findByOwnerId(Long ownerId) {
return findByOwnerId(ownerId, false);
}
Expand Down
8 changes: 7 additions & 1 deletion src/main/java/edu/harvard/iq/dataverse/DatasetVersion.java
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,13 @@
query = "SELECT OBJECT(o) FROM DatasetVersion AS o WHERE o.dataset.harvestedFrom IS NULL and o.releaseTime IS NOT NULL and o.archivalCopyLocation IS NULL"
),
@NamedQuery(name = "DatasetVersion.findById",
query = "SELECT o FROM DatasetVersion o LEFT JOIN FETCH o.fileMetadatas WHERE o.id=:id")})
query = "SELECT o FROM DatasetVersion o LEFT JOIN FETCH o.fileMetadatas WHERE o.id=:id"),
@NamedQuery(name = "DatasetVersion.findByDataset",
query = "SELECT o FROM DatasetVersion o WHERE o.dataset.id=:datasetId ORDER BY o.versionNumber DESC, o.minorVersionNumber DESC"),
@NamedQuery(name = "DatasetVersion.findReleasedByDataset",
query = "SELECT o FROM DatasetVersion o WHERE o.dataset.id=:datasetId AND o.versionState=edu.harvard.iq.dataverse.DatasetVersion.VersionState.RELEASED ORDER BY o.versionNumber DESC, o.minorVersionNumber DESC")/*,
@NamedQuery(name = "DatasetVersion.findVersionElements",
query = "SELECT o.id, o.versionState, o.versionNumber, o.minorVersionNumber FROM DatasetVersion o WHERE o.dataset.id=:datasetId ORDER BY o.versionNumber DESC, o.minorVersionNumber DESC")*/})


@Entity
Expand Down
154 changes: 151 additions & 3 deletions src/main/java/edu/harvard/iq/dataverse/DatasetVersionServiceBean.java
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,23 @@ public class DatasetVersionServiceBean implements java.io.Serializable {
private static final Logger logger = Logger.getLogger(DatasetVersionServiceBean.class.getCanonicalName());

private static final SimpleDateFormat logFormatter = new SimpleDateFormat("yyyy-MM-dd'T'HH-mm-ss");


private static final String QUERY_STR_FIND_ALL_FILE_METADATAS_ORDER_BY_LABEL = "SELECT fm FROM FileMetadata fm"
+ " WHERE fm.datasetVersion.id=:datasetVersionId"
+ " ORDER BY fm.label";
private static final String QUERY_STR_FIND_ALL_FILE_METADATAS_ORDER_BY_DATE = "SELECT fm FROM FileMetadata fm, DvObject dvo"
+ " WHERE fm.datasetVersion.id = :datasetVersionId"
+ " AND fm.dataFile.id = dvo.id"
+ " ORDER BY CASE WHEN dvo.publicationDate IS NOT NULL THEN dvo.publicationDate ELSE dvo.createDate END";
private static final String QUERY_STR_FIND_ALL_FILE_METADATAS_ORDER_BY_SIZE = "SELECT fm FROM FileMetadata fm, DataFile df"
+ " WHERE fm.datasetVersion.id = :datasetVersionId"
+ " AND fm.dataFile.id = df.id"
+ " ORDER BY df.filesize";
private static final String QUERY_STR_FIND_ALL_FILE_METADATAS_ORDER_BY_TYPE = "SELECT fm FROM FileMetadata fm, DataFile df"
+ " WHERE fm.datasetVersion.id = :datasetVersionId"
+ " AND fm.dataFile.id = df.id"
+ " ORDER BY df.contentType";

@EJB
DatasetServiceBean datasetService;

Expand Down Expand Up @@ -149,7 +165,19 @@ public DatasetVersion getDatasetVersion(){
return this.datasetVersionForResponse;
}
} // end RetrieveDatasetVersionResponse


/**
* Different criteria to sort the results of FileMetadata queries used in {@link DatasetVersionServiceBean#getFileMetadatas}
*/
public enum FileMetadatasOrderCriteria {
NameAZ,
NameZA,
Newest,
Oldest,
Size,
Type
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I recognize this from #9693. Does it matter which PR is merged first?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I would prefer #9693 to be merged first, and then resolve the conflict in this branch (I added a database lookup optimization on top of the code introduced in that PR).

}

public DatasetVersion find(Object pk) {
return em.find(DatasetVersion.class, pk);
}
Expand All @@ -166,9 +194,44 @@ public DatasetVersion findDeep(Object pk) {
.setHint("eclipselink.left-join-fetch", "o.fileMetadatas.datasetVersion")
.setHint("eclipselink.left-join-fetch", "o.fileMetadatas.dataFile.releaseUser")
.setHint("eclipselink.left-join-fetch", "o.fileMetadatas.dataFile.creator")
.setHint("eclipselink.left-join-fetch", "o.fileMetadatas.dataFile.dataFileTags")
.getSingleResult();
}


/**
* Performs the same database lookup as the one behind Dataset.getVersions().
* Additionally, provides the arguments for selecting a partial list of
* (length-offset) versions for pagination, plus the ability to pre-select
* only the publicly-viewable versions.
* It is recommended that individual software components utilize the
* ListVersionsCommand, instead of calling this service method directly.
* @param datasetId
* @param offset for pagination through long lists of versions
* @param length for pagination through long lists of versions
* @param includeUnpublished retrieves all the versions, including drafts and deaccessioned.
* @return (partial) list of versions
*/
public List<DatasetVersion> findVersions(Long datasetId, Integer offset, Integer length, boolean includeUnpublished) {
TypedQuery<DatasetVersion> query;
if (includeUnpublished) {
query = em.createNamedQuery("DatasetVersion.findByDataset", DatasetVersion.class);
} else {
query = em.createNamedQuery("DatasetVersion.findReleasedByDataset", DatasetVersion.class)
.setParameter("datasetId", datasetId);
}

query.setParameter("datasetId", datasetId);

if (offset != null) {
query.setFirstResult(offset);
}
if (length != null) {
query.setMaxResults(length);
}

return query.getResultList();
}

public DatasetVersion findByFriendlyVersionNumber(Long datasetId, String friendlyVersionNumber) {
Long majorVersionNumber = null;
Long minorVersionNumber = null;
Expand Down Expand Up @@ -1224,4 +1287,89 @@ public List<DatasetVersion> getUnarchivedDatasetVersions(){
return null;
}
} // end getUnarchivedDatasetVersions

/**
* Returns a FileMetadata list of files in the specified DatasetVersion
*
* @param datasetVersion the DatasetVersion to access
* @param limit for pagination, can be null
* @param offset for pagination, can be null
* @param orderCriteria a FileMetadatasOrderCriteria to order the results
* @return a FileMetadata list of the specified DatasetVersion
*/
public List<FileMetadata> getFileMetadatas(DatasetVersion datasetVersion, Integer limit, Integer offset, FileMetadatasOrderCriteria orderCriteria) {
TypedQuery<FileMetadata> query = em.createQuery(getQueryStringFromFileMetadatasOrderCriteria(orderCriteria), FileMetadata.class)
.setParameter("datasetVersionId", datasetVersion.getId());

if (limit == null && offset == null) {
query = query.setHint("eclipselink.left-join-fetch", "fm.dataFile.ingestRequest")
.setHint("eclipselink.left-join-fetch", "fm.dataFile.thumbnailForDataset")
.setHint("eclipselink.left-join-fetch", "fm.dataFile.dataTables")
.setHint("eclipselink.left-join-fetch", "fm.fileCategories")
.setHint("eclipselink.left-join-fetch", "fm.dataFile.embargo")
.setHint("eclipselink.left-join-fetch", "fm.datasetVersion")
.setHint("eclipselink.left-join-fetch", "fm.dataFile.releaseUser")
.setHint("eclipselink.left-join-fetch", "fm.dataFile.dataFileTags")
.setHint("eclipselink.left-join-fetch", "fm.dataFile.creator");
} else {
// @todo: is there really no way to use offset-limit with left join hints?
if (limit != null) {
query = query.setMaxResults(limit);
}
if (offset != null) {
query = query.setFirstResult(offset);
}
}
return query.getResultList();
}

public List<FileMetadata> getFileMetadatasByDbId(Long versionId, Integer limit, Integer offset, FileMetadatasOrderCriteria orderCriteria) {
TypedQuery<FileMetadata> query = em.createQuery(getQueryStringFromFileMetadatasOrderCriteria(orderCriteria), FileMetadata.class)
.setParameter("datasetVersionId", versionId);

if (limit == null && offset == null) {
query = query.setHint("eclipselink.left-join-fetch", "fm.dataFile.ingestRequest")
.setHint("eclipselink.left-join-fetch", "fm.dataFile.thumbnailForDataset")
.setHint("eclipselink.left-join-fetch", "fm.dataFile.dataTables")
.setHint("eclipselink.left-join-fetch", "fm.fileCategories")
.setHint("eclipselink.left-join-fetch", "fm.dataFile.embargo")
.setHint("eclipselink.left-join-fetch", "fm.datasetVersion")
.setHint("eclipselink.left-join-fetch", "fm.dataFile.releaseUser")
.setHint("eclipselink.left-join-fetch", "fm.dataFile.creator");
} else {
// @todo: is there really no way to use offset-limit with left join hints?
if (limit != null) {
query = query.setMaxResults(limit);
}
if (offset != null) {
query = query.setFirstResult(offset);
}
}
return query.getResultList();
}

private String getQueryStringFromFileMetadatasOrderCriteria(FileMetadatasOrderCriteria orderCriteria) {
String queryString;
switch (orderCriteria) {
case NameZA:
queryString = QUERY_STR_FIND_ALL_FILE_METADATAS_ORDER_BY_LABEL + " DESC";
break;
case Newest:
queryString = QUERY_STR_FIND_ALL_FILE_METADATAS_ORDER_BY_DATE + " DESC";
break;
case Oldest:
queryString = QUERY_STR_FIND_ALL_FILE_METADATAS_ORDER_BY_DATE;
break;
case Size:
queryString = QUERY_STR_FIND_ALL_FILE_METADATAS_ORDER_BY_SIZE;
break;
case Type:
queryString = QUERY_STR_FIND_ALL_FILE_METADATAS_ORDER_BY_TYPE;
break;
default:
queryString = QUERY_STR_FIND_ALL_FILE_METADATAS_ORDER_BY_LABEL;
break;
}
return queryString;
}
} // end class
Loading
Loading