org.opennms.netmgt.eventd.processor

Class AbstractJdbcPersister

java.lang.Object

org.opennms.netmgt.eventd.processor.AbstractJdbcPersister

All Implemented Interfaces:

EventWriter, EventProcessor, org.springframework.beans.factory.InitializingBean

Direct Known Subclasses:

JdbcEventWriter

public abstract class AbstractJdbcPersister
extends Object
implements org.springframework.beans.factory.InitializingBean, EventWriter

EventWriter loads the information in each 'Event' into the database. While loading mutiple values of the same element into a single DB column, the mutiple values are delimited by MULTIPLE_VAL_DELIM. When an element and its attribute are loaded into a single DB column, the value and the attribute are separated by a DB_ATTRIB_DELIM. When using delimiters to append values, if the values already have the delimiter, the delimiter in the value is escaped as in URLs. Values for the ' ' block are loaded with each parm name and parm value delimited with the NAME_VAL_DELIM.

Author:

David Hustace , OpenNMS.org Changes: - Alarm persisting added (many moons ago) - Alarm persisting now removes oldest events by default. Use "auto-clean" attribute in eventconf files.

See Also:

EventDatabaseConstants.MULTIPLE_VAL_DELIM, EventDatabaseConstants.DB_ATTRIB_DELIM, EventDatabaseConstants.NAME_VAL_DELIM, EventDatabaseConstants.MULTIPLE_VAL_DELIM, EventDatabaseConstants.DB_ATTRIB_DELIM, EventDatabaseConstants.NAME_VAL_DELIM, EventDatabaseConstants.MULTIPLE_VAL_DELIM, EventDatabaseConstants.DB_ATTRIB_DELIM, EventDatabaseConstants.NAME_VAL_DELIM

Field Summary

Fields inherited from interface org.opennms.netmgt.eventd.processor.EventWriter

EVENT_ACKUSER_FIELD_SIZE, EVENT_AUTOACTION_FIELD_SIZE, EVENT_CORRELATION_FIELD_SIZE, EVENT_DPNAME_FIELD_SIZE, EVENT_FORWARD_FIELD_SIZE, EVENT_HOST_FIELD_SIZE, EVENT_INTERFACE_FIELD_SIZE, EVENT_LOGGRP_FIELD_SIZE, EVENT_MOUSEOVERTEXT_FIELD_SIZE, EVENT_OPERACTION_FIELD_SIZE, EVENT_OPERACTION_MENU_FIELD_SIZE, EVENT_PATHOUTAGE_FIELD_SIZE, EVENT_SNMP_FIELD_SIZE, EVENT_SNMPHOST_FIELD_SIZE, EVENT_SOURCE_FIELD_SIZE, EVENT_TTICKET_FIELD_SIZE, EVENT_UEI_FIELD_SIZE, EVENT_X733_ALARMTYPE_SIZE, MSG_NO, MSG_YES

Constructor Summary

Constructors

Constructor and Description
AbstractJdbcPersister() Constructor for AbstractJdbcPersister.

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet() afterPropertiesSet
protected static boolean	checkEventSanityAndDoWeProcess(Event event, String logPrefix) checkEventSanityAndDoWeProcess
DataSource	getDataSource() getDataSource
EventdServiceManager	getEventdServiceManager() getEventdServiceManager
protected static Timestamp	getEventTime(Event event) getEventTime
EventUtil	getEventUtil()
String	getGetNextIdString() getGetNextIdString
protected int	getNextId() getNextId
protected int	getServiceID(String name) This method is used to convert the service name into a service id.
protected static void	set(PreparedStatement stmt, int ndx, char value) Sets the statement up for a character value.
protected static void	set(PreparedStatement stmt, int ndx, int value) Sets the statement up for an integer type.
protected static void	set(PreparedStatement stmt, int ndx, String value) Sets the statement up for a String value.
protected static void	set(PreparedStatement stmt, int ndx, Timestamp value) Sets the statement up for a timestamp type.
void	setDataSource(DataSource dataSource) setDataSource
void	setEventdServiceManager(EventdServiceManager eventdServiceManager) setEventdServiceManager
void	setEventUtil(EventUtil eventUtil)
void	setGetNextIdString(String getNextIdString) setGetNextIdString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opennms.netmgt.events.api.EventProcessor

process

Constructor Detail

AbstractJdbcPersister

public AbstractJdbcPersister()

Constructor for AbstractJdbcPersister.

Method Detail

set

protected static void set(PreparedStatement stmt,
                          int ndx,
                          String value)
                   throws SQLException

Sets the statement up for a String value.

Parameters:

stmt - The statement to add the value to.

ndx - The ndx for the value.

value - The value to add to the statement.

Throws:

SQLException - Thrown if there is an error adding the value to the statement.

SQLException - if any.

set

protected static void set(PreparedStatement stmt,
                          int ndx,
                          int value)
                   throws SQLException

Sets the statement up for an integer type. If the integer type is less than zero, then it is set to null!

Parameters:

stmt - The statement to add the value to.

ndx - The ndx for the value.

value - The value to add to the statement.

Throws:

SQLException - Thrown if there is an error adding the value to the statement.

SQLException - if any.

set

protected static void set(PreparedStatement stmt,
                          int ndx,
                          Timestamp value)
                   throws SQLException

Sets the statement up for a timestamp type.

Parameters:

stmt - The statement to add the value to.

ndx - The ndx for the value.

value - The value to add to the statement.

Throws:

SQLException - Thrown if there is an error adding the value to the statement.

SQLException - if any.

set

protected static void set(PreparedStatement stmt,
                          int ndx,
                          char value)
                   throws SQLException

Sets the statement up for a character value.

Parameters:

stmt - The statement to add the value to.

ndx - The ndx for the value.

value - The value to add to the statement.

Throws:

SQLException - Thrown if there is an error adding the value to the statement.

SQLException - if any.

getServiceID

protected int getServiceID(String name)
                    throws SQLException

This method is used to convert the service name into a service id. It first looks up the information from a service map of Eventd and if no match is found, by performing a lookup in the database. If the conversion is successful then the corresponding integer identifier will be returned to the caller.

Parameters:

name - The name of the service

Returns:

The integer identifier for the service name.

Throws:

SQLException - Thrown if there is an error accessing the stored data or the SQL text is malformed. This will also be thrown if the result cannot be obtained.

SQLException - if any.

See Also:

EventdConstants.SQL_DB_SVCNAME_TO_SVCID

getEventTime

protected static Timestamp getEventTime(Event event)

getEventTime

Parameters:

event - a Event object.

Returns:

a Timestamp object.

getNextId

protected int getNextId()
                 throws SQLException

getNextId

Returns:

a int.

Throws:

SQLException - if any.

afterPropertiesSet

public void afterPropertiesSet()
                        throws SQLException

afterPropertiesSet

Specified by:

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

Throws:

SQLException - if any.

getEventdServiceManager

public EventdServiceManager getEventdServiceManager()

getEventdServiceManager

Returns:

a EventdServiceManager object.

setEventdServiceManager

public void setEventdServiceManager(EventdServiceManager eventdServiceManager)

setEventdServiceManager

Parameters:

eventdServiceManager - a EventdServiceManager object.

getDataSource

public DataSource getDataSource()

getDataSource

Returns:

a DataSource object.

setDataSource

public void setDataSource(DataSource dataSource)

setDataSource

Parameters:

dataSource - a DataSource object.

getEventUtil

public EventUtil getEventUtil()

setEventUtil

public void setEventUtil(EventUtil eventUtil)

getGetNextIdString

public String getGetNextIdString()

getGetNextIdString

Returns:

a String object.

setGetNextIdString

public void setGetNextIdString(String getNextIdString)

setGetNextIdString

Parameters:

getNextIdString - a String object.

checkEventSanityAndDoWeProcess

protected static boolean checkEventSanityAndDoWeProcess(Event event,
                                                        String logPrefix)

checkEventSanityAndDoWeProcess

Parameters:

event - a Event object.

logPrefix - a String object.

Returns:

a boolean.