Package com.flowable.serviceregistry.engine.impl.invoker.db

Class DbServiceInvoker

java.lang.Object

com.flowable.serviceregistry.engine.impl.invoker.db.DbServiceInvoker

All Implemented Interfaces:

ServiceInvoker

public class DbServiceInvoker
extends Object
implements ServiceInvoker

Field Summary

Fields

Modifier and Type	Field	Description
static String	KEY
protected ServiceRegistryEngineConfiguration	serviceRegistryEngineConfiguration

Constructor Summary

Constructors

Constructor	Description
DbServiceInvoker(ServiceRegistryEngineConfiguration serviceRegistryEngineConfiguration)

Method Summary

Modifier and Type	Method	Description
protected Collection<String>	asCollectionOfStrings(Object object)
protected DbColumnMapping	asDbColumnMapping(ColumnMapping columnMapping)
protected int	asInt(Object object, int valueIfNull)
protected QueryParameter	asQueryParameter(QueryColumnMapping queryColumn, ServiceDefinitionModel model, ServiceRegistryDataObjectModel dataObjectModel, String tenantId, Object value)
protected String	asString(Object object)
protected Map<String,List<DbColumnMapping>>	columnsByName(ServiceDefinitionModel model, DBServiceOperationConfig config, Function<DBServiceOperationConfig,Collection<DbColumnMapping>> columnsProvider)
protected JoinTableConfig	createJoinTableConfig(ColumnMapping columnMapping, String tenantId, String owningTableName, ServiceDefinitionModel model, ServiceRegistryDataObjectModel dataObjectModel, long id)
protected List<JoinTableConfig>	createJoinTableConfigs(ServiceDefinitionModel model, ServiceRegistryDataObjectModel dataObjectModel, DBServiceOperationConfig operationConfig, String tenantId)
protected List<JoinTableConfig>	createJoinTableConfigs(ServiceDefinitionModel model, ServiceRegistryDataObjectModel dataObjectModel, BiPredicate<String,ColumnMapping> shouldUseMappingRelation, String tenantId)
protected Collection<String>	extractAccessibleByGroups(ServiceInvocationVariablesContainer variablesContainer, DBServiceOperationConfig operationConfig)
protected String	extractAccessibleByUser(ServiceInvocationVariablesContainer variablesContainer, DBServiceOperationConfig operationConfig)
protected QueryParameter	extractLookupIdQueryParameter(ServiceDefinitionModel serviceDefinitionModel, ServiceOperation serviceOperation, Object lookupIdValue)
protected int	extractPagingParameter(ServiceInvocationVariablesContainer variableContainer, DBServiceOperationConfig operationConfig, Function<SelectPaging,String> parameterMapper, String defaultParameterName, int valueIfNull)
protected Collection<QueryParameter>	extractQueryParameters(ServiceInvocationVariablesContainer variableContainer, ServiceDefinitionModel model, ServiceRegistryDataObjectModel dataObjectModel, DBServiceOperationConfig operationConfig)
protected Collection<OrderParameter>	extractSortParameters(ServiceInvocationVariablesContainer variablesContainer, ServiceDefinitionModel serviceDefinitionModel, DBServiceOperationConfig operationConfig, boolean lookupIdFallback)
protected ColumnMapping	findColumnMapping(String columnMapping, ServiceDefinitionModel model)
protected org.apache.commons.lang3.tuple.Pair<ServiceDefinitionModel,ServiceRegistryDataObjectModel>	findReferenceServiceDefinitionModel(ColumnMapping columnMapping, String tenantId, ServiceRegistryDataObjectModel dataObjectModel)
protected Map<String,ServiceInputParameter>	inputParametersByName(ServiceDefinitionModel model, ServiceOperation operation)
protected Map<String,List<DbColumnMapping>>	insertColumnsByName(ServiceDefinitionModel model, DBServiceOperationConfig config)
DatabaseServiceInvocationResponse	invoke(ServiceDefinitionModel serviceDefinitionModel, ServiceOperation serviceOperation, ServiceInvocationContext context)
List<ServiceInvocationResponse>	invokeList(ServiceDefinitionModel serviceDefinition, ServiceOperation serviceOperation, ServiceInvocationContext serviceInvocationContext)
protected int	performDelete(ServiceInvocationVariablesContainer serviceInvocationVariablesContainer, ServiceDefinitionModel serviceDefinitionModel, ServiceRegistryDataObjectModel dataObjectModel, DBServiceOperationConfig operationConfig)
protected DatabaseServiceInvocationResponse	performSearch(ServiceInvocationVariablesContainer serviceInvocationVariablesContainer, ServiceDefinitionModel serviceDefinitionModel, ServiceRegistryDataObjectModel dataObjectModel, ServiceOperation serviceOperation, DBServiceOperationConfig operationConfig)
protected int	performUpdate(ServiceInvocationVariablesContainer serviceInvocationVariablesContainer, ServiceDefinitionModel serviceDefinitionModel, ServiceRegistryDataObjectModel dataObjectModel, ServiceOperation serviceOperation, DBServiceOperationConfig operationConfig)
protected DBServiceOperationConfig	readOperationConfig(ServiceDefinitionModel model, ServiceOperation operation)
protected Map<String,String>	sortPropertiesByName(ServiceDefinitionModel model, DBServiceOperationConfig config)
protected Map<String,List<DbColumnMapping>>	updateColumnsByName(ServiceDefinitionModel model, DBServiceOperationConfig config)

Methods inherited from class java.lang.Object

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

Field Detail

KEY

public static final String KEY

See Also:

Constant Field Values

serviceRegistryEngineConfiguration

protected ServiceRegistryEngineConfiguration serviceRegistryEngineConfiguration

Constructor Detail

DbServiceInvoker

public DbServiceInvoker(ServiceRegistryEngineConfiguration serviceRegistryEngineConfiguration)

Method Detail

invoke

public DatabaseServiceInvocationResponse invoke(ServiceDefinitionModel serviceDefinitionModel,
                                                ServiceOperation serviceOperation,
                                                ServiceInvocationContext context)

Specified by:

invoke in interface ServiceInvoker

createJoinTableConfigs

protected List<JoinTableConfig> createJoinTableConfigs(ServiceDefinitionModel model,
                                                       ServiceRegistryDataObjectModel dataObjectModel,
                                                       DBServiceOperationConfig operationConfig,
                                                       String tenantId)

createJoinTableConfigs

protected List<JoinTableConfig> createJoinTableConfigs(ServiceDefinitionModel model,
                                                       ServiceRegistryDataObjectModel dataObjectModel,
                                                       BiPredicate<String,ColumnMapping> shouldUseMappingRelation,
                                                       String tenantId)

createJoinTableConfig

protected JoinTableConfig createJoinTableConfig(ColumnMapping columnMapping,
                                                String tenantId,
                                                String owningTableName,
                                                ServiceDefinitionModel model,
                                                ServiceRegistryDataObjectModel dataObjectModel,
                                                long id)

findReferenceServiceDefinitionModel

protected org.apache.commons.lang3.tuple.Pair<ServiceDefinitionModel,ServiceRegistryDataObjectModel> findReferenceServiceDefinitionModel(ColumnMapping columnMapping,
                                                                                                                                               String tenantId,
                                                                                                                                               ServiceRegistryDataObjectModel dataObjectModel)

invokeList

public List<ServiceInvocationResponse> invokeList(ServiceDefinitionModel serviceDefinition,
                                                  ServiceOperation serviceOperation,
                                                  ServiceInvocationContext serviceInvocationContext)

Specified by:

invokeList in interface ServiceInvoker

sortPropertiesByName

protected Map<String,String> sortPropertiesByName(ServiceDefinitionModel model,
                                                        DBServiceOperationConfig config)

insertColumnsByName

protected Map<String,List<DbColumnMapping>> insertColumnsByName(ServiceDefinitionModel model,
                                                                      DBServiceOperationConfig config)

updateColumnsByName

protected Map<String,List<DbColumnMapping>> updateColumnsByName(ServiceDefinitionModel model,
                                                                      DBServiceOperationConfig config)

columnsByName

protected Map<String,List<DbColumnMapping>> columnsByName(ServiceDefinitionModel model,
                                                                DBServiceOperationConfig config,
                                                                Function<DBServiceOperationConfig,Collection<DbColumnMapping>> columnsProvider)

asDbColumnMapping

protected DbColumnMapping asDbColumnMapping(ColumnMapping columnMapping)

inputParametersByName

protected Map<String,ServiceInputParameter> inputParametersByName(ServiceDefinitionModel model,
                                                                        ServiceOperation operation)

performSearch

protected DatabaseServiceInvocationResponse performSearch(ServiceInvocationVariablesContainer serviceInvocationVariablesContainer,
                                                          ServiceDefinitionModel serviceDefinitionModel,
                                                          ServiceRegistryDataObjectModel dataObjectModel,
                                                          ServiceOperation serviceOperation,
                                                          DBServiceOperationConfig operationConfig)

performUpdate

protected int performUpdate(ServiceInvocationVariablesContainer serviceInvocationVariablesContainer,
                            ServiceDefinitionModel serviceDefinitionModel,
                            ServiceRegistryDataObjectModel dataObjectModel,
                            ServiceOperation serviceOperation,
                            DBServiceOperationConfig operationConfig)

performDelete

protected int performDelete(ServiceInvocationVariablesContainer serviceInvocationVariablesContainer,
                            ServiceDefinitionModel serviceDefinitionModel,
                            ServiceRegistryDataObjectModel dataObjectModel,
                            DBServiceOperationConfig operationConfig)

extractPagingParameter

protected int extractPagingParameter(ServiceInvocationVariablesContainer variableContainer,
                                     DBServiceOperationConfig operationConfig,
                                     Function<SelectPaging,String> parameterMapper,
                                     String defaultParameterName,
                                     int valueIfNull)

extractAccessibleByUser

protected String extractAccessibleByUser(ServiceInvocationVariablesContainer variablesContainer,
                                         DBServiceOperationConfig operationConfig)

extractAccessibleByGroups

protected Collection<String> extractAccessibleByGroups(ServiceInvocationVariablesContainer variablesContainer,
                                                       DBServiceOperationConfig operationConfig)

extractQueryParameters

protected Collection<QueryParameter> extractQueryParameters(ServiceInvocationVariablesContainer variableContainer,
                                                            ServiceDefinitionModel model,
                                                            ServiceRegistryDataObjectModel dataObjectModel,
                                                            DBServiceOperationConfig operationConfig)

asQueryParameter

protected QueryParameter asQueryParameter(QueryColumnMapping queryColumn,
                                          ServiceDefinitionModel model,
                                          ServiceRegistryDataObjectModel dataObjectModel,
                                          String tenantId,
                                          Object value)

findColumnMapping

protected ColumnMapping findColumnMapping(String columnMapping,
                                          ServiceDefinitionModel model)

readOperationConfig

protected DBServiceOperationConfig readOperationConfig(ServiceDefinitionModel model,
                                                       ServiceOperation operation)

extractLookupIdQueryParameter

protected QueryParameter extractLookupIdQueryParameter(ServiceDefinitionModel serviceDefinitionModel,
                                                       ServiceOperation serviceOperation,
                                                       Object lookupIdValue)

extractSortParameters

protected Collection<OrderParameter> extractSortParameters(ServiceInvocationVariablesContainer variablesContainer,
                                                           ServiceDefinitionModel serviceDefinitionModel,
                                                           DBServiceOperationConfig operationConfig,
                                                           boolean lookupIdFallback)

asInt

protected int asInt(Object object,
                    int valueIfNull)

asString

protected String asString(Object object)

asCollectionOfStrings

protected Collection<String> asCollectionOfStrings(Object object)