org.ikasan.topology.dao

Class HibernateTopologyDao

java.lang.Object

org.springframework.dao.support.DaoSupport

org.springframework.orm.hibernate5.support.HibernateDaoSupport

org.ikasan.topology.dao.HibernateTopologyDao

All Implemented Interfaces:

TopologyDao, org.springframework.beans.factory.InitializingBean

public class HibernateTopologyDao
extends org.springframework.orm.hibernate5.support.HibernateDaoSupport
implements TopologyDao

Hibernate implementation of TopologyDao

Author:

Ikasan Development Team

Field Summary

Fields inherited from class org.springframework.dao.support.DaoSupport

logger

Constructor Summary

Constructors

Constructor and Description
HibernateTopologyDao()

Method Summary

Modifier and Type	Method and Description
void	delete(Component component) Delete a component.
void	delete(Flow flow) Delete a flow.
void	delete(Module module) Delete a module.
void	delete(Notification notification)
void	deleteBusinessStream(BusinessStream businessStream) Delete a business stream
void	deleteBusinessStreamFlow(BusinessStreamFlow businessStreamFlow) Delete a business stream flow
void	deleteBusinessStreamFlowByFlowId(java.lang.Long flowId)
void	deleteFilter(Filter filter)
void	deleteFilterComponentsByComponentId(java.lang.Long componentId)
void	deleteFilterComponentsByFilterId(java.lang.Long filterId)
void	deleteRoleFilter(RoleFilter roleFilter)
java.util.List<BusinessStream>	getAllBusinessStreams() Get all BusinessStreams
java.util.List<Component>	getAllComponents() Get all components
java.util.List<Filter>	getAllFilters()
java.util.List<Flow>	getAllFlows() Get all flows.
java.util.List<Module>	getAllModules() Get all modules
java.util.List<Notification>	getAllNotifications()
java.util.List<Server>	getAllServers() Get all servers
java.util.List<BusinessStream>	getBusinessStreamsByUserId(java.util.List<java.lang.Long> ids) Get all BusinessStreams by a list of ids.
java.util.List<BusinessStream>	getBusinessStreamsByUserId(java.lang.Long userId) Get all BusinessStreams associated with a given user.
java.util.List<Component>	getComponentsByServerIdModuleIdAndFlownameAndComponentNameNotIn(java.lang.Long serverId, java.lang.Long moduleId, java.lang.String flowName, java.util.List<java.lang.String> componentNames) Get a components by server id, module id and flow name and component name not in.
Filter	getFilterByName(java.lang.String name)
Flow	getFlowByServerIdModuleIdAndFlowname(java.lang.Long serverId, java.lang.Long moduleId, java.lang.String flowName) Get a flow by server id, module id and flow name.
java.util.List<Flow>	getFlowsByServerIdAndModuleId(java.lang.Long serverId, java.lang.Long moduleId) Get all flows by server id and module id.
java.util.List<Flow>	getFlowsByServerIdModuleIdAndNotInFlownames(java.lang.Long serverId, java.lang.Long moduleId, java.util.List<java.lang.String> flowName) Get a orphaned flow by server id, module id and flow names.
Module	getModuleByName(java.lang.String name) Method to get a Module by its name.
Notification	getNotificationByName(java.lang.String name)
RoleFilter	getRoleFilterByFilterId(java.lang.Long filterId)
java.util.List<RoleFilter>	getRoleFiltersByRoleId(java.util.List<java.lang.Long> roleIds)
void	save(Component component) Save a component.
void	save(Flow flow) Save a flow.
void	save(Module module) Save a module.
void	save(Notification notification)
void	save(Server server) Save a server.
void	saveBusinessStream(BusinessStream businessStream) Save a BusinessStream.
void	saveFilter(Filter filter)
void	saveRoleFilter(RoleFilter roleFilter)

Methods inherited from class org.springframework.orm.hibernate5.support.HibernateDaoSupport

checkDaoConfig, createHibernateTemplate, currentSession, getHibernateTemplate, getSessionFactory, setHibernateTemplate, setSessionFactory

Methods inherited from class org.springframework.dao.support.DaoSupport

afterPropertiesSet, initDao

Methods inherited from class java.lang.Object

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

Constructor Detail

HibernateTopologyDao

public HibernateTopologyDao()

Method Detail

getAllServers

public java.util.List<Server> getAllServers()

Description copied from interface: TopologyDao

Get all servers

Specified by:

getAllServers in interface TopologyDao

Returns:

save

public void save(Server server)

Description copied from interface: TopologyDao

Save a server. Will create a new record or update an existing.

Specified by:

save in interface TopologyDao

getAllModules

public java.util.List<Module> getAllModules()

Description copied from interface: TopologyDao

Get all modules

Specified by:

getAllModules in interface TopologyDao

Returns:

save

public void save(Module module)

Description copied from interface: TopologyDao

Save a module. Will create a new record or update an existing.

Specified by:

save in interface TopologyDao

delete

public void delete(Module module)

Description copied from interface: TopologyDao

Delete a module.

Specified by:

delete in interface TopologyDao

getAllFlows

public java.util.List<Flow> getAllFlows()

Description copied from interface: TopologyDao

Get all flows.

Specified by:

getAllFlows in interface TopologyDao

Returns:

getAllComponents

public java.util.List<Component> getAllComponents()

Description copied from interface: TopologyDao

Get all components

Specified by:

getAllComponents in interface TopologyDao

Returns:

save

public void save(Flow flow)

Description copied from interface: TopologyDao

Save a flow. Will create a new record or update an existing.

Specified by:

save in interface TopologyDao

getAllBusinessStreams

public java.util.List<BusinessStream> getAllBusinessStreams()

Description copied from interface: TopologyDao

Get all BusinessStreams

Specified by:

getAllBusinessStreams in interface TopologyDao

Returns:

saveBusinessStream

public void saveBusinessStream(BusinessStream businessStream)

Description copied from interface: TopologyDao

Save a BusinessStream. Will create a new record or update an existing.

Specified by:

saveBusinessStream in interface TopologyDao

getBusinessStreamsByUserId

public java.util.List<BusinessStream> getBusinessStreamsByUserId(java.lang.Long userId)

Description copied from interface: TopologyDao

Get all BusinessStreams associated with a given user.

Specified by:

getBusinessStreamsByUserId in interface TopologyDao

Returns:

getFlowsByServerIdAndModuleId

public java.util.List<Flow> getFlowsByServerIdAndModuleId(java.lang.Long serverId,
                                                          java.lang.Long moduleId)

Description copied from interface: TopologyDao

Get all flows by server id and module id.

Specified by:

getFlowsByServerIdAndModuleId in interface TopologyDao

Returns:

deleteBusinessStreamFlow

public void deleteBusinessStreamFlow(BusinessStreamFlow businessStreamFlow)

Description copied from interface: TopologyDao

Delete a business stream flow

Specified by:

deleteBusinessStreamFlow in interface TopologyDao

getModuleByName

public Module getModuleByName(java.lang.String name)

Description copied from interface: TopologyDao

Method to get a Module by its name.

Specified by:

getModuleByName in interface TopologyDao

Returns:

getBusinessStreamsByUserId

public java.util.List<BusinessStream> getBusinessStreamsByUserId(java.util.List<java.lang.Long> ids)

Description copied from interface: TopologyDao

Get all BusinessStreams by a list of ids.

Specified by:

getBusinessStreamsByUserId in interface TopologyDao

Returns:

getFlowByServerIdModuleIdAndFlowname

public Flow getFlowByServerIdModuleIdAndFlowname(java.lang.Long serverId,
                                                 java.lang.Long moduleId,
                                                 java.lang.String flowName)

Description copied from interface: TopologyDao

Get a flow by server id, module id and flow name.

Specified by:

getFlowByServerIdModuleIdAndFlowname in interface TopologyDao

Returns:

delete

public void delete(Flow flow)

Description copied from interface: TopologyDao

Delete a flow.

Specified by:

delete in interface TopologyDao

delete

public void delete(Component component)

Description copied from interface: TopologyDao

Delete a component.

Specified by:

delete in interface TopologyDao

save

public void save(Component component)

Description copied from interface: TopologyDao

Save a component. Will create a new record or update an existing.

Specified by:

save in interface TopologyDao

deleteBusinessStream

public void deleteBusinessStream(BusinessStream businessStream)

Description copied from interface: TopologyDao

Delete a business stream

Specified by:

deleteBusinessStream in interface TopologyDao

getFlowsByServerIdModuleIdAndNotInFlownames

public java.util.List<Flow> getFlowsByServerIdModuleIdAndNotInFlownames(java.lang.Long serverId,
                                                                        java.lang.Long moduleId,
                                                                        java.util.List<java.lang.String> flowName)

Description copied from interface: TopologyDao

Get a orphaned flow by server id, module id and flow names.

Specified by:

getFlowsByServerIdModuleIdAndNotInFlownames in interface TopologyDao

Returns:

getComponentsByServerIdModuleIdAndFlownameAndComponentNameNotIn

public java.util.List<Component> getComponentsByServerIdModuleIdAndFlownameAndComponentNameNotIn(java.lang.Long serverId,
                                                                                                 java.lang.Long moduleId,
                                                                                                 java.lang.String flowName,
                                                                                                 java.util.List<java.lang.String> componentNames)

Description copied from interface: TopologyDao

Get a components by server id, module id and flow name and component name not in.

Specified by:

getComponentsByServerIdModuleIdAndFlownameAndComponentNameNotIn in interface TopologyDao

Returns:

saveFilter

public void saveFilter(Filter filter)

Specified by:

saveFilter in interface TopologyDao

getFilterByName

public Filter getFilterByName(java.lang.String name)

Specified by:

getFilterByName in interface TopologyDao

Returns:

getAllFilters

public java.util.List<Filter> getAllFilters()

Specified by:

getAllFilters in interface TopologyDao

Returns:

saveRoleFilter

public void saveRoleFilter(RoleFilter roleFilter)

Specified by:

saveRoleFilter in interface TopologyDao

getRoleFiltersByRoleId

public java.util.List<RoleFilter> getRoleFiltersByRoleId(java.util.List<java.lang.Long> roleIds)

Specified by:

getRoleFiltersByRoleId in interface TopologyDao

Returns:

getRoleFilterByFilterId

public RoleFilter getRoleFilterByFilterId(java.lang.Long filterId)

Specified by:

getRoleFilterByFilterId in interface TopologyDao

Returns:

deleteFilter

public void deleteFilter(Filter filter)

Specified by:

deleteFilter in interface TopologyDao

deleteRoleFilter

public void deleteRoleFilter(RoleFilter roleFilter)

Specified by:

deleteRoleFilter in interface TopologyDao

deleteFilterComponentsByFilterId

public void deleteFilterComponentsByFilterId(java.lang.Long filterId)

Specified by:

deleteFilterComponentsByFilterId in interface TopologyDao

deleteFilterComponentsByComponentId

public void deleteFilterComponentsByComponentId(java.lang.Long componentId)

Specified by:

deleteFilterComponentsByComponentId in interface TopologyDao

deleteBusinessStreamFlowByFlowId

public void deleteBusinessStreamFlowByFlowId(java.lang.Long flowId)

Specified by:

deleteBusinessStreamFlowByFlowId in interface TopologyDao

save

public void save(Notification notification)

Specified by:

save in interface TopologyDao

delete

public void delete(Notification notification)

Specified by:

delete in interface TopologyDao

getNotificationByName

public Notification getNotificationByName(java.lang.String name)

Specified by:

getNotificationByName in interface TopologyDao

Returns:

getAllNotifications

public java.util.List<Notification> getAllNotifications()

Specified by:

getAllNotifications in interface TopologyDao

Returns: