Package io.datarouter.client.mysql.ddl.execute

Class MysqlSchemaUpdateService

java.lang.Object
io.datarouter.storage.config.schema.BaseSchemaUpdateService
io.datarouter.client.mysql.ddl.execute.MysqlSchemaUpdateService
@Singleton
public class MysqlSchemaUpdateService
extends io.datarouter.storage.config.schema.BaseSchemaUpdateService

  • Constructor Summary

    Constructors 
    Constructor Description
    MysqlSchemaUpdateService​(io.datarouter.storage.config.DatarouterProperties datarouterProperties, io.datarouter.storage.config.DatarouterAdministratorEmailService adminEmailService, MysqlSingleTableSchemaUpdateService mysqlSingleTableSchemaUpdateService, io.datarouter.storage.config.executor.DatarouterStorageExecutors.DatarouterSchemaUpdateScheduler executor, io.datarouter.web.email.DatarouterHtmlEmailService htmlEmailService, MysqlConnectionPoolHolder mysqlConnectionPoolHolder, io.datarouter.web.config.DatarouterWebPaths datarouterWebPaths)  

  • Method Summary

    Modifier and Type Method Description
    protected java.util.List<java.lang.String> fetchExistingTables​(io.datarouter.storage.client.ClientId clientId)  
    protected java.util.concurrent.Callable<java.util.Optional<io.datarouter.storage.config.schema.SchemaUpdateResult>> makeSchemaUpdateCallable​(io.datarouter.storage.client.ClientId clientId, io.datarouter.util.lazy.Lazy<java.util.List<java.lang.String>> existingTableNames, io.datarouter.storage.node.type.physical.PhysicalNode<?,​?,​?> node)  
    protected void sendEmail​(java.lang.String fromEmail, java.lang.String toEmail, java.lang.String subject, java.lang.String body)  

    Methods inherited from class io.datarouter.storage.config.schema.BaseSchemaUpdateService

    gatherSchemaUpdates, queueNodeForSchemaUpdate

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • MysqlSchemaUpdateService

      @Inject public MysqlSchemaUpdateService​(io.datarouter.storage.config.DatarouterProperties datarouterProperties, io.datarouter.storage.config.DatarouterAdministratorEmailService adminEmailService, MysqlSingleTableSchemaUpdateService mysqlSingleTableSchemaUpdateService, io.datarouter.storage.config.executor.DatarouterStorageExecutors.DatarouterSchemaUpdateScheduler executor, io.datarouter.web.email.DatarouterHtmlEmailService htmlEmailService, MysqlConnectionPoolHolder mysqlConnectionPoolHolder, io.datarouter.web.config.DatarouterWebPaths datarouterWebPaths)

  • Method Details

    • makeSchemaUpdateCallable

      protected java.util.concurrent.Callable<java.util.Optional<io.datarouter.storage.config.schema.SchemaUpdateResult>> makeSchemaUpdateCallable​(io.datarouter.storage.client.ClientId clientId, io.datarouter.util.lazy.Lazy<java.util.List<java.lang.String>> existingTableNames, io.datarouter.storage.node.type.physical.PhysicalNode<?,​?,​?> node)
      Specified by:
      makeSchemaUpdateCallable in class io.datarouter.storage.config.schema.BaseSchemaUpdateService

    • sendEmail

      protected void sendEmail​(java.lang.String fromEmail, java.lang.String toEmail, java.lang.String subject, java.lang.String body)
      Specified by:
      sendEmail in class io.datarouter.storage.config.schema.BaseSchemaUpdateService

    • fetchExistingTables

      protected java.util.List<java.lang.String> fetchExistingTables​(io.datarouter.storage.client.ClientId clientId)
      Specified by:
      fetchExistingTables in class io.datarouter.storage.config.schema.BaseSchemaUpdateService