class_docstr: This handler handles connection and execution of the Couchbase statements.
docstr: Execute a raw query against Couchbase.
  
  Args:
      query (str): Raw Couchbase query.
  
  Returns:
      HandlerResponse containing query results.
docstr_tok: ["Execute","a","raw","query","against","Couchbase",".","Args",":","query","(","str",")",":","Raw","Couchbase","query",".","Returns",":","HandlerResponse","containing","query","results","."]
code: def native_query(self, query: str) -> Response:
      """Execute a raw query against Couchbase.
  
      Args:
          query (str): Raw Couchbase query.
  
      Returns:
          HandlerResponse containing query results.
      """
      self.connect()
      bucket = self.cluster.bucket(self.bucket_name)
      cb = bucket.scope(self.scope)
  
      data = {}
      try:
          for collection in cb.query(query):
              for collection_name, row in collection.items():
                  if isinstance(row, dict):
                      for k, v in row.items():
                          data.setdefault(k, []).append(v)
                  else:
                      for k, v in collection.items():
                          data.setdefault(k, []).append(v)
  
          response = Response(
              RESPONSE_TYPE.TABLE,
              pd.DataFrame(data) if data else RESPONSE_TYPE.OK,
          )
      except CouchbaseException as e:
          response = Response(
              RESPONSE_TYPE.ERROR,
              error_message=str(e.error_context.first_error_message),
          )
  
      return response
  
imports: from datetime import timedelta
  from collections import OrderedDict
  from mindsdb.integrations.libs.base import DatabaseHandler
  from mindsdb.utilities import log
  from mindsdb_sql.parser.ast.base import ASTNode
  import pandas
  from mindsdb.integrations.libs.const import HANDLER_CONNECTION_ARG_TYPE
  from mindsdb.integrations.libs.response import HandlerStatusResponse, HandlerResponse, RESPONSE_TYPE
  from couchbase.auth import PasswordAuthenticator
  from couchbase.cluster import Cluster
  from couchbase.exceptions import UnAmbiguousTimeoutException
  from couchbase.options import ClusterOptions
  from couchbase.exceptions import KeyspaceNotFoundException, CouchbaseException
label_desc: Use image node_id 5 for calling the CouchbaseHandler obj's underlying member method code with example usage: obj.native_query(query) and returns: response