Class ComQuery

java.lang.Object
org.mariadb.jdbc.internal.com.send.ComQuery

public class ComQuery extends Object
  • Constructor Details

    • ComQuery

      public ComQuery()
  • Method Details

    • sendSubCmd

      public static void sendSubCmd(PacketOutputStream out, ClientPrepareResult clientPrepareResult, ParameterHolder[] parameters, int queryTimeout) throws IOException
      Client-side PrepareStatement.execute() packet send.
      Parameters:
      out - outputStream
      clientPrepareResult - clientPrepareResult
      parameters - parameter
      queryTimeout - query timeout
      Throws:
      IOException - if connection fail
    • sendRewriteCmd

      public static int sendRewriteCmd(PacketOutputStream pos, List<byte[]> queryParts, int currentIndex, int paramCount, List<ParameterHolder[]> parameterList, boolean rewriteValues) throws IOException
      Client side PreparedStatement.executeBatch values rewritten (concatenate value params according to max_allowed_packet)
      Parameters:
      pos - outputStream
      queryParts - query parts
      currentIndex - currentIndex
      paramCount - parameter pos
      parameterList - parameter list
      rewriteValues - is query rewritable by adding values
      Returns:
      current index
      Throws:
      IOException - if connection fail
    • sendBatchAggregateSemiColon

      public static int sendBatchAggregateSemiColon(PacketOutputStream writer, String firstQuery, List<String> queries, int currentIndex) throws IOException
      Statement.executeBatch() rewritten multiple (concatenate with ";") according to max_allowed_packet)
      Parameters:
      writer - outputstream
      firstQuery - first query
      queries - queries
      currentIndex - currentIndex
      Returns:
      current index
      Throws:
      IOException - if connection error occur
    • sendDirect

      public static void sendDirect(PacketOutputStream pos, byte[] sqlBytes) throws IOException
      Send directly to socket the sql data.
      Parameters:
      pos - output stream
      sqlBytes - the query in UTF-8 bytes
      Throws:
      IOException - if connection error occur
    • sendDirect

      public static void sendDirect(PacketOutputStream pos, byte[] sqlBytes, int queryTimeout) throws IOException
      Send directly to socket the sql data.
      Parameters:
      pos - output stream
      sqlBytes - the query in UTF-8 bytes
      queryTimeout - timeout using max_statement_time
      Throws:
      IOException - if connection error occur
    • sendMultiDirect

      public static void sendMultiDirect(PacketOutputStream pos, List<byte[]> sqlBytes) throws IOException
      Send directly to socket the sql data.
      Parameters:
      pos - output stream
      sqlBytes - the query in UTF-8 bytes
      Throws:
      IOException - if connection error occur
    • sendMultiDirect

      public static void sendMultiDirect(PacketOutputStream pos, List<byte[]> sqlBytes, int queryTimeout) throws IOException
      Send directly to socket the sql data.
      Parameters:
      pos - output stream
      sqlBytes - the query in UTF-8 bytes
      queryTimeout - timeout using max_statement_time
      Throws:
      IOException - if connection error occur