code: public void cancelCurrentQuery() throws QueryException {
          Protocol copiedProtocol = new MySQLProtocol(host, port, database, username, password, info);
          queryWasCancelled = true;
          copiedProtocol.executeQuery(new DrizzleQuery("KILL QUERY " + serverThreadId));
          copiedProtocol.close();
      }
docs: cancels the current query - clones the current protocol and executes a query using the new connection
  <p/>
  thread safe
  
  @throws QueryException