com.serotonin.mango.db.dao

Class EventDao

java.lang.Object

com.serotonin.db.DaoUtils

com.serotonin.mango.db.dao.BaseDao

com.serotonin.mango.db.dao.EventDao

public class EventDao
extends BaseDao

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	EventDao.EventHandlerRowMapper
static class	EventDao.EventInstanceRowMapper
(package private) static class	EventDao.PendingEventCacheEntry
(package private) class	EventDao.UserEventInstanceRowMapper
(package private) class	EventDao.UserPendingEventRetriever

Field Summary

Fields

Modifier and Type	Field and Description
private static java.lang.String	BASIC_EVENT_SELECT
private static long	CACHE_TTL
private static java.lang.String	EVENT_ACK
private static java.lang.String	EVENT_COMMENT_SELECT
private static java.lang.String	EVENT_HANDLER_SELECT
private static java.lang.String	EVENT_INSERT
private static int[]	EVENT_INSERT_TYPES
private static java.lang.String	EVENT_SELECT_WITH_USER_DATA
private static java.lang.String	EVENT_UPDATE
private static int	MAX_PENDING_EVENTS
private static java.util.Map<java.lang.Integer,EventDao.PendingEventCacheEntry>	pendingEventCache
private int	searchRowCount
private static java.lang.String	SILENCED_SELECT
private int	startRow
private static java.lang.String	USER_EVENT_ACK
private static java.lang.String	USER_EVENTS_INSERT

Fields inherited from class com.serotonin.db.DaoUtils

dataSource, ejt, tm

Constructor Summary

Constructors

Constructor and Description
EventDao()

Method Summary

Modifier and Type	Method and Description
void	ackEvent(int eventId, long time, int userId, int alternateAckSource)
static void	addToCache(int userId, java.util.List<EventInstance> list)
(package private) void	attachRelationalInfo(EventInstance event)
private void	attachRelationalInfo(java.util.List<EventInstance> list)
static void	clearCache()
(package private) static EventType	createEventType(java.sql.ResultSet rs, int offset)
void	deleteEventHandler(int handlerId)
java.lang.String	generateUniqueXid()
java.util.List<EventInstance>	getActiveEvents()
int	getEventCount()
EventHandlerVO	getEventHandler(int eventHandlerId)
EventHandlerVO	getEventHandler(java.lang.String xid)
java.util.List<EventHandlerVO>	getEventHandlers()
java.util.List<EventHandlerVO>	getEventHandlers(EventType type)
java.util.List<EventHandlerVO>	getEventHandlers(EventTypeVO type)
private java.util.List<EventHandlerVO>	getEventHandlers(int typeId, int ref1, int ref2) Note: eventHandlers.eventTypeRef2 matches on both the given ref2 and 0.
EventType	getEventHandlerType(int handlerId)
private EventInstance	getEventInstance(int eventId)
java.util.List<EventInstance>	getEventsForDataPoint(int dataPointId, int userId)
static java.util.List<EventInstance>	getFromCache(int userId)
int	getHighestUnsilencedAlarmLevel(int userId)
java.util.List<EventInstance>	getPendingEvents(int userId)
(package private) java.util.List<EventInstance>	getPendingEvents(int typeId, int typeRef1, int userId)
java.util.List<EventInstance>	getPendingEventsForDataPoint(int dataPointId, int userId)
java.util.List<EventInstance>	getPendingEventsForDataSource(int dataSourceId, int userId)
java.util.List<EventInstance>	getPendingEventsForPublisher(int publisherId, int userId)
int	getSearchRowCount()
int	getStartRow()
private void	insertEvent(EventInstance event)
EventInstance	insertEventComment(int eventId, UserComment comment)
(package private) void	insertEventHandler(int typeId, int typeRef1, int typeRef2, EventHandlerVO handler)
void	insertUserEvents(int eventId, java.util.List<java.lang.Integer> userIds, boolean alarm)
boolean	isXidUnique(java.lang.String xid, int excludeId)
int	purgeEventsBefore(long time)
void	removeUserFromHandlers(int id)
static void	removeUserIdFromCache(int userId)
void	saveEvent(EventInstance event)
EventHandlerVO	saveEventHandler(EventType type, EventHandlerVO handler)
EventHandlerVO	saveEventHandler(EventTypeVO type, EventHandlerVO handler)
private EventHandlerVO	saveEventHandler(int typeId, int typeRef1, int typeRef2, EventHandlerVO handler)
java.util.List<EventInstance>	search(int eventId, int[] eventSourceType, java.lang.String[] status, int[] alarmLevel, java.lang.String[] keywords, long dateFrom, long dateTo, int userId, java.util.ResourceBundle bundle, int from, int to, java.util.Date date)
java.util.List<EventInstance>	search(int eventId, int eventSourceType, java.lang.String status, int alarmLevel, java.lang.String[] keywords, int userId, java.util.ResourceBundle bundle, int from, int to, java.util.Date date)
java.util.List<EventInstance>	search(int eventId, int eventSourceType, java.lang.String status, int alarmLevel, java.lang.String[] keywords, long dateFrom, long dateTo, int userId, java.util.ResourceBundle bundle, int from, int to, java.util.Date date)
java.util.List<EventInstance>	searchOld(int eventId, int eventSourceType, java.lang.String status, int alarmLevel, java.lang.String[] keywords, int maxResults, int userId, java.util.ResourceBundle bundle)
boolean	toggleSilence(int eventId, int userId)
static void	updateCache(EventInstance event)
private void	updateEvent(EventInstance event)
(package private) void	updateEventHandler(EventHandlerVO handler)

Methods inherited from class com.serotonin.mango.db.dao.BaseDao

boolToChar, charToBool, deleteInChunks, doInsert, doInsert, doInsert, doInsertLong, doInsertLong, doInsertLong, generateUniqueXid, getGeneratedKeyName, getPreparedStatementCreator, isXidUnique

Methods inherited from class com.serotonin.db.DaoUtils

batchUpdate, createDelimitedList, createDelimitedList, createDelimitedList, createIntValuePairs, createKeyValuePairs, dbEncodeSearchString, getInt, getTransactionManager, getTransactionTemplate, now, query, query, query, query, query, query, queryForList, queryForList, queryForObject, queryForObject, queryForObject, setInt

Methods inherited from class java.lang.Object

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

Field Detail

MAX_PENDING_EVENTS

private static final int MAX_PENDING_EVENTS

See Also:

Constant Field Values

EVENT_INSERT

private static final java.lang.String EVENT_INSERT

See Also:

Constant Field Values

EVENT_INSERT_TYPES

private static final int[] EVENT_INSERT_TYPES

EVENT_UPDATE

private static final java.lang.String EVENT_UPDATE

See Also:

Constant Field Values

EVENT_ACK

private static final java.lang.String EVENT_ACK

See Also:

Constant Field Values

USER_EVENT_ACK

private static final java.lang.String USER_EVENT_ACK

See Also:

Constant Field Values

USER_EVENTS_INSERT

private static final java.lang.String USER_EVENTS_INSERT

See Also:

Constant Field Values

BASIC_EVENT_SELECT

private static final java.lang.String BASIC_EVENT_SELECT

See Also:

Constant Field Values

EVENT_SELECT_WITH_USER_DATA

private static final java.lang.String EVENT_SELECT_WITH_USER_DATA

See Also:

Constant Field Values

EVENT_COMMENT_SELECT

private static final java.lang.String EVENT_COMMENT_SELECT

See Also:

Constant Field Values

searchRowCount

private int searchRowCount

startRow

private int startRow

EVENT_HANDLER_SELECT

private static final java.lang.String EVENT_HANDLER_SELECT

See Also:

Constant Field Values

SILENCED_SELECT

private static final java.lang.String SILENCED_SELECT

See Also:

Constant Field Values

pendingEventCache

private static java.util.Map<java.lang.Integer,EventDao.PendingEventCacheEntry> pendingEventCache

CACHE_TTL

private static final long CACHE_TTL

See Also:

Constant Field Values

Constructor Detail

EventDao

public EventDao()

Method Detail

saveEvent

public void saveEvent(EventInstance event)

insertEvent

private void insertEvent(EventInstance event)

updateEvent

private void updateEvent(EventInstance event)

ackEvent

public void ackEvent(int eventId,
                     long time,
                     int userId,
                     int alternateAckSource)

insertUserEvents

public void insertUserEvents(int eventId,
                             java.util.List<java.lang.Integer> userIds,
                             boolean alarm)

getActiveEvents

public java.util.List<EventInstance> getActiveEvents()

getEventsForDataPoint

public java.util.List<EventInstance> getEventsForDataPoint(int dataPointId,
                                                           int userId)

getPendingEventsForDataPoint

public java.util.List<EventInstance> getPendingEventsForDataPoint(int dataPointId,
                                                                  int userId)

getPendingEventsForDataSource

public java.util.List<EventInstance> getPendingEventsForDataSource(int dataSourceId,
                                                                   int userId)

getPendingEventsForPublisher

public java.util.List<EventInstance> getPendingEventsForPublisher(int publisherId,
                                                                  int userId)

getPendingEvents

java.util.List<EventInstance> getPendingEvents(int typeId,
                                               int typeRef1,
                                               int userId)

getPendingEvents

public java.util.List<EventInstance> getPendingEvents(int userId)

getEventInstance

private EventInstance getEventInstance(int eventId)

createEventType

static EventType createEventType(java.sql.ResultSet rs,
                                 int offset)
                          throws java.sql.SQLException

Throws:

java.sql.SQLException

attachRelationalInfo

private void attachRelationalInfo(java.util.List<EventInstance> list)

attachRelationalInfo

void attachRelationalInfo(EventInstance event)

insertEventComment

public EventInstance insertEventComment(int eventId,
                                        UserComment comment)

purgeEventsBefore

public int purgeEventsBefore(long time)

getEventCount

public int getEventCount()

searchOld

public java.util.List<EventInstance> searchOld(int eventId,
                                               int eventSourceType,
                                               java.lang.String status,
                                               int alarmLevel,
                                               java.lang.String[] keywords,
                                               int maxResults,
                                               int userId,
                                               java.util.ResourceBundle bundle)

search

public java.util.List<EventInstance> search(int eventId,
                                            int eventSourceType,
                                            java.lang.String status,
                                            int alarmLevel,
                                            java.lang.String[] keywords,
                                            int userId,
                                            java.util.ResourceBundle bundle,
                                            int from,
                                            int to,
                                            java.util.Date date)

search

public java.util.List<EventInstance> search(int eventId,
                                            int eventSourceType,
                                            java.lang.String status,
                                            int alarmLevel,
                                            java.lang.String[] keywords,
                                            long dateFrom,
                                            long dateTo,
                                            int userId,
                                            java.util.ResourceBundle bundle,
                                            int from,
                                            int to,
                                            java.util.Date date)

search

public java.util.List<EventInstance> search(int eventId,
                                            int[] eventSourceType,
                                            java.lang.String[] status,
                                            int[] alarmLevel,
                                            java.lang.String[] keywords,
                                            long dateFrom,
                                            long dateTo,
                                            int userId,
                                            java.util.ResourceBundle bundle,
                                            int from,
                                            int to,
                                            java.util.Date date)

getSearchRowCount

public int getSearchRowCount()

getStartRow

public int getStartRow()

generateUniqueXid

public java.lang.String generateUniqueXid()

isXidUnique

public boolean isXidUnique(java.lang.String xid,
                           int excludeId)

getEventHandlerType

public EventType getEventHandlerType(int handlerId)

getEventHandlers

public java.util.List<EventHandlerVO> getEventHandlers(EventType type)

getEventHandlers

public java.util.List<EventHandlerVO> getEventHandlers(EventTypeVO type)

getEventHandlers

public java.util.List<EventHandlerVO> getEventHandlers()

getEventHandlers

private java.util.List<EventHandlerVO> getEventHandlers(int typeId,
                                                        int ref1,
                                                        int ref2)

Note: eventHandlers.eventTypeRef2 matches on both the given ref2 and 0. This is to allow a single set of event handlers to be defined for user login events, rather than have to individually define them for each user.

getEventHandler

public EventHandlerVO getEventHandler(int eventHandlerId)

getEventHandler

public EventHandlerVO getEventHandler(java.lang.String xid)

saveEventHandler

public EventHandlerVO saveEventHandler(EventType type,
                                       EventHandlerVO handler)

saveEventHandler

public EventHandlerVO saveEventHandler(EventTypeVO type,
                                       EventHandlerVO handler)

saveEventHandler

private EventHandlerVO saveEventHandler(int typeId,
                                        int typeRef1,
                                        int typeRef2,
                                        EventHandlerVO handler)

insertEventHandler

void insertEventHandler(int typeId,
                        int typeRef1,
                        int typeRef2,
                        EventHandlerVO handler)

updateEventHandler

void updateEventHandler(EventHandlerVO handler)

deleteEventHandler

public void deleteEventHandler(int handlerId)

toggleSilence

public boolean toggleSilence(int eventId,
                             int userId)

getHighestUnsilencedAlarmLevel

public int getHighestUnsilencedAlarmLevel(int userId)

getFromCache

public static java.util.List<EventInstance> getFromCache(int userId)

addToCache

public static void addToCache(int userId,
                              java.util.List<EventInstance> list)

updateCache

public static void updateCache(EventInstance event)

removeUserIdFromCache

public static void removeUserIdFromCache(int userId)

clearCache

public static void clearCache()

removeUserFromHandlers

public void removeUserFromHandlers(int id)