with connect_to_copied_db(copy_db_info) as copy_connection: # sqlalchemy connection
    with src_cnx.engine.raw_connection().cursor() as src_cursor, \
            copy_connection.connection.cursor() as copy_cursor:

        for table_name, query in filtered_table_queries:
            src_cursor.arraysize = table_batch_size(table_name)

            try:
                src_cursor.execute(query)
            except Exception as e:
                logger.exception(f'Cannot execute query {query}')
                raise e from None

            fulltable = f'{copy_db_info.schema}.{table_name}'
            previous_nb_rows = 0
            while batch := src_cursor.fetchmany():
                nb_rows = len(batch)
                if nb_rows != previous_nb_rows:
                    num_columns = len(batch[0])
                    previous_nb_rows = nb_rows

                    insert_query = 'insert all '
                    for irow in range(nb_rows):
                        placeholders = ', '.join([f":{irow*num_columns + i + 1}" for i in range(num_columns)])
                        insert_query += f' into {fulltable} values ({", ".join([placeholders])})\n'
                    insert_query += 'select * from dual'

                params = []
                for row in batch:
                    params.extend(list(row))

                try:
                    copy_cursor.execute(insert_query, params)
                except Exception as e:
                    logger.exception(f'Cannot insert into {table_name}')
                    raise e from None
            copy_connection.connection.commit()