Revision 43419
Added by Sandro La Bruzzo over 8 years ago
| modules/dnet-openaireplus-workflows/trunk/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/fillhostedByDoaj/update.db.patch.wf.st | ||
|---|---|---|
| 6 | 6 |
<PARAM required="true" type="string" name="api" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
| 7 | 7 |
</PARAMETERS> |
| 8 | 8 |
<ARCS> |
| 9 |
<ARC to="SELECT_MODE"/>
|
|
| 9 |
<ARC to="obtainParams"/>
|
|
| 10 | 10 |
</ARCS> |
| 11 | 11 |
</NODE> |
| 12 |
|
|
| 13 |
<NODE name="SELECT_MODE" type="Selection"> |
|
| 14 |
<DESCRIPTION>Choose collection mode</DESCRIPTION> |
|
| 12 |
<NODE name="obtainParams" type="ObtainOpenaireDataSourceParams"> |
|
| 13 |
<DESCRIPTION>Get more datasource info</DESCRIPTION> |
|
| 15 | 14 |
<PARAMETERS> |
| 16 |
<PARAM required="true" type="string" name="selection" managedBy="user" function="validValues(['REFRESH','INCREMENTAL'])">REFRESH</PARAM>
|
|
| 15 |
<PARAM required="true" type="string" name="providerId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 17 | 16 |
</PARAMETERS> |
| 18 | 17 |
<ARCS> |
| 19 |
<ARC to="COLLECT_REFRESH" name="REFRESH" /> |
|
| 20 |
<ARC to="PREPARE_INCREMENTAL" name="INCREMENTAL" /> |
|
| 18 |
<ARC to="PrepareUpdateSQL"/> |
|
| 21 | 19 |
</ARCS> |
| 22 | 20 |
</NODE> |
| 23 |
|
|
| 24 |
<NODE name="COLLECT_REFRESH" type="CollectRecords"> |
|
| 25 |
<DESCRIPTION>Start Harvesting</DESCRIPTION> |
|
| 26 |
<PARAMETERS> |
|
| 27 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 28 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 29 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">collected_epr</PARAM> |
|
| 21 |
<NODE name="PrepareUpdateSQL" type="PrepareHostedbyUpdateSQL"> |
|
| 22 |
<DESCRIPTION>Generates the update command</DESCRIPTION> |
|
| 23 |
<PARAMETERS> |
|
| 24 |
<PARAM name="theQueryParamName" type="string" managedBy="system" required="true">hostedByUpdateSQL</PARAM> |
|
| 25 |
<PARAM name="updateSqlTemplatePath" type="string" managedBy="user" required="true" |
|
| 26 |
function="listFiles('/eu/dnetlib/msro/openaireplus/workflows/repo-hi/fillhostedBy','st')">/eu/dnetlib/msro/openaireplus/workflows/repo-hi/fillhostedBy/fillHostedBy.sql.st</PARAM>
|
|
| 30 | 27 |
</PARAMETERS> |
| 31 |
<ARCS>
|
|
| 32 |
<ARC to="MD_BUILDER_REFRESH"/>
|
|
| 28 |
<ARCS>
|
|
| 29 |
<ARC to="EXECUTE"/>
|
|
| 33 | 30 |
</ARCS> |
| 34 | 31 |
</NODE> |
| 35 | 32 |
|
| 36 |
<NODE name="MD_BUILDER_REFRESH" type="MdBuilder"> |
|
| 37 |
<DESCRIPTION>Prepare mdstore records</DESCRIPTION> |
|
| 38 |
<PARAMETERS> |
|
| 39 |
<PARAM required="true" type="string" name="inputEprParam" managedBy="system">collected_epr</PARAM> |
|
| 40 |
<PARAM required="true" type="string" name="outputEprParam" managedBy="system">store_epr</PARAM> |
|
| 41 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 42 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 43 |
</PARAMETERS> |
|
| 44 |
<ARCS> |
|
| 45 |
<ARC to="STORE_REFRESH"/> |
|
| 33 |
<NODE name="EXECUTE" type="ExecuteSqlFromEnv"> |
|
| 34 |
<DESCRIPTION>Add new journal to patch entry tables</DESCRIPTION> |
|
| 35 |
<PARAMETERS> |
|
| 36 |
<PARAM name="dbProperty" type="string" managedBy="system" required="true">dnet.openaire.db.name</PARAM> |
|
| 37 |
<PARAM name="sqlParamName" type="string" managedBy="system" required="true">hostedByUpdateSQL</PARAM> |
|
| 38 |
</PARAMETERS> |
|
| 39 |
<ARCS> |
|
| 40 |
<ARC to="success"/> |
|
| 46 | 41 |
</ARCS> |
| 47 | 42 |
</NODE> |
Also available in: Unified diff
Revert to previous version of fill hosted by map