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