Package com.flowable.dataobject.engine.impl.runtime.datasource

Class DataObjectOperations

java.lang.Object

com.flowable.dataobject.engine.impl.runtime.datasource.DataObjectOperations

public class DataObjectOperations
extends Object

Author:

Filip Hrisafov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	DataObjectOperations.RestServiceInvocationResponseBpmnErrorVariableContainer

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	DEFINITION_ID_REPRESENTATION_KEY
protected static final String	DEFINITION_KEY_REPRESENTATION_KEY
protected static final String	FLOWABLE_DATA_OBJECT_MODEL_KEY
protected static final String	FLOWABLE_DATA_OBJECT_VARIABLE_TYPE
protected static final String	FLOWABLE_DETACHED_DATA_OBJECT_VARIABLE_TYPE
protected static final String	FLOWABLE_VARIABLE_TYPE_KEY
protected static final org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Constructor	Description
DataObjectOperations()

Method Summary

Modifier and Type	Method	Description
protected ServiceRegistryDataObjectModel	asServiceRegistryDataObjectModel(DataObjectModel dataObjectModel)
protected BpmnError	createBpmnError(String code, String message, RestServiceInvocationResponse response, String tenantId)
DataObjectInstanceVariableContainer	createDataObjectInstance(Map<String,Object> data, Object lookupIdValue, DataObjectDefinition dataObjectDefinition, ServiceRegistryDataObjectModel objectModel, String tenantId)
DetachedDataObjectInstanceVariableContainer	createDetachedDataObjectInstance(com.fasterxml.jackson.databind.node.ObjectNode data, String lookupIdValue, DataObjectDefinition dataObjectDefinition, ServiceRegistryDataObjectModel objectModel, String tenantId)
int	delete(DataObjectInstanceVariableContainer entity, DataObjectModel dataObjectModel)
int	delete(String operation, Map<String,Object> serviceData, DataObjectDefinition dataObjectDefinition, DataObjectModel dataObjectModel)
DataObjectInstanceVariableContainer	detachDataObjectInstance(DataObjectInstanceVariableContainer dataObject, DataObjectDefinition dataObjectDefinition, DataObjectModel dataObjectModel)
protected Set<String>	fieldsAsSet(Iterable<String> fields)
protected Map<String,ServiceRegistryFieldMapping>	getFieldMappingsByName(ServiceRegistryDataObjectModel objectModel)
Object	getLookupId(Map<String,Object> data, DataObjectDefinition dataObjectDefinition, DataObjectModel objectModel)
protected String	getLookupIdName(ServiceRegistryDataObjectModel model)
protected PlatformEngineConfigurationApi	getPlatformEngineConfigurationApi()
ServiceDefinitionModel	getServiceDefinitionModel(DataObjectDefinition dataObjectDefinition, DataObjectModel objectModel)
protected ServiceRegistryEngineConfigurationApi	getServiceRegistryConfigurationApi()
protected ServiceRegistryRepositoryService	getServiceRegistryRepositoryService()
protected ServiceRegistryRuntimeService	getServiceRegistryRuntimeService()
int	insert(DataObjectInstanceVariableContainer entity, DataObjectModel dataObjectModel)
DataObjectInstanceVariableContainer	insert(String operation, Map<String,Object> serviceData, DataObjectDefinition dataObjectDefinition, DataObjectModel dataObjectModel)
protected ServiceInvocationResultResponse	invokeServiceAndGetResult(DataObjectInstanceVariableContainer entity, ServiceRegistryDataObjectModel objectModel, String operationKey, String operationType, String tenantId, Map<String,ServiceRegistryFieldMapping> fieldMappingsByName, boolean logMissingProperties)
protected <R> R	invokeServiceAndGetResult(String operation, String operationType, Map<String,Object> serviceData, String tenantId, ServiceRegistryDataObjectModel registryDataObjectModel, Function<ServiceInvocationBuilder,R> builderInvocationFunction)
protected Object	parseInputValue(com.fasterxml.jackson.databind.node.ArrayNode values, String tenantId)
protected Object	parseInputValue(com.fasterxml.jackson.databind.node.ObjectNode value, String tenantId)
Object	parseInputValue(Object value, String tenantId)
protected Object	parseInputValue(List<Object> values, String tenantId)
protected Object	parseInputValue(Map<String,Object> value, String tenantId)
protected Object	parseValue(com.fasterxml.jackson.databind.JsonNode value)
protected Object	parseValue(ServiceRegistryFieldMapping fieldMapping, Object value, DataObjectInstanceVariableContainer entity)
protected Object	parseValue(Object value)
protected Boolean	parseValueAsBoolean(Object value)
protected Object	parseValueAsDataObject(ServiceRegistryFieldMapping fieldMapping, Object value, String tenantId)
protected Date	parseValueAsDate(Object value, DataObjectInstanceVariableContainer entity)
protected Double	parseValueAsDouble(Object value)
protected Integer	parseValueAsInteger(Object value)
protected com.fasterxml.jackson.databind.JsonNode	parseValueAsJson(Object value, DataObjectInstanceVariableContainer entity)
protected LocalDate	parseValueAsLocalDate(Object value, DataObjectInstanceVariableContainer entity)
protected Long	parseValueAsLong(Object value)
protected String	parseValueAsText(Object value)
protected List<DataObjectInstanceVariableContainer>	parseValuesAsListOfDataObjects(Object value, DataObjectDefinition definition, ServiceRegistryDataObjectModel model)
protected DataObjectInstanceVariableContainer	parseValuesAsSingleDataObject(Object value, DataObjectDefinition definition, ServiceRegistryDataObjectModel model)
protected void	readonlyCheckEnabled(Object entity, boolean readonlyCheck)
DataObjectInstanceVariableContainer	selectById(String id, DataObjectDefinition dataObjectDefinition, DataObjectModel dataObjectModel)
List<DataObjectInstanceVariableContainer>	selectList(String operation, Map<String,Object> serviceData, DataObjectDefinition dataObjectDefinition, DataObjectModel dataObjectModel)
DataObjectInstanceVariableContainer	selectSingle(String operation, Map<String,Object> serviceData, DataObjectDefinition dataObjectDefinition, DataObjectModel dataObjectModel)
protected DataObjectInstanceVariableContainer	toDataObjectInstanceVariableContainer(ServiceInvocationResultResponse invocationResult, DataObjectDefinition dataObjectDefinition, ServiceRegistryDataObjectModel registryDataObjectModel)
protected boolean	treatInputValueAsDataObject(com.fasterxml.jackson.databind.JsonNode value)
protected boolean	treatInputValueAsDataObject(Map<?,?> value)
int	update(DataObjectInstanceVariableContainer entity, DataObjectModel dataObjectModel)
DataObjectInstanceVariableContainer	update(String operation, Map<String,Object> serviceData, DataObjectDefinition dataObjectDefinition, DataObjectModel dataObjectModel)
protected void	updateValuesInEntity(DataObjectInstanceVariableContainer entity, ServiceInvocationResultResponse invocationResult, List<ServiceRegistryFieldMapping> fieldMappings)
protected void	updateValuesInEntity(DataObjectInstanceVariableContainer entity, Predicate<String> hasValueCheck, Function<String,Object> valueProvider, List<ServiceRegistryFieldMapping> fieldMappings)

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

protected static final org.slf4j.Logger LOGGER

DEFINITION_ID_REPRESENTATION_KEY

protected static final String DEFINITION_ID_REPRESENTATION_KEY

See Also:

• Constant Field Values

DEFINITION_KEY_REPRESENTATION_KEY

protected static final String DEFINITION_KEY_REPRESENTATION_KEY

See Also:

• Constant Field Values

FLOWABLE_VARIABLE_TYPE_KEY

protected static final String FLOWABLE_VARIABLE_TYPE_KEY

See Also:

• Constant Field Values

FLOWABLE_DATA_OBJECT_MODEL_KEY

protected static final String FLOWABLE_DATA_OBJECT_MODEL_KEY

See Also:

• Constant Field Values

FLOWABLE_DATA_OBJECT_VARIABLE_TYPE

protected static final String FLOWABLE_DATA_OBJECT_VARIABLE_TYPE

See Also:

• Constant Field Values

FLOWABLE_DETACHED_DATA_OBJECT_VARIABLE_TYPE

protected static final String FLOWABLE_DETACHED_DATA_OBJECT_VARIABLE_TYPE

See Also:

• Constant Field Values

Constructor Details

DataObjectOperations

public DataObjectOperations()

Method Details

getServiceDefinitionModel

public ServiceDefinitionModel getServiceDefinitionModel(DataObjectDefinition dataObjectDefinition,
 DataObjectModel objectModel)

getLookupId

public Object getLookupId(Map<String,Object> data,
 DataObjectDefinition dataObjectDefinition,
 DataObjectModel objectModel)

getLookupIdName

protected String getLookupIdName(ServiceRegistryDataObjectModel model)

selectById

public DataObjectInstanceVariableContainer selectById(String id,
 DataObjectDefinition dataObjectDefinition,
 DataObjectModel dataObjectModel)

selectSingle

public DataObjectInstanceVariableContainer selectSingle(String operation,
 Map<String,Object> serviceData,
 DataObjectDefinition dataObjectDefinition,
 DataObjectModel dataObjectModel)

toDataObjectInstanceVariableContainer

protected DataObjectInstanceVariableContainer toDataObjectInstanceVariableContainer(ServiceInvocationResultResponse invocationResult,
 DataObjectDefinition dataObjectDefinition,
 ServiceRegistryDataObjectModel registryDataObjectModel)

selectList

public List<DataObjectInstanceVariableContainer> selectList(String operation,
 Map<String,Object> serviceData,
 DataObjectDefinition dataObjectDefinition,
 DataObjectModel dataObjectModel)

insert

public DataObjectInstanceVariableContainer insert(String operation,
 Map<String,Object> serviceData,
 DataObjectDefinition dataObjectDefinition,
 DataObjectModel dataObjectModel)

insert

public int insert(DataObjectInstanceVariableContainer entity,
 DataObjectModel dataObjectModel)

update

public DataObjectInstanceVariableContainer update(String operation,
 Map<String,Object> serviceData,
 DataObjectDefinition dataObjectDefinition,
 DataObjectModel dataObjectModel)

update

public int update(DataObjectInstanceVariableContainer entity,
 DataObjectModel dataObjectModel)

delete

public int delete(String operation,
 Map<String,Object> serviceData,
 DataObjectDefinition dataObjectDefinition,
 DataObjectModel dataObjectModel)

delete

public int delete(DataObjectInstanceVariableContainer entity,
 DataObjectModel dataObjectModel)

parseInputValue

public Object parseInputValue(Object value,
 String tenantId)

parseInputValue

protected Object parseInputValue(Map<String,Object> value,
 String tenantId)

parseInputValue

protected Object parseInputValue(com.fasterxml.jackson.databind.node.ObjectNode value,
 String tenantId)

parseInputValue

protected Object parseInputValue(List<Object> values,
 String tenantId)

parseInputValue

protected Object parseInputValue(com.fasterxml.jackson.databind.node.ArrayNode values,
 String tenantId)

treatInputValueAsDataObject

protected boolean treatInputValueAsDataObject(Map<?,?> value)

treatInputValueAsDataObject

protected boolean treatInputValueAsDataObject(com.fasterxml.jackson.databind.JsonNode value)

asServiceRegistryDataObjectModel

protected ServiceRegistryDataObjectModel asServiceRegistryDataObjectModel(DataObjectModel dataObjectModel)

getFieldMappingsByName

protected Map<String,ServiceRegistryFieldMapping> getFieldMappingsByName(ServiceRegistryDataObjectModel objectModel)

invokeServiceAndGetResult

protected ServiceInvocationResultResponse invokeServiceAndGetResult(DataObjectInstanceVariableContainer entity,
 ServiceRegistryDataObjectModel objectModel,
 String operationKey,
 String operationType,
 String tenantId,
 Map<String,ServiceRegistryFieldMapping> fieldMappingsByName,
 boolean logMissingProperties)

invokeServiceAndGetResult

protected <R> R invokeServiceAndGetResult(String operation,
 String operationType,
 Map<String,Object> serviceData,
 String tenantId,
 ServiceRegistryDataObjectModel registryDataObjectModel,
 Function<ServiceInvocationBuilder,R> builderInvocationFunction)

updateValuesInEntity

protected void updateValuesInEntity(DataObjectInstanceVariableContainer entity,
 ServiceInvocationResultResponse invocationResult,
 List<ServiceRegistryFieldMapping> fieldMappings)

updateValuesInEntity

protected void updateValuesInEntity(DataObjectInstanceVariableContainer entity,
 Predicate<String> hasValueCheck,
 Function<String,Object> valueProvider,
 List<ServiceRegistryFieldMapping> fieldMappings)

readonlyCheckEnabled

protected void readonlyCheckEnabled(Object entity,
 boolean readonlyCheck)

fieldsAsSet

protected Set<String> fieldsAsSet(Iterable<String> fields)

parseValue

protected Object parseValue(ServiceRegistryFieldMapping fieldMapping,
 Object value,
 DataObjectInstanceVariableContainer entity)

parseValueAsText

protected String parseValueAsText(Object value)

parseValueAsBoolean

protected Boolean parseValueAsBoolean(Object value)

parseValueAsDouble

protected Double parseValueAsDouble(Object value)

parseValueAsInteger

protected Integer parseValueAsInteger(Object value)

parseValueAsLong

protected Long parseValueAsLong(Object value)

parseValueAsDate

protected Date parseValueAsDate(Object value,
 DataObjectInstanceVariableContainer entity)

parseValueAsLocalDate

protected LocalDate parseValueAsLocalDate(Object value,
 DataObjectInstanceVariableContainer entity)

parseValueAsJson

protected com.fasterxml.jackson.databind.JsonNode parseValueAsJson(Object value,
 DataObjectInstanceVariableContainer entity)

parseValueAsDataObject

protected Object parseValueAsDataObject(ServiceRegistryFieldMapping fieldMapping,
 Object value,
 String tenantId)

parseValuesAsListOfDataObjects

protected List<DataObjectInstanceVariableContainer> parseValuesAsListOfDataObjects(Object value,
 DataObjectDefinition definition,
 ServiceRegistryDataObjectModel model)

parseValuesAsSingleDataObject

protected DataObjectInstanceVariableContainer parseValuesAsSingleDataObject(Object value,
 DataObjectDefinition definition,
 ServiceRegistryDataObjectModel model)

parseValue

protected Object parseValue(Object value)

parseValue

protected Object parseValue(com.fasterxml.jackson.databind.JsonNode value)

getServiceRegistryConfigurationApi

protected ServiceRegistryEngineConfigurationApi getServiceRegistryConfigurationApi()

getPlatformEngineConfigurationApi

protected PlatformEngineConfigurationApi getPlatformEngineConfigurationApi()

getServiceRegistryRuntimeService

protected ServiceRegistryRuntimeService getServiceRegistryRuntimeService()

getServiceRegistryRepositoryService

protected ServiceRegistryRepositoryService getServiceRegistryRepositoryService()

createBpmnError

protected BpmnError createBpmnError(String code,
 String message,
 RestServiceInvocationResponse response,
 String tenantId)

createDataObjectInstance

public DataObjectInstanceVariableContainer createDataObjectInstance(Map<String,Object> data,
 Object lookupIdValue,
 DataObjectDefinition dataObjectDefinition,
 ServiceRegistryDataObjectModel objectModel,
 String tenantId)

detachDataObjectInstance

public DataObjectInstanceVariableContainer detachDataObjectInstance(DataObjectInstanceVariableContainer dataObject,
 DataObjectDefinition dataObjectDefinition,
 DataObjectModel dataObjectModel)

createDetachedDataObjectInstance

public DetachedDataObjectInstanceVariableContainer createDetachedDataObjectInstance(com.fasterxml.jackson.databind.node.ObjectNode data,
 String lookupIdValue,
 DataObjectDefinition dataObjectDefinition,
 ServiceRegistryDataObjectModel objectModel,
 String tenantId)