org.qbroker.monitor

Class DBQuery

java.lang.Object

org.qbroker.monitor.Monitor

org.qbroker.monitor.DBQuery

All Implemented Interfaces:

MonitorAction, MonitorReport

public class DBQuery
extends Monitor

DBQuery queres a Database to see if it hangs or goes down

It queries the given DBDriver, URI and an SQL Query statement. It throws exceptions if the internal error occurs. Otherwise it returns an integer indicating the status of the db server.

Status Code Description
-2 NOTAVAILABLE not available
-1 CONNFAILED connection failed
0 QUERYOK query is successful
1 PROTOCOLERROR protocol error, probably wrong port
2 QUERYERROR SQL Query not compile
3 QUERYFAILED SQL Query failed
4 LOGINTIMEOUT login timeout, probably server is busy
5 LOGINREFUSED login refused, probably password is wrong

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
static int	CONNFAILED
static int	LOGINREFUSED
static int	LOGINTIMEOUT
static int	NOTAVAILABLE
static int	PROTOCOLERROR
static int	QUERYERROR
static int	QUERYFAILED
static int	QUERYOK

Fields inherited from class org.qbroker.monitor.Monitor

actionCount, actionGroup, aPatternGroup, cachedSkip, category, dependencyGroup, description, disabledWithReport, disableMode, exceptionCount, exceptionTolerance, FILE_SEPARATOR, formatText, keyList, maxPage, maxRetry, name, normalStep, pm, previousStatus, repeatPeriod, report, reportMode, reportName, resolution, serialNumber, site, skip, statsLogger, statusOffset, statusText, step, template, timeFormat, timeTemplate, tolerance, type, xPatternGroup

Fields inherited from interface org.qbroker.monitor.MonitorReport

DISABLED, EXCEPTION, NOSKIP, REPORT_CACHED, REPORT_CLUSTER, REPORT_FINAL, REPORT_FLOW, REPORT_LOCAL, REPORT_NODE, REPORT_NONE, REPORT_SHARED, SKIPPED

Constructor Summary

Constructors

Constructor and Description
DBQuery(java.util.Map props)

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.Object>	checkpoint() returns the checkpoint Map for the action
void	dbClose()
void	destroy() closes and releases all opened resources
protected void	finalize()
java.util.Map<java.lang.String,java.lang.Object>	generateReport(long currentTime) generates a report on a monitored entity and returns it as a Map.
Event	performAction(int status, long currentTime, java.util.Map<java.lang.String,java.lang.Object> latest) examines the report on the monitored entity and reacts to it as an action
void	restoreFromCheckpoint(java.util.Map<java.lang.String,java.lang.Object> chkpt) restores the state of the action from the checkpoint Map

Methods inherited from class org.qbroker.monitor.Monitor

getName, getReportKeys, getReportMode, getReportName, getSkippingStatus, initTimeTemplate, updateContent

Methods inherited from class java.lang.Object

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

Field Detail

NOTAVAILABLE

public static final int NOTAVAILABLE

See Also:

Constant Field Values

CONNFAILED

public static final int CONNFAILED

See Also:

Constant Field Values

QUERYOK

public static final int QUERYOK

See Also:

Constant Field Values

PROTOCOLERROR

public static final int PROTOCOLERROR

See Also:

Constant Field Values

QUERYERROR

public static final int QUERYERROR

See Also:

Constant Field Values

QUERYFAILED

public static final int QUERYFAILED

See Also:

Constant Field Values

LOGINTIMEOUT

public static final int LOGINTIMEOUT

See Also:

Constant Field Values

LOGINREFUSED

public static final int LOGINREFUSED

See Also:

Constant Field Values

Constructor Detail

DBQuery

public DBQuery(java.util.Map props)

Method Detail

generateReport

public java.util.Map<java.lang.String,java.lang.Object> generateReport(long currentTime)
                                                                throws java.io.IOException

Description copied from interface: MonitorReport

generates a report on a monitored entity and returns it as a Map. The report Map will be passed to the associated MonitorAction as an opaque object. The action object is supposed to know how to retrieve the information from the report Map.

Specified by:

generateReport in interface MonitorReport

Specified by:

generateReport in class Monitor

Throws:

java.io.IOException

performAction

public Event performAction(int status,
                           long currentTime,
                           java.util.Map<java.lang.String,java.lang.Object> latest)

Description copied from interface: MonitorAction

examines the report on the monitored entity and reacts to it as an action

Specified by:

performAction in interface MonitorAction

Specified by:

performAction in class Monitor

dbClose

public void dbClose()

checkpoint

public java.util.Map<java.lang.String,java.lang.Object> checkpoint()

Description copied from interface: MonitorAction

returns the checkpoint Map for the action

Specified by:

checkpoint in interface MonitorAction

Overrides:

checkpoint in class Monitor

restoreFromCheckpoint

public void restoreFromCheckpoint(java.util.Map<java.lang.String,java.lang.Object> chkpt)

Description copied from interface: MonitorAction

restores the state of the action from the checkpoint Map

Specified by:

restoreFromCheckpoint in interface MonitorAction

Overrides:

restoreFromCheckpoint in class Monitor

destroy

public void destroy()

Description copied from interface: MonitorReport

closes and releases all opened resources

Specified by:

destroy in interface MonitorReport

Overrides:

destroy in class Monitor

finalize

protected void finalize()

Overrides:

finalize in class Monitor