Package io.datarouter.client.mysql.util

Class MysqlTool

java.lang.Object
io.datarouter.client.mysql.util.MysqlTool
public class MysqlTool
extends java.lang.Object

  • Field Summary

    Fields 
    Modifier and Type Field Description
    static java.lang.String PRIMARY_KEY_INDEX_NAME  

  • Constructor Summary

    Constructors 
    Constructor Description
    MysqlTool()  

  • Method Summary

    Modifier and Type Method Description
    static void execute​(MysqlConnectionPoolHolder.MysqlConnectionPool connectionPool, java.lang.String sql)  
    static <F> F fieldSetFromMysqlResultSetUsingReflection​(MysqlFieldCodecFactory fieldCodecFactory, java.util.function.Supplier<F> supplier, java.util.List<io.datarouter.model.field.Field<?>> fields, java.sql.ResultSet rs)  
    static java.sql.Connection openConnection​(java.lang.String hostname, int port, java.lang.String user, java.lang.String password)  
    static java.sql.PreparedStatement prepareStatement​(java.sql.Connection connection, java.lang.String sql)  
    static <PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​ D extends io.datarouter.model.databean.Databean<PK,​ D>>
    java.util.List<D>    		 selectDatabeans​(MysqlFieldCodecFactory fieldCodecFactory, java.util.function.Supplier<D> databeanSupplier, java.util.List<io.datarouter.model.field.Field<?>> fields, java.sql.PreparedStatement ps)  
    static <PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​ D extends io.datarouter.model.databean.Databean<PK,​ D>,​ IK extends io.datarouter.model.key.primary.PrimaryKey<IK>,​ IE extends io.datarouter.model.index.IndexEntry<IK,​ IE,​ PK,​ D>,​ IF extends io.datarouter.model.serialize.fielder.DatabeanFielder<IK,​ IE>>
    java.util.List<IK>    		 selectIndexEntryKeys​(MysqlFieldCodecFactory fieldCodecFactory, io.datarouter.storage.serialize.fieldcache.IndexEntryFieldInfo<IK,​IE,​IF> fieldInfo, java.sql.PreparedStatement ps)  
    static <PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​ D extends io.datarouter.model.databean.Databean<PK,​ D>,​ F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​ D>>
    java.util.List<PK>    		 selectPrimaryKeys​(MysqlFieldCodecFactory fieldCodecFactory, io.datarouter.storage.serialize.fieldcache.DatabeanFieldInfo<PK,​D,​F> fieldInfo, java.sql.PreparedStatement ps)  
    static java.util.List<java.lang.String> showDatabases​(java.sql.Connection connection)  
    static java.util.List<java.lang.String> showTables​(java.sql.Connection connection, java.lang.String schemaName)  
    static int update​(java.sql.PreparedStatement statement)  

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

  • Method Details

    • openConnection

      public static java.sql.Connection openConnection​(java.lang.String hostname, int port, java.lang.String user, java.lang.String password)

    • showTables

      public static java.util.List<java.lang.String> showTables​(java.sql.Connection connection, java.lang.String schemaName)

    • showDatabases

      public static java.util.List<java.lang.String> showDatabases​(java.sql.Connection connection)

    • selectPrimaryKeys

      public static <PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​ D extends io.datarouter.model.databean.Databean<PK,​ D>,​ F extends io.datarouter.model.serialize.fielder.DatabeanFielder<PK,​ D>> java.util.List<PK> selectPrimaryKeys​(MysqlFieldCodecFactory fieldCodecFactory, io.datarouter.storage.serialize.fieldcache.DatabeanFieldInfo<PK,​D,​F> fieldInfo, java.sql.PreparedStatement ps)

    • selectDatabeans

      public static <PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​ D extends io.datarouter.model.databean.Databean<PK,​ D>> java.util.List<D> selectDatabeans​(MysqlFieldCodecFactory fieldCodecFactory, java.util.function.Supplier<D> databeanSupplier, java.util.List<io.datarouter.model.field.Field<?>> fields, java.sql.PreparedStatement ps)

    • selectIndexEntryKeys

      public static <PK extends io.datarouter.model.key.primary.PrimaryKey<PK>,​ D extends io.datarouter.model.databean.Databean<PK,​ D>,​ IK extends io.datarouter.model.key.primary.PrimaryKey<IK>,​ IE extends io.datarouter.model.index.IndexEntry<IK,​ IE,​ PK,​ D>,​ IF extends io.datarouter.model.serialize.fielder.DatabeanFielder<IK,​ IE>> java.util.List<IK> selectIndexEntryKeys​(MysqlFieldCodecFactory fieldCodecFactory, io.datarouter.storage.serialize.fieldcache.IndexEntryFieldInfo<IK,​IE,​IF> fieldInfo, java.sql.PreparedStatement ps)

    • update

      public static int update​(java.sql.PreparedStatement statement)

    • fieldSetFromMysqlResultSetUsingReflection

      public static <F> F fieldSetFromMysqlResultSetUsingReflection​(MysqlFieldCodecFactory fieldCodecFactory, java.util.function.Supplier<F> supplier, java.util.List<io.datarouter.model.field.Field<?>> fields, java.sql.ResultSet rs)

    • prepareStatement

      public static java.sql.PreparedStatement prepareStatement​(java.sql.Connection connection, java.lang.String sql)

    • execute

      public static void execute​(MysqlConnectionPoolHolder.MysqlConnectionPool connectionPool, java.lang.String sql)