org.apache.ambari.eventdb.db

Class PostgresConnector

java.lang.Object

org.apache.ambari.eventdb.db.PostgresConnector

All Implemented Interfaces:

DBConnector

Direct Known Subclasses:

MySQLConnector, OracleConnector

public class PostgresConnector
extends Object
implements DBConnector

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PostgresConnector.Statements

Field Summary

Fields

Modifier and Type	Field and Description
protected Connection	db
protected static int	DEFAULT_LIMIT
static String	SORT_ASC
static String	SORT_DESC

Constructor Summary

Constructors

Constructor and Description
PostgresConnector(String connectionURL, String driverName, String username, String password)

Method Summary

Modifier and Type	Method and Description
void	close()
List<Jobs.JobDBEntry>	fetchJobDetails(long minFinishTime, long maxStartTime)
List<Jobs.JobDBEntry>	fetchJobDetails(String workflowId)
long[]	fetchJobStartStopTimes(String jobID)
List<TaskAttempt>	fetchJobTaskAttempts(String jobID)
List<TaskAttempt>	fetchTaskAttempts(long minFinishTime, long maxStartTime)
Workflows	fetchWorkflows()
DataTable	fetchWorkflows(int offset, int limit, String searchTerm, int echo, Workflows.WorkflowDBEntry.WorkflowFields col, boolean sortAscending, String searchWorkflowId, String searchWorkflowName, String searchWorkflowType, String searchUserName, int minJobs, int maxJobs, long minInputBytes, long maxInputBytes, long minOutputBytes, long maxOutputBytes, long minDuration, long maxDuration, long minStartTime, long maxStartTime, long minFinishTime, long maxFinishTime)
Workflows	fetchWorkflows(Workflows.WorkflowDBEntry.WorkflowFields field, boolean sortAscending, int offset, int limit)
List<TaskAttempt>	fetchWorkflowTaskAttempts(String workflowId)
protected void	finalize()
protected PreparedStatement	getQualifiedPS(PostgresConnector.Statements statement, String searchClause)
protected PreparedStatement	getQualifiedPS(PostgresConnector.Statements statement, String searchClause, Workflows.WorkflowDBEntry.WorkflowFields field, boolean sortAscending, int offset, int limit)
void	submitJob(Jobs.JobDBEntry j, WorkflowContext context)
void	updateJob(Jobs.JobDBEntry j)

Methods inherited from class java.lang.Object

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

Field Detail

SORT_ASC

public static final String SORT_ASC

See Also:

Constant Field Values

SORT_DESC

public static final String SORT_DESC

See Also:

Constant Field Values

DEFAULT_LIMIT

protected static final int DEFAULT_LIMIT

See Also:

Constant Field Values

db

protected Connection db

Constructor Detail

PostgresConnector

public PostgresConnector(String connectionURL,
                         String driverName,
                         String username,
                         String password)
                  throws IOException

Throws:

IOException

Method Detail

submitJob

public void submitJob(Jobs.JobDBEntry j,
                      WorkflowContext context)
               throws IOException

Specified by:

submitJob in interface DBConnector

Throws:

IOException

updateJob

public void updateJob(Jobs.JobDBEntry j)
               throws IOException

Specified by:

updateJob in interface DBConnector

Throws:

IOException

fetchWorkflows

public Workflows fetchWorkflows()
                         throws IOException

Specified by:

fetchWorkflows in interface DBConnector

Throws:

IOException

fetchWorkflows

public Workflows fetchWorkflows(Workflows.WorkflowDBEntry.WorkflowFields field,
                                boolean sortAscending,
                                int offset,
                                int limit)
                         throws IOException

Specified by:

fetchWorkflows in interface DBConnector

Throws:

IOException

fetchWorkflows

public DataTable fetchWorkflows(int offset,
                                int limit,
                                String searchTerm,
                                int echo,
                                Workflows.WorkflowDBEntry.WorkflowFields col,
                                boolean sortAscending,
                                String searchWorkflowId,
                                String searchWorkflowName,
                                String searchWorkflowType,
                                String searchUserName,
                                int minJobs,
                                int maxJobs,
                                long minInputBytes,
                                long maxInputBytes,
                                long minOutputBytes,
                                long maxOutputBytes,
                                long minDuration,
                                long maxDuration,
                                long minStartTime,
                                long maxStartTime,
                                long minFinishTime,
                                long maxFinishTime)
                         throws IOException

Specified by:

fetchWorkflows in interface DBConnector

Throws:

IOException

fetchJobDetails

public List<Jobs.JobDBEntry> fetchJobDetails(String workflowId)
                                      throws IOException

Specified by:

fetchJobDetails in interface DBConnector

Throws:

IOException

fetchJobDetails

public List<Jobs.JobDBEntry> fetchJobDetails(long minFinishTime,
                                             long maxStartTime)
                                      throws IOException

Specified by:

fetchJobDetails in interface DBConnector

Throws:

IOException

fetchJobStartStopTimes

public long[] fetchJobStartStopTimes(String jobID)
                              throws IOException

Specified by:

fetchJobStartStopTimes in interface DBConnector

Throws:

IOException

fetchTaskAttempts

public List<TaskAttempt> fetchTaskAttempts(long minFinishTime,
                                           long maxStartTime)
                                    throws IOException

Specified by:

fetchTaskAttempts in interface DBConnector

Throws:

IOException

fetchJobTaskAttempts

public List<TaskAttempt> fetchJobTaskAttempts(String jobID)
                                       throws IOException

Specified by:

fetchJobTaskAttempts in interface DBConnector

Throws:

IOException

fetchWorkflowTaskAttempts

public List<TaskAttempt> fetchWorkflowTaskAttempts(String workflowId)
                                            throws IOException

Specified by:

fetchWorkflowTaskAttempts in interface DBConnector

Throws:

IOException

getQualifiedPS

protected PreparedStatement getQualifiedPS(PostgresConnector.Statements statement,
                                           String searchClause)
                                    throws IOException

Throws:

IOException

getQualifiedPS

protected PreparedStatement getQualifiedPS(PostgresConnector.Statements statement,
                                           String searchClause,
                                           Workflows.WorkflowDBEntry.WorkflowFields field,
                                           boolean sortAscending,
                                           int offset,
                                           int limit)
                                    throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface DBConnector

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable