org.apache.ambari.eventdb.db

Class MySQLConnector

java.lang.Object

org.apache.ambari.eventdb.db.PostgresConnector

org.apache.ambari.eventdb.db.MySQLConnector

All Implemented Interfaces:

DBConnector

public class MySQLConnector
extends PostgresConnector

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ambari.eventdb.db.PostgresConnector

PostgresConnector.Statements

Field Summary

Fields inherited from class org.apache.ambari.eventdb.db.PostgresConnector

db, DEFAULT_LIMIT, SORT_ASC, SORT_DESC

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected PreparedStatement	getQualifiedPS(PostgresConnector.Statements statement, String searchClause, Workflows.WorkflowDBEntry.WorkflowFields field, boolean sortAscending, int offset, int limit)

Methods inherited from class org.apache.ambari.eventdb.db.PostgresConnector

close, fetchJobDetails, fetchJobDetails, fetchJobStartStopTimes, fetchJobTaskAttempts, fetchTaskAttempts, fetchWorkflows, fetchWorkflows, fetchWorkflows, fetchWorkflowTaskAttempts, finalize, getQualifiedPS, submitJob, updateJob

Methods inherited from class java.lang.Object

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

Constructor Detail

MySQLConnector

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

Throws:

IOException

Method Detail

getQualifiedPS

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

Overrides:

getQualifiedPS in class PostgresConnector

Throws:

IOException