compbio.stat.collector

Class StatDB

java.lang.Object

compbio.stat.collector.StatDB

public class StatDB
extends java.lang.Object

The database must be stored in the application root directory and called "ExecutionStatistic"

Author:

pvtroshin

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static java.sql.Connection	conn
private static java.lang.String	driver
private static org.apache.log4j.Logger	log
private static java.lang.String	protocol
private static java.lang.String	statDBName

Constructor Summary

Constructors

Constructor and Description
StatDB()
StatDB(boolean ignored) Connect to test database

Method Summary

Modifier and Type	Method and Description
(package private) static void	clearStatTable()
private void	createStatTable() rs.getBoolean(i) will return true for any non-zero value and false for 0 on SMALLINT data column.
int	getAbandonedCount(java.sql.Timestamp from, java.sql.Timestamp to)
int	getCancelledCount(java.sql.Timestamp from, java.sql.Timestamp to)
private static java.sql.Connection	getDBConnection()
java.util.Date	getEarliestRecord()
int	getIncompleteCount(java.sql.Timestamp from, java.sql.Timestamp to)
private int	getIntResult(java.sql.Timestamp from, java.sql.Timestamp to, java.lang.String query)
private static java.sql.Connection	getTestDBConnection()
int	getTotalJobsCount(java.sql.Timestamp from, java.sql.Timestamp to)
(package private) void	insertData(java.util.Set<JobStat> jobstatus)
static void	main(java.lang.String[] args)
java.util.List<JobStat>	readData(java.sql.Timestamp from, java.sql.Timestamp to, Services wservice, java.lang.Boolean clusterOnly)
void	removeRecordedJobs(java.util.Set<JobStat> fsJobs) Removes the job if 1) It has already been recorded 2) It has not completed and did not timeout - this is to prevent recording the information on the incomplete jobs.
static void	shutdownDBServer()

Methods inherited from class java.lang.Object

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

Field Detail

driver

private static final java.lang.String driver

See Also:

Constant Field Values

protocol

private static final java.lang.String protocol

See Also:

Constant Field Values

statDBName

private static final java.lang.String statDBName

See Also:

Constant Field Values

log

private static final org.apache.log4j.Logger log

conn

static java.sql.Connection conn

Constructor Detail

StatDB

public StatDB()
       throws java.sql.SQLException

Throws:

java.sql.SQLException

StatDB

StatDB(boolean ignored)
throws java.sql.SQLException

Connect to test database

Parameters:

ignored -

Throws:

java.sql.SQLException

Method Detail

getDBConnection

private static java.sql.Connection getDBConnection()
                                            throws java.sql.SQLException

Throws:

java.sql.SQLException

getTestDBConnection

private static java.sql.Connection getTestDBConnection()
                                                throws java.sql.SQLException

Throws:

java.sql.SQLException

createStatTable

private void createStatTable()
                      throws java.sql.SQLException

rs.getBoolean(i) will return true for any non-zero value and false for 0 on SMALLINT data column.

Throws:

java.sql.SQLException

clearStatTable

static void clearStatTable()
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

insertData

void insertData(java.util.Set<JobStat> jobstatus)
         throws java.sql.SQLException

Throws:

java.sql.SQLException

getEarliestRecord

public java.util.Date getEarliestRecord()
                                 throws java.sql.SQLException

Throws:

java.sql.SQLException

getTotalJobsCount

public int getTotalJobsCount(java.sql.Timestamp from,
                             java.sql.Timestamp to)
                      throws java.sql.SQLException

Throws:

java.sql.SQLException

getCancelledCount

public int getCancelledCount(java.sql.Timestamp from,
                             java.sql.Timestamp to)
                      throws java.sql.SQLException

Throws:

java.sql.SQLException

getAbandonedCount

public int getAbandonedCount(java.sql.Timestamp from,
                             java.sql.Timestamp to)
                      throws java.sql.SQLException

Throws:

java.sql.SQLException

getIncompleteCount

public int getIncompleteCount(java.sql.Timestamp from,
                              java.sql.Timestamp to)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

getIntResult

private int getIntResult(java.sql.Timestamp from,
                         java.sql.Timestamp to,
                         java.lang.String query)
                  throws java.sql.SQLException

Throws:

java.sql.SQLException

readData

public java.util.List<JobStat> readData(java.sql.Timestamp from,
                                        java.sql.Timestamp to,
                                        Services wservice,
                                        java.lang.Boolean clusterOnly)
                                 throws java.sql.SQLException

Throws:

java.sql.SQLException

removeRecordedJobs

public void removeRecordedJobs(java.util.Set<JobStat> fsJobs)
                        throws java.sql.SQLException

Removes the job if 1) It has already been recorded 2) It has not completed and did not timeout - this is to prevent recording the information on the incomplete jobs.

Parameters:

fsJobs -

Throws:

java.sql.SQLException

shutdownDBServer

public static final void shutdownDBServer()

main

public static void main(java.lang.String[] args)