Class PostgresBackendLoader

java.lang.Object
org.dotwebstack.framework.backend.postgres.PostgresBackendLoader
All Implemented Interfaces:
org.dotwebstack.framework.core.backend.BackendLoader

public class PostgresBackendLoader extends Object implements org.dotwebstack.framework.core.backend.BackendLoader
  • Field Summary

    Fields inherited from interface org.dotwebstack.framework.core.backend.BackendLoader

    NILL_MAP
  • Constructor Summary

    Constructors
    Constructor
    Description
     
  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Flux<reactor.core.publisher.GroupedFlux<Map<String,Object>,Map<String,Object>>>
    batchLoadMany(org.dotwebstack.framework.core.query.model.CollectionBatchRequest collectionBatchRequest, org.dotwebstack.framework.core.query.model.RequestContext requestContext)
     
    reactor.core.publisher.Flux<reactor.util.function.Tuple2<Map<String,Object>,Map<String,Object>>>
    batchLoadSingle(org.dotwebstack.framework.core.query.model.BatchRequest batchRequest, org.dotwebstack.framework.core.query.model.RequestContext requestContext)
     
    reactor.core.publisher.Flux<Map<String,Object>>
    loadMany(org.dotwebstack.framework.core.query.model.CollectionRequest collectionRequest, org.dotwebstack.framework.core.query.model.RequestContext requestContext)
     
    reactor.core.publisher.Mono<Map<String,Object>>
    loadSingle(org.dotwebstack.framework.core.query.model.ObjectRequest objectRequest, org.dotwebstack.framework.core.query.model.RequestContext requestContext)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Constructor Details

    • PostgresBackendLoader

      public PostgresBackendLoader(PostgresClient postgresClient)
  • Method Details

    • loadSingle

      public reactor.core.publisher.Mono<Map<String,Object>> loadSingle(org.dotwebstack.framework.core.query.model.ObjectRequest objectRequest, org.dotwebstack.framework.core.query.model.RequestContext requestContext)
      Specified by:
      loadSingle in interface org.dotwebstack.framework.core.backend.BackendLoader
    • loadMany

      public reactor.core.publisher.Flux<Map<String,Object>> loadMany(org.dotwebstack.framework.core.query.model.CollectionRequest collectionRequest, org.dotwebstack.framework.core.query.model.RequestContext requestContext)
      Specified by:
      loadMany in interface org.dotwebstack.framework.core.backend.BackendLoader
    • batchLoadMany

      public reactor.core.publisher.Flux<reactor.core.publisher.GroupedFlux<Map<String,Object>,Map<String,Object>>> batchLoadMany(org.dotwebstack.framework.core.query.model.CollectionBatchRequest collectionBatchRequest, org.dotwebstack.framework.core.query.model.RequestContext requestContext)
      Specified by:
      batchLoadMany in interface org.dotwebstack.framework.core.backend.BackendLoader
    • batchLoadSingle

      public reactor.core.publisher.Flux<reactor.util.function.Tuple2<Map<String,Object>,Map<String,Object>>> batchLoadSingle(org.dotwebstack.framework.core.query.model.BatchRequest batchRequest, org.dotwebstack.framework.core.query.model.RequestContext requestContext)
      Specified by:
      batchLoadSingle in interface org.dotwebstack.framework.core.backend.BackendLoader