com.xxdb.streaming.client.streamingSQL

Class StreamingSQLClient

java.lang.Object

com.xxdb.streaming.client.AbstractClient

com.xxdb.streaming.client.streamingSQL.StreamingSQLClient

public class StreamingSQLClient
extends AbstractClient

Nested Class Summary

Nested classes/interfaces inherited from class com.xxdb.streaming.client.AbstractClient

AbstractClient.HAStreamTableInfo

Field Summary

Fields inherited from class com.xxdb.streaming.client.AbstractClient

connList, currentSiteIndexMap, DEFAULT_ACTION_NAME, DEFAULT_HOST, DEFAULT_PORT, haStreamTableInfo, HATopicToTrueTopic, hostEndian, ifUseBackupSite, isClose_, lastBackupSiteTopic, lastExceptionTopicTimeMap, lastQueue, lastSuccessSubscribeTopic, listeningHost, listeningPort, messageCache, pThread, queueManager, reconnectTable, resubscribeInterval, subInfos_, subOnce, tableNameToTrueTopic, trueTopicToSites, users, waitReconnectTopic

Constructor Summary

Constructors

Constructor and Description
StreamingSQLClient(String host, int port, String userName, String password)

Method Summary

Modifier and Type	Method and Description
void	declareStreamingSQLTable(String tableName)
protected boolean	doReconnect(Site site)
BasicTable	getStreamingSQLStatus()
BasicTable	getStreamingSQLStatus(String queryId)
BasicTable	listStreamingSQLTables()
String	registerStreamingSQL(String sqlQuery)
String	registerStreamingSQL(String sqlQuery, int logTableCacheSize)
String	registerStreamingSQL(String sqlQuery, String queryId)
String	registerStreamingSQL(String sqlQuery, String queryId, int logTableCacheSize)
void	revokeStreamingSQL(String queryId)
void	revokeStreamingSQLTable(String tableName)
BasicTable	subscribeStreamingSQL(String queryId)
BasicTable	subscribeStreamingSQL(String queryId, int batchSize, float throttle)
void	unsubscribeStreamingSQL(String queryId)

Methods inherited from class com.xxdb.streaming.client.AbstractClient

activeCloseConnection, batchDispatch, close, dispatch, getAllReconnectSites, getAllReconnectTopic, getAllTopicsBySite, getCurrentSiteByName, getNeedReconnect, getNewLeader, getReconnectTimestamp, getSiteByName, getSubInfos, getTopicToSites, isClose, isClosed, isRemoteLittleEndian, setMsgId, setNeedReconnect, setReconnectTimestamp, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeStreamingSqlLogInfoInternal, tryReconnect, unsubscribeInternal, unsubscribeInternal

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamingSQLClient

public StreamingSQLClient(String host,
                          int port,
                          String userName,
                          String password)
                   throws IOException

Throws:

IOException

Method Detail

declareStreamingSQLTable

public void declareStreamingSQLTable(String tableName)

revokeStreamingSQLTable

public void revokeStreamingSQLTable(String tableName)

listStreamingSQLTables

public BasicTable listStreamingSQLTables()

registerStreamingSQL

public String registerStreamingSQL(String sqlQuery)

registerStreamingSQL

public String registerStreamingSQL(String sqlQuery,
                                   String queryId)

registerStreamingSQL

public String registerStreamingSQL(String sqlQuery,
                                   int logTableCacheSize)

registerStreamingSQL

public String registerStreamingSQL(String sqlQuery,
                                   String queryId,
                                   int logTableCacheSize)

revokeStreamingSQL

public void revokeStreamingSQL(String queryId)

getStreamingSQLStatus

public BasicTable getStreamingSQLStatus()

getStreamingSQLStatus

public BasicTable getStreamingSQLStatus(String queryId)

subscribeStreamingSQL

public BasicTable subscribeStreamingSQL(String queryId)
                                 throws IOException

Throws:

IOException

subscribeStreamingSQL

public BasicTable subscribeStreamingSQL(String queryId,
                                        int batchSize,
                                        float throttle)
                                 throws IOException

Throws:

IOException

unsubscribeStreamingSQL

public void unsubscribeStreamingSQL(String queryId)
                             throws IOException

Throws:

IOException

doReconnect

protected boolean doReconnect(Site site)

Specified by:

doReconnect in class AbstractClient