Package org.opennms.netmgt.filter

Class JdbcFilterDao

java.lang.Object

org.opennms.netmgt.filter.JdbcFilterDao

All Implemented Interfaces:

FilterDao, org.springframework.beans.factory.InitializingBean

@Transactional
public class JdbcFilterDao
extends Object
implements FilterDao, org.springframework.beans.factory.InitializingBean

JdbcFilterDao class.

Version:

$Id: $

Author:

DJ Gregor

Constructor Summary

Constructors

Constructor	Description
JdbcFilterDao()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()	afterPropertiesSet
void	destroy()
void	flushActiveIpAddressListCache()
protected InetAddress	getActiveIPAddress(String rule, String address)
List<InetAddress>	getActiveIPAddressList(String rule)	Get the (non-deleted) IP addresses that match the specified rule.
DatabaseSchemaConfig	getDatabaseSchemaConfigFactory()	getDatabaseSchemaConfigFactory
DataSource	getDataSource()	getDataSource
String	getInterfaceWithServiceStatement(String rule)	getInterfaceWithServiceStatement
List<InetAddress>	getIPAddressList(String rule)	Get the IP addresses (including deleted) that match the specified rule.
Map<InetAddress,Set<String>>	getIPAddressServiceMap(String rule)	getIPServiceMap
Map<Integer,Map<InetAddress,Set<String>>>	getNodeIPAddressServiceMap(String rule)	Retrieve a mapping of IP-services scoped by node that match the given rule.
String	getNodeIPServiceMappingStatement(String rule)	getNodeIPServiceMappingStatement
SortedMap<Integer,String>	getNodeMap(String rule)	This method returns a map of all node IDs and node labels that match the rule that is passed in, sorted by node ID.
String	getNodeMappingStatement(String rule)	getNodeMappingStatement
protected String	getSQLStatement(String rule)	This method parses a rule and returns the SQL select statement equivalent of the rule.
protected String	getSQLStatement(String rule, long nodeId, String ipaddr, String service)	This method should be called if you want to put constraints on the node, interface or service that is returned in the rule.
boolean	isRuleMatching(String rule)	Does this rule match anything in the database? In particular, does it return at least one record from the database?
boolean	isValid(String addr, String rule)	isValid
void	setDatabaseSchemaConfigFactory(DatabaseSchemaConfig factory)	setDatabaseSchemaConfigFactory
void	setDataSource(DataSource dataSource)	setDataSource
void	validateRule(String rule)	validateRule

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcFilterDao

public JdbcFilterDao()

Method Detail

setDataSource

public void setDataSource(DataSource dataSource)

setDataSource

Parameters:

dataSource - a DataSource object.

getDataSource

public DataSource getDataSource()

getDataSource

Returns:

a DataSource object.

setDatabaseSchemaConfigFactory

public void setDatabaseSchemaConfigFactory(DatabaseSchemaConfig factory)

setDatabaseSchemaConfigFactory

Parameters:

factory - a DatabaseSchemaConfigFactory object.

getDatabaseSchemaConfigFactory

public DatabaseSchemaConfig getDatabaseSchemaConfigFactory()

getDatabaseSchemaConfigFactory

Returns:

a DatabaseSchemaConfigFactory object.

afterPropertiesSet

public void afterPropertiesSet()

afterPropertiesSet

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

destroy

@PreDestroy
@Transactional(propagation=NOT_SUPPORTED)
public void destroy()
             throws Exception

Throws:

Exception

getNodeMap

public SortedMap<Integer,String> getNodeMap(String rule)
                                           throws FilterParseException

This method returns a map of all node IDs and node labels that match the rule that is passed in, sorted by node ID. This method returns a map of all nodeids and nodelabels that match the rule that is passed in, sorted by nodeid.

Specified by:

getNodeMap in interface FilterDao

Parameters:

rule - an expression rule to be parsed and executed.

Returns:

SortedMap containing all node IDs and node labels selected by the rule.

Throws:

FilterParseException - if a rule is syntactically incorrect or failed in executing the SQL statement

getIPAddressServiceMap

public Map<InetAddress,Set<String>> getIPAddressServiceMap(String rule)
                                                          throws FilterParseException

getIPServiceMap

Specified by:

getIPAddressServiceMap in interface FilterDao

Parameters:

rule - a String object.

Returns:

a Map object.

Throws:

FilterParseException - if any.

getNodeIPAddressServiceMap

public Map<Integer,Map<InetAddress,Set<String>>> getNodeIPAddressServiceMap(String rule)
                                                                                 throws FilterParseException

Description copied from interface: FilterDao

Retrieve a mapping of IP-services scoped by node that match the given rule.

Specified by:

getNodeIPAddressServiceMap in interface FilterDao

Parameters:

rule - filter rule to evaluate

Returns:

map of IP-services

Throws:

FilterParseException - if the rule is invalid

flushActiveIpAddressListCache

@CacheEvict(value="activeIpAddressList",
            allEntries=true)
public void flushActiveIpAddressListCache()

Specified by:

flushActiveIpAddressListCache in interface FilterDao

getActiveIPAddressList

@Cacheable("activeIpAddressList")
public List<InetAddress> getActiveIPAddressList(String rule)
                                         throws FilterParseException

Get the (non-deleted) IP addresses that match the specified rule.

Specified by:

getActiveIPAddressList in interface FilterDao

Parameters:

rule - the filter rule

Returns:

a List of IP addresses.

Throws:

FilterParseException - if a rule is syntactically incorrect or failed in executing the SQL statement.

getActiveIPAddress

protected InetAddress getActiveIPAddress(String rule,
                                         String address)

getIPAddressList

public List<InetAddress> getIPAddressList(String rule)
                                   throws FilterParseException

Get the IP addresses (including deleted) that match the specified rule.

Specified by:

getIPAddressList in interface FilterDao

Parameters:

rule - the filter rule

Returns:

a List of IP addresses.

Throws:

FilterParseException - if a rule is syntactically incorrect or failed in executing the SQL statement.

isValid

public boolean isValid(String addr,
                       String rule)
                throws FilterParseException

isValid

This method verifies if an ip address adheres to a given rule.

Specified by:

isValid in interface FilterDao

Parameters:

addr - a String object.

rule - a String object.

Returns:

a boolean.

Throws:

FilterParseException - if a rule is syntactically incorrect or failed in executing the SQL statement.

isRuleMatching

public boolean isRuleMatching(String rule)
                       throws FilterParseException

Does this rule match anything in the database? In particular, does it return at least one record from the database?

Specified by:

isRuleMatching in interface FilterDao

Parameters:

rule - rule to match on

Returns:

true if there is at least one match, false otherwise

Throws:

FilterParseException - if any.

validateRule

public void validateRule(String rule)
                  throws FilterParseException

validateRule

Specified by:

validateRule in interface FilterDao

Parameters:

rule - a String object.

Throws:

FilterParseException - if any.

getNodeMappingStatement

public String getNodeMappingStatement(String rule)
                               throws FilterParseException

getNodeMappingStatement

Parameters:

rule - a String object.

Returns:

a String object.

Throws:

FilterParseException - if any.

getNodeIPServiceMappingStatement

public String getNodeIPServiceMappingStatement(String rule)
                                        throws FilterParseException

getNodeIPServiceMappingStatement

Parameters:

rule - a String object.

Returns:

a String object.

Throws:

FilterParseException - if any.

getInterfaceWithServiceStatement

public String getInterfaceWithServiceStatement(String rule)
                                        throws FilterParseException

getInterfaceWithServiceStatement

Parameters:

rule - a String object.

Returns:

a String object.

Throws:

FilterParseException - if any.

getSQLStatement

protected String getSQLStatement(String rule)
                          throws FilterParseException

This method parses a rule and returns the SQL select statement equivalent of the rule.

Parameters:

rule - a String object.

Returns:

the SQL select statement

Throws:

FilterParseException - if any.

getSQLStatement

protected String getSQLStatement(String rule,
                                 long nodeId,
                                 String ipaddr,
                                 String service)
                          throws FilterParseException

This method should be called if you want to put constraints on the node, interface or service that is returned in the rule. This is useful to see if a particular node, interface, or service matches in the rule, and is primarily used to filter notices. A sub-select is built containing joins constrained by node, interface, and service if they are not null or blank. This select is then ANDed with the filter rule to get the complete SQL statement.

Parameters:

nodeId - a node id to constrain against

ipaddr - an ipaddress to constrain against

service - a service name to constrain against

rule - a String object.

Returns:

a String object.

Throws:

FilterParseException - if any.