co.cask.coopr.store.cluster

Class SQLSystemClusterStoreView

java.lang.Object

co.cask.coopr.store.cluster.BaseSQLClusterStoreView

co.cask.coopr.store.cluster.SQLSystemClusterStoreView

All Implemented Interfaces:

ClusterStoreView, ReadOnlyClusterStoreView

public class SQLSystemClusterStoreView
extends BaseSQLClusterStoreView

The cluster store as viewed by the system. The system can do anything to any object.

Constructor Summary

Constructors

Constructor and Description
SQLSystemClusterStoreView(DBConnectionPool dbConnectionPool, DBQueryExecutor dbQueryExecutor)

Method Summary

Methods

Modifier and Type	Method and Description
protected PreparedStatement	getClusterExistsStatement(Connection conn, long id)
protected PreparedStatement	getDeleteClusterStatement(Connection conn, long id)
protected PreparedStatement	getSelectAllClustersStatement(Connection conn)
protected PreparedStatement	getSelectClusterJobsStatement(Connection conn, long id)
protected PreparedStatement	getSelectClusterNodesStatement(Connection conn, long id)
protected PreparedStatement	getSelectClusterStatement(Connection conn, long id)
protected PreparedStatement	getSelectNonTerminatedClusters(Connection conn)
protected PreparedStatement	getSetClusterStatement(Connection conn, long id, Cluster cluster, byte[] clusterBytes)

Methods inherited from class co.cask.coopr.store.cluster.BaseSQLClusterStoreView

clusterExists, deleteCluster, getAllClusters, getAllClusterSummaries, getAllClusterSummaries, getCluster, getClusterJobs, getClusterNodes, getNonTerminatedClusters, setInClause, writeCluster

Methods inherited from class java.lang.Object

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

Constructor Detail

SQLSystemClusterStoreView

public SQLSystemClusterStoreView(DBConnectionPool dbConnectionPool,
                         DBQueryExecutor dbQueryExecutor)

Method Detail

getSelectAllClustersStatement

protected PreparedStatement getSelectAllClustersStatement(Connection conn)
                                                   throws SQLException

Throws:

SQLException

getSelectNonTerminatedClusters

protected PreparedStatement getSelectNonTerminatedClusters(Connection conn)
                                                    throws SQLException

Throws:

SQLException

getSelectClusterStatement

protected PreparedStatement getSelectClusterStatement(Connection conn,
                                          long id)
                                               throws SQLException

Throws:

SQLException

getSetClusterStatement

protected PreparedStatement getSetClusterStatement(Connection conn,
                                       long id,
                                       Cluster cluster,
                                       byte[] clusterBytes)
                                            throws SQLException

Throws:

SQLException

getClusterExistsStatement

protected PreparedStatement getClusterExistsStatement(Connection conn,
                                          long id)
                                               throws SQLException

Throws:

SQLException

getDeleteClusterStatement

protected PreparedStatement getDeleteClusterStatement(Connection conn,
                                          long id)
                                               throws SQLException

Throws:

SQLException

getSelectClusterJobsStatement

protected PreparedStatement getSelectClusterJobsStatement(Connection conn,
                                              long id)
                                                   throws SQLException

Throws:

SQLException

getSelectClusterNodesStatement

protected PreparedStatement getSelectClusterNodesStatement(Connection conn,
                                               long id)
                                                    throws SQLException

Throws:

SQLException