def ExecuteQuery(self, query, args=None):
    """Get connection from pool and execute query."""

    def Action(connection):
      connection.cursor.execute(query, args)
      rowcount = connection.cursor.rowcount
      results = connection.cursor.fetchall()
      return results, rowcount

    return self._RetryWrapper(Action)
Get connection from pool and execute query.