Function write_copy_stream 

pub async fn write_copy_stream(
    transaction: &Transaction<'_>,
    copy_query: &str,
    file: &mut File,
    relation_name: &str,
) -> Result<(), Error>