com.exalead.cloudview.alerting

Class AlertingDatabaseService

java.lang.Object

com.exalead.cloudview.alerting.AlertingDatabaseService

public class AlertingDatabaseService
extends java.lang.Object

Interaction with the alerting database. At the moment, all interactions are synchronized due to SQLite constraints. TODO: Should be smarter and wait if db is locked.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	INSERT_ALL_ALERT_FIELDS
static java.lang.String	SELECT_ALL_ALERT_FIELDS

Constructor Summary

Constructors

Constructor and Description
AlertingDatabaseService()
AlertingDatabaseService(java.lang.String connectionString)
AlertingDatabaseService(java.lang.String connectionString, java.lang.String connectionLogin, java.lang.String connectionPassword)

Method Summary

Modifier and Type	Method and Description
void	commit()
void	connect()
void	deleteAlert(java.lang.String key, java.lang.String user)
void	deleteAllAlerts()
void	disconnect()
void	editAlert(AlertDesc alert) Edits the alert based on its *key* (NOT id)
protected void	fetchGroupsInfo(java.util.List<AlertDesc> list)
protected void	fetchLastRunInfo(java.util.List<AlertDesc> list)
AlertDesc	getAlert(long id)
AlertDesc	getAlert(java.lang.String key)
java.util.List<AlertDesc>	getAllGlobalAlerts(java.lang.String group)
java.util.List<AlertDesc>	getAllGroupAlerts(java.lang.String group)
java.util.Map<java.lang.String,java.util.List<AlertDesc>>	getAllGroupAlertsPerUser(java.lang.String group)
java.util.List<AlertDesc>	getAllGroupGlobalAlerts(java.lang.String group)
java.util.List<AlertDesc>	getAllUserAlerts(java.lang.String user, java.lang.String group) group = null : all groups
protected com.exalead.cloudview.alerting.AlertingDatabaseService.DB	getDBTypeFromConnectionString(java.lang.String connectionString)
long	getGroupAlertsCount(java.lang.String group)
void	newAlert(AlertDesc alert) Fills the id on the alert
protected java.util.List<AlertDesc>	resultSetToAlertDescList(java.sql.ResultSet rs)
protected java.util.List<AlertDesc>	resultSetToAlertDescListWithLastInfoAndGroups(java.sql.ResultSet rs)
void	rollback()
long	storeAlertOccurence(ScheduledAlertOccurrence occur, java.lang.String format, byte[] data)
long	storeRTAlertOccurence(RTAlertOccurrence occur, java.lang.String format, java.lang.String data)

Methods inherited from class java.lang.Object

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

Field Detail

SELECT_ALL_ALERT_FIELDS

public static java.lang.String SELECT_ALL_ALERT_FIELDS

INSERT_ALL_ALERT_FIELDS

public static java.lang.String INSERT_ALL_ALERT_FIELDS

Constructor Detail

AlertingDatabaseService

public AlertingDatabaseService()

AlertingDatabaseService

public AlertingDatabaseService(java.lang.String connectionString)

AlertingDatabaseService

public AlertingDatabaseService(java.lang.String connectionString,
                               java.lang.String connectionLogin,
                               java.lang.String connectionPassword)

Method Detail

getDBTypeFromConnectionString

protected com.exalead.cloudview.alerting.AlertingDatabaseService.DB getDBTypeFromConnectionString(java.lang.String connectionString)

connect

public void connect()
             throws java.sql.SQLException

Throws:

java.sql.SQLException

disconnect

public void disconnect()
                throws java.sql.SQLException

Throws:

java.sql.SQLException

commit

public void commit()
            throws java.sql.SQLException

Throws:

java.sql.SQLException

rollback

public void rollback()
              throws java.sql.SQLException

Throws:

java.sql.SQLException

getAllGroupAlerts

public java.util.List<AlertDesc> getAllGroupAlerts(java.lang.String group)
                                            throws java.sql.SQLException

Throws:

java.sql.SQLException

getGroupAlertsCount

public long getGroupAlertsCount(java.lang.String group)
                         throws java.sql.SQLException

Throws:

java.sql.SQLException

getAllUserAlerts

public java.util.List<AlertDesc> getAllUserAlerts(java.lang.String user,
                                                  java.lang.String group)
                                           throws java.sql.SQLException

group = null : all groups

Throws:

java.sql.SQLException

getAllGlobalAlerts

public java.util.List<AlertDesc> getAllGlobalAlerts(java.lang.String group)
                                             throws java.sql.SQLException

Throws:

java.sql.SQLException

getAllGroupAlertsPerUser

public java.util.Map<java.lang.String,java.util.List<AlertDesc>> getAllGroupAlertsPerUser(java.lang.String group)
                                                                                   throws java.lang.Exception

Throws:

java.lang.Exception

getAllGroupGlobalAlerts

public java.util.List<AlertDesc> getAllGroupGlobalAlerts(java.lang.String group)
                                                  throws java.lang.Exception

Throws:

java.lang.Exception

newAlert

public void newAlert(AlertDesc alert)
              throws java.sql.SQLException

Fills the id on the alert

Throws:

java.sql.SQLException

getAlert

public AlertDesc getAlert(java.lang.String key)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

getAlert

public AlertDesc getAlert(long id)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

editAlert

public void editAlert(AlertDesc alert)
               throws java.sql.SQLException

Edits the alert based on its *key* (NOT id)

Throws:

java.sql.SQLException

deleteAlert

public void deleteAlert(java.lang.String key,
                        java.lang.String user)
                 throws java.sql.SQLException

Throws:

java.sql.SQLException

deleteAllAlerts

public void deleteAllAlerts()
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

storeAlertOccurence

public long storeAlertOccurence(ScheduledAlertOccurrence occur,
                                java.lang.String format,
                                byte[] data)
                         throws java.sql.SQLException

Throws:

java.sql.SQLException

storeRTAlertOccurence

public long storeRTAlertOccurence(RTAlertOccurrence occur,
                                  java.lang.String format,
                                  java.lang.String data)
                           throws java.sql.SQLException

Throws:

java.sql.SQLException

resultSetToAlertDescListWithLastInfoAndGroups

protected java.util.List<AlertDesc> resultSetToAlertDescListWithLastInfoAndGroups(java.sql.ResultSet rs)
                                                                           throws java.sql.SQLException

Throws:

java.sql.SQLException

resultSetToAlertDescList

protected java.util.List<AlertDesc> resultSetToAlertDescList(java.sql.ResultSet rs)
                                                      throws java.sql.SQLException

Throws:

java.sql.SQLException

fetchGroupsInfo

protected void fetchGroupsInfo(java.util.List<AlertDesc> list)
                        throws java.sql.SQLException

Throws:

java.sql.SQLException

fetchLastRunInfo

protected void fetchLastRunInfo(java.util.List<AlertDesc> list)
                         throws java.sql.SQLException

Throws:

java.sql.SQLException