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

Class DatabaseSchemaDataObjectJdbcTemplate

java.lang.Object

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

public class DatabaseSchemaDataObjectJdbcTemplate
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Constructor	Description
DatabaseSchemaDataObjectJdbcTemplate()

Method Summary

Modifier and Type	Method	Description
protected Map<String,Object>	createLinkedObject(Map<String,Object> result, JoinTableConfig relation, String linkedId)
protected DatabaseGenericInstanceQuery	createQuery(ServiceDefinitionModel model)
protected void	createRelation(DbSqlSession dbSqlSession, ColumnMappingRelation relation, Object lookupIdValue, Object value)
int	delete(ServiceDefinitionModel serviceDefinitionModel, DatabaseGenericInstanceQuery query)
protected int	deleteRelation(DbSqlSession dbSqlSession, ColumnMappingRelation relation, List<String> instanceIds)
protected String	getLookupIdColumnName(ServiceDefinitionModel model)
protected void	handleListRelation(Map<String,Object> object, Map<String,Object> result, JoinTableConfig relation, Map<String,List<JoinTableConfig>> tablesByRelation)
protected void	handleObjectRelation(Map<String,Object> object, Map<String,Object> result, JoinTableConfig relation, Map<String,List<JoinTableConfig>> tablesByRelation)
protected void	handleRelations(Map<String,Object> object, Map<String,Object> result, String joinTableName, Map<String,List<JoinTableConfig>> tablesByRelation)
Map<String,Object>	insert(ServiceInvocationVariablesContainer variableContainer, ServiceDefinitionModel serviceDefinitionModel, Map<String,List<DbColumnMapping>> insertColumnsByName, BiFunction<String,ServiceDefinitionModel,ColumnMapping> columnMappingProvider)
protected int	insertRelations(DbSqlSession dbSqlSession, ColumnMappingRelation relation, List<?> instanceIds, List<?> referenceIds)
protected List<Map<String,Object>>	selectList(DatabaseGenericInstanceQuery query)
protected List<Map<String,Object>>	selectListWithJoinTables(DbSqlSession dbSqlSession, DatabaseGenericInstanceQuery query)
protected List<Map<String,Object>>	selectListWithoutJoinTables(DbSqlSession dbSqlSession, DatabaseGenericInstanceQuery query)
protected DatabaseServiceInvocationResponse	selectMulti(DatabaseGenericInstanceQuery query)
protected DatabaseServiceInvocationResponse	selectSingle(DatabaseGenericInstanceQuery query)
int	update(ServiceInvocationVariablesContainer variablesContainer, DatabaseGenericInstanceQuery query, Map<String,List<DbColumnMapping>> updateColumnsByName, Function<String,ColumnMapping> columnMappingProvider)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

Constructor Detail

DatabaseSchemaDataObjectJdbcTemplate

public DatabaseSchemaDataObjectJdbcTemplate()

Method Detail

createQuery

protected DatabaseGenericInstanceQuery createQuery(ServiceDefinitionModel model)

getLookupIdColumnName

protected String getLookupIdColumnName(ServiceDefinitionModel model)

selectSingle

protected DatabaseServiceInvocationResponse selectSingle(DatabaseGenericInstanceQuery query)

selectMulti

protected DatabaseServiceInvocationResponse selectMulti(DatabaseGenericInstanceQuery query)

selectList

protected List<Map<String,Object>> selectList(DatabaseGenericInstanceQuery query)

selectListWithoutJoinTables

protected List<Map<String,Object>> selectListWithoutJoinTables(DbSqlSession dbSqlSession,
                                                                     DatabaseGenericInstanceQuery query)

selectListWithJoinTables

protected List<Map<String,Object>> selectListWithJoinTables(DbSqlSession dbSqlSession,
                                                                  DatabaseGenericInstanceQuery query)

handleRelations

protected void handleRelations(Map<String,Object> object,
                               Map<String,Object> result,
                               String joinTableName,
                               Map<String,List<JoinTableConfig>> tablesByRelation)

handleListRelation

protected void handleListRelation(Map<String,Object> object,
                                  Map<String,Object> result,
                                  JoinTableConfig relation,
                                  Map<String,List<JoinTableConfig>> tablesByRelation)

handleObjectRelation

protected void handleObjectRelation(Map<String,Object> object,
                                    Map<String,Object> result,
                                    JoinTableConfig relation,
                                    Map<String,List<JoinTableConfig>> tablesByRelation)

createLinkedObject

protected Map<String,Object> createLinkedObject(Map<String,Object> result,
                                                      JoinTableConfig relation,
                                                      String linkedId)

insert

public Map<String,Object> insert(ServiceInvocationVariablesContainer variableContainer,
                                       ServiceDefinitionModel serviceDefinitionModel,
                                       Map<String,List<DbColumnMapping>> insertColumnsByName,
                                       BiFunction<String,ServiceDefinitionModel,ColumnMapping> columnMappingProvider)

update

public int update(ServiceInvocationVariablesContainer variablesContainer,
                  DatabaseGenericInstanceQuery query,
                  Map<String,List<DbColumnMapping>> updateColumnsByName,
                  Function<String,ColumnMapping> columnMappingProvider)

delete

public int delete(ServiceDefinitionModel serviceDefinitionModel,
                  DatabaseGenericInstanceQuery query)

createRelation

protected void createRelation(DbSqlSession dbSqlSession,
                              ColumnMappingRelation relation,
                              Object lookupIdValue,
                              Object value)

deleteRelation

protected int deleteRelation(DbSqlSession dbSqlSession,
                             ColumnMappingRelation relation,
                             List<String> instanceIds)

insertRelations

protected int insertRelations(DbSqlSession dbSqlSession,
                              ColumnMappingRelation relation,
                              List<?> instanceIds,
                              List<?> referenceIds)