class Multiwoven::Integrations::Source::WatsonxData::Client

def execute_query(connection_config, query)
  connection_config.with_indifferent_access
  get_access_token(connection_config[:api_key])
  url = format(
    WATSONX_DATA_QUERIES_URL,
    region: connection_config[:region],
    engine_id: connection_config[:engine_id]
  )
  headers = auth_headers(@access_token)
  headers["AuthInstanceId"] = connection_config[:auth_instance_id]
  send_request(
    url: url,
    http_method: HTTP_POST,
    payload: {
      sql_string: query,
      catalog_name: connection_config[:database],
      schema_name: connection_config[:schema]
    },
    headers: headers,
    config: connection_config[:config]
  )
end