jrds.probe.jdbc

Class JdbcProbe

java.lang.Object

jrds.starter.StarterNode

jrds.Probe<String,Number>

jrds.probe.jdbc.JdbcProbe

All Implemented Interfaces:

Comparable<Probe<String,Number>>, IndexedProbe, UrlProbe, StartersSet

Direct Known Subclasses:

Mysql, Sybase

public abstract class JdbcProbe
extends Probe<String,Number>
implements UrlProbe, IndexedProbe

Field Summary

Fields

Modifier and Type	Field and Description
protected JdbcStarter	starter

Constructor Summary

Constructors

Constructor and Description
JdbcProbe()
JdbcProbe(ProbeDesc pd)

Method Summary

Methods

Modifier and Type	Method and Description
void	configure()
void	configure(int port, String user, String passwd)
void	configure(int port, String user, String passwd, String dbName)
String	getDbName()
String	getIndexName()
String	getName()
Map<String,Number>	getNewSampleValues() The method that return a map of data collected. It should return return as raw as possible, they can even be opaque data tied to the probe.
String	getPassword()
Integer	getPort()
abstract List<String>	getQueries()
String	getSourceType()
long	getUptime() This function should return the uptime of the probe If it's not overriden or fixed with setUptime, it will return Long.MAX_VALUE that's make it useless, as it used to make the probe pause after a restart of the probe.
URL	getUrl()
String	getUrlAsString()
String	getUser()
boolean	isCollectRunning()
abstract Map<String,Number>	parseRs(ResultSet rs)
protected List<Map<String,Object>>	parseRsHorizontaly(ResultSet rs, boolean numFilter)
protected List<Map<String,Object>>	parseRsVerticaly(ResultSet rs, boolean numFilter)
Map<String,Number>	select2Map(String query) Parse all the collumns of a query and return a List of Map where the column name is the key
Map<String,Object>	select2Map(String query, String keyCol, String valCol)
void	setDbName(String dbName)
void	setPassword(String password)
void	setPort(Integer port)
void	setUser(String user)

Methods inherited from class jrds.Probe

addGraph, addGraph, checkStore, checkStoreFile, collect, compareTo, create, dsExist, dumpAsXml, dumpAsXml, fetchData, fetchData, fetchData, filterValues, getCollectMapping, getDsDefs, getGraphList, getHost, getLabel, getLastUpdate, getLastValues, getNamedLogger, getPd, getQualifiedName, getRrdDef, getRrdName, getTags, hashCode, log, log, modifySample, readProperties, readSpecific, setHost, setLabel, setName, setPd, setUptime, toString

Methods inherited from class jrds.starter.StarterNode

configureStarters, find, find, find, find, find, getHostList, getLevel, getParent, getStarters, getStep, getTimeout, isStarted, registerStarter, registerStarter, setParent, setParent, setStep, setTimeout, startCollect, stopCollect

Methods inherited from class java.lang.Object

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

Field Detail

starter

protected final JdbcStarter starter

Constructor Detail

JdbcProbe

public JdbcProbe()

JdbcProbe

public JdbcProbe(ProbeDesc pd)

Method Detail

configure

public void configure()

configure

public void configure(int port,
             String user,
             String passwd)

configure

public void configure(int port,
             String user,
             String passwd,
             String dbName)

getName

public String getName()

Overrides:

getName in class Probe<String,Number>

getNewSampleValues

public Map<String,Number> getNewSampleValues()

Description copied from class: Probe

The method that return a map of data collected.
It should return return as raw as possible, they can even be opaque data tied to the probe. the key is resolved using the ProbeDesc. A key not associated with an existent datastore will generate a warning but will not prevent the other values to be stored.
the value should be a java.lang.Number


Specified by:

getNewSampleValues in class Probe<String,Number>

Returns:

the map of collected object

getQueries

public abstract List<String> getQueries()

parseRsVerticaly

protected List<Map<String,Object>> parseRsVerticaly(ResultSet rs,
                                        boolean numFilter)
                                             throws SQLException

Throws:

SQLException

parseRsHorizontaly

protected List<Map<String,Object>> parseRsHorizontaly(ResultSet rs,
                                          boolean numFilter)
                                               throws SQLException

Throws:

SQLException

parseRs

public abstract Map<String,Number> parseRs(ResultSet rs)
                                    throws SQLException

Throws:

SQLException

select2Map

public Map<String,Number> select2Map(String query)

Parse all the collumns of a query and return a List of Map where the column name is the key

Parameters:

query -

numFilter - force all value to be a Number

Returns:

a List of Map of values

select2Map

public Map<String,Object> select2Map(String query,
                            String keyCol,
                            String valCol)

getPort

public Integer getPort()

Specified by:

getPort in interface UrlProbe

Returns:

Returns the port.

setPort

public void setPort(Integer port)

Parameters:

port - The port to set.

getUser

public String getUser()

Returns:

Returns the user.

setUser

public void setUser(String user)

Parameters:

user - The user to set.

getPassword

public String getPassword()

Returns:

Returns the user.

setPassword

public void setPassword(String password)

Parameters:

password - The user to set.

getDbName

public String getDbName()

Returns:

Returns the dbName.

setDbName

public void setDbName(String dbName)

Parameters:

dbName -

getUrlAsString

public String getUrlAsString()

Specified by:

getUrlAsString in interface UrlProbe

isCollectRunning

public boolean isCollectRunning()

Overrides:

isCollectRunning in class StarterNode

getSourceType

public String getSourceType()

Specified by:

getSourceType in class Probe<String,Number>

getUptime

public long getUptime()

Description copied from class: Probe

This function should return the uptime of the probe If it's not overriden or fixed with setUptime, it will return Long.MAX_VALUE that's make it useless, as it used to make the probe pause after a restart of the probe. It's called after filterValues

Overrides:

getUptime in class Probe<String,Number>

Returns:

the uptime in second

getIndexName

public String getIndexName()

Specified by:

getIndexName in interface IndexedProbe

getUrl

public URL getUrl()

Specified by:

getUrl in interface UrlProbe