class_docstr: Moves data from Oracle to Oracle.
  
  :param oracle_destination_conn_id: destination Oracle connection.
  :param destination_table: destination table to insert rows.
  :param oracle_source_conn_id: :ref:`Source Oracle connection <howto/connection:oracle>`.
  :param source_sql: SQL query to execute against the source Oracle
      database. (templated)
  :param source_sql_params: Parameters to use in sql query. (templated)
  :param rows_chunk: number of rows per chunk to commit.
code: def _execute(self, src_hook, dest_hook, context) -> None:
      with src_hook.get_conn() as src_conn:
          cursor = src_conn.cursor()
          self.log.info(
              "Querying data from source: %s",
              self.oracle_source_conn_id,
          )
          cursor.execute(self.source_sql, self.source_sql_params)
          target_fields = [field[0] for field in cursor.description]
  
          rows_total = 0
          for rows in iter(
              lambda: cursor.fetchmany(self.rows_chunk), []
          ):
              dest_hook.bulk_insert_rows(
                  self.destination_table,
                  rows,
                  target_fields=target_fields,
                  commit_every=self.rows_chunk,
              )
              rows_total += len(rows)
              self.log.info("Total inserted: %s rows", rows_total)
  
          self.log.info("Finished data transfer.")
          cursor.close()
  
file_path: airflow/airflow/providers/oracle/transfers/oracle_to_oracle.py
imports: from __future__ import annotations
  from typing import TYPE_CHECKING, Sequence
  from airflow.models import BaseOperator
  from airflow.providers.oracle.hooks.oracle import OracleHook
label_desc: Use image node_id 2 for calling the OracleToOracleOperator obj's underlying member method code with example usage: obj._execute(src_hook, dest_hook, context) without return types