Package io.datarouter.client.mysql

Class MysqlClientManager

java.lang.Object
io.datarouter.storage.client.BaseClientManager
io.datarouter.client.mysql.MysqlClientManager
All Implemented Interfaces:
MysqlConnectionClientManager, TxnClientManager, io.datarouter.storage.client.ClientManager, io.datarouter.storage.client.type.ConnectionClientManager
@Singleton
public class MysqlClientManager
extends io.datarouter.storage.client.BaseClientManager
implements MysqlConnectionClientManager, TxnClientManager

  • Constructor Summary

    Constructors 
    Constructor Description
    MysqlClientManager()  

  • Method Summary

    Modifier and Type Method Description
    void beginTxn​(io.datarouter.storage.client.ClientId clientId, Isolation isolation, boolean autoCommit)  
    void commitTxn​(io.datarouter.storage.client.ClientId clientId)  
    protected java.util.concurrent.Future<java.util.Optional<io.datarouter.storage.config.schema.SchemaUpdateResult>> doSchemaUpdate​(io.datarouter.storage.node.type.physical.PhysicalNode<?,​?,​?> node)  
    void gatherSchemaUpdates()  
    java.sql.Connection getExistingConnection​(io.datarouter.storage.client.ClientId clientId)  
    io.datarouter.storage.client.ConnectionHandle getExistingHandle​(io.datarouter.storage.client.ClientId clientId)  
    java.lang.String getStats​(io.datarouter.storage.client.ClientId clientId)  
    void releaseConnection​(io.datarouter.storage.client.ClientId clientId)  
    void reserveConnection​(io.datarouter.storage.client.ClientId clientId)  
    void rollbackTxn​(io.datarouter.storage.client.ClientId clientId)  
    protected void safeInitClient​(io.datarouter.storage.client.ClientId clientId)  
    void shutdown​(io.datarouter.storage.client.ClientId clientId)  

    Methods inherited from class io.datarouter.storage.client.BaseClientManager

    doSchemaUpdate, initClient, monitorLatency

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.datarouter.storage.client.ClientManager

    doSchemaUpdate, initClient, monitorLatency

  • Constructor Details

  • Method Details

    • safeInitClient

      protected void safeInitClient​(io.datarouter.storage.client.ClientId clientId)
      Specified by:
      safeInitClient in class io.datarouter.storage.client.BaseClientManager

    • doSchemaUpdate

      protected java.util.concurrent.Future<java.util.Optional<io.datarouter.storage.config.schema.SchemaUpdateResult>> doSchemaUpdate​(io.datarouter.storage.node.type.physical.PhysicalNode<?,​?,​?> node)
      Overrides:
      doSchemaUpdate in class io.datarouter.storage.client.BaseClientManager

    • gatherSchemaUpdates

      public void gatherSchemaUpdates()
      Specified by:
      gatherSchemaUpdates in interface io.datarouter.storage.client.ClientManager
      Overrides:
      gatherSchemaUpdates in class io.datarouter.storage.client.BaseClientManager

    • getExistingHandle

      public io.datarouter.storage.client.ConnectionHandle getExistingHandle​(io.datarouter.storage.client.ClientId clientId)
      Specified by:
      getExistingHandle in interface io.datarouter.storage.client.type.ConnectionClientManager

    • reserveConnection

      public void reserveConnection​(io.datarouter.storage.client.ClientId clientId)
      Specified by:
      reserveConnection in interface io.datarouter.storage.client.type.ConnectionClientManager

    • releaseConnection

      public void releaseConnection​(io.datarouter.storage.client.ClientId clientId)
      Specified by:
      releaseConnection in interface io.datarouter.storage.client.type.ConnectionClientManager

    • getExistingConnection

      public java.sql.Connection getExistingConnection​(io.datarouter.storage.client.ClientId clientId)
      Specified by:
      getExistingConnection in interface MysqlConnectionClientManager

    • beginTxn

      public void beginTxn​(io.datarouter.storage.client.ClientId clientId, Isolation isolation, boolean autoCommit)
      Specified by:
      beginTxn in interface TxnClientManager

    • commitTxn

      public void commitTxn​(io.datarouter.storage.client.ClientId clientId)
      Specified by:
      commitTxn in interface TxnClientManager

    • rollbackTxn

      public void rollbackTxn​(io.datarouter.storage.client.ClientId clientId)
      Specified by:
      rollbackTxn in interface TxnClientManager

    • shutdown

      public void shutdown​(io.datarouter.storage.client.ClientId clientId)
      Specified by:
      shutdown in interface io.datarouter.storage.client.ClientManager

    • getStats

      public java.lang.String getStats​(io.datarouter.storage.client.ClientId clientId)