Package org.dotwebstack.framework.backend.postgres

Class PostgresDataLoader

java.lang.Object

org.dotwebstack.framework.backend.postgres.PostgresDataLoader

All Implemented Interfaces:

BackendDataLoader

@Component
public class PostgresDataLoader
extends Object
implements BackendDataLoader

Constructor Summary

Constructors

Constructor	Description
PostgresDataLoader(org.springframework.r2dbc.core.DatabaseClient databaseClient, SelectQueryBuilder selectQueryBuilder)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<reactor.core.publisher.GroupedFlux<KeyCondition,Map<String,Object>>>	batchLoadMany(Set<KeyCondition> keyConditions, LoadEnvironment environment)
reactor.core.publisher.Flux<reactor.core.publisher.GroupedFlux<KeyCondition,Map<String,Object>>>	batchLoadManyRequest(Set<KeyCondition> keyConditions, CollectionRequest collectionRequest)
reactor.core.publisher.Flux<reactor.util.function.Tuple2<KeyCondition,Map<String,Object>>>	batchLoadSingle(Set<KeyCondition> keyConditions, LoadEnvironment environment)
reactor.core.publisher.Flux<reactor.util.function.Tuple2<KeyCondition,Map<String,Object>>>	batchLoadSingleRequest(ObjectRequest objectRequest)
reactor.core.publisher.Flux<Map<String,Object>>	loadMany(KeyCondition keyCondition, LoadEnvironment environment)
reactor.core.publisher.Flux<Map<String,Object>>	loadManyRequest(KeyCondition keyCondition, CollectionRequest collectionRequest)
reactor.core.publisher.Mono<Map<String,Object>>	loadSingle(KeyCondition keyCondition, LoadEnvironment environment)
reactor.core.publisher.Mono<Map<String,Object>>	loadSingleRequest(ObjectRequest objectRequest)
boolean	supports(TypeConfiguration<?> typeConfiguration)
boolean	useRequestApproach()

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresDataLoader

public PostgresDataLoader(org.springframework.r2dbc.core.DatabaseClient databaseClient,
                          SelectQueryBuilder selectQueryBuilder)

Method Detail

supports

public boolean supports(TypeConfiguration<?> typeConfiguration)

Specified by:

supports in interface BackendDataLoader

loadSingleRequest

public reactor.core.publisher.Mono<Map<String,Object>> loadSingleRequest(ObjectRequest objectRequest)

Specified by:

loadSingleRequest in interface BackendDataLoader

loadManyRequest

public reactor.core.publisher.Flux<Map<String,Object>> loadManyRequest(KeyCondition keyCondition,
                                                                             CollectionRequest collectionRequest)

Specified by:

loadManyRequest in interface BackendDataLoader

batchLoadManyRequest

public reactor.core.publisher.Flux<reactor.core.publisher.GroupedFlux<KeyCondition,Map<String,Object>>> batchLoadManyRequest(Set<KeyCondition> keyConditions,
                                                                                                                                         CollectionRequest collectionRequest)

Specified by:

batchLoadManyRequest in interface BackendDataLoader

batchLoadSingleRequest

public reactor.core.publisher.Flux<reactor.util.function.Tuple2<KeyCondition,Map<String,Object>>> batchLoadSingleRequest(ObjectRequest objectRequest)

Specified by:

batchLoadSingleRequest in interface BackendDataLoader

loadSingle

public reactor.core.publisher.Mono<Map<String,Object>> loadSingle(KeyCondition keyCondition,
                                                                        LoadEnvironment environment)

Specified by:

loadSingle in interface BackendDataLoader

batchLoadSingle

public reactor.core.publisher.Flux<reactor.util.function.Tuple2<KeyCondition,Map<String,Object>>> batchLoadSingle(Set<KeyCondition> keyConditions,
                                                                                                                              LoadEnvironment environment)

Specified by:

batchLoadSingle in interface BackendDataLoader

loadMany

public reactor.core.publisher.Flux<Map<String,Object>> loadMany(KeyCondition keyCondition,
                                                                      LoadEnvironment environment)

Specified by:

loadMany in interface BackendDataLoader

batchLoadMany

public reactor.core.publisher.Flux<reactor.core.publisher.GroupedFlux<KeyCondition,Map<String,Object>>> batchLoadMany(Set<KeyCondition> keyConditions,
                                                                                                                                  LoadEnvironment environment)

Specified by:

batchLoadMany in interface BackendDataLoader

useRequestApproach

public boolean useRequestApproach()

Specified by:

useRequestApproach in interface BackendDataLoader