Package org.linuxforhealth.fhir.persistence.jdbc.dao.impl

Class FetchPayloadsForIdsDAO

java.lang.Object

org.linuxforhealth.fhir.persistence.jdbc.dao.impl.FetchPayloadsForIdsDAO

public class FetchPayloadsForIdsDAO
extends java.lang.Object

DAO to fetch the payload objects for a list of resource ids

Constructor Summary

Constructors

Constructor	Description
FetchPayloadsForIdsDAO(java.lang.String schemaName, java.lang.String resourceType, java.util.List<java.lang.Long> resourceIds, java.util.function.Consumer<ResourcePayload> consumer)	Public constructor

Method Summary

Modifier and Type	Method	Description
void	run(java.sql.Connection c)	Fetch the payloads using the given connection

Methods inherited from class java.lang.Object

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

Constructor Detail

FetchPayloadsForIdsDAO

public FetchPayloadsForIdsDAO(java.lang.String schemaName,
                              java.lang.String resourceType,
                              java.util.List<java.lang.Long> resourceIds,
                              java.util.function.Consumer<ResourcePayload> consumer)

Public constructor

Parameters:

schemaName - the FHIR data schema

the - resource type name

resourceIds - the list of database resource_id values

consumer - the consumer to process each result. The stream must be processed before returning from the accept method

Method Detail

run

public void run(java.sql.Connection c)
         throws FHIRPersistenceException

Fetch the payloads using the given connection

Parameters:

c -

Throws:

FHIRPersistenceException