hxcliff@fb2ca11
let sql = "LOAD DATA LOCAL INFILE 'tmp' INTO TABLE `test` FIELDS TERMINATED BY ',' ENCLOSED BY '\"' LINES TERMINATED BY '\r\n'";
let (sender, recv) = tokio::sync::mpsc::unbounded_channel();
let recv_task = tokio::spawn(async move {
pool.get_conn().await.unwrap().load_data(sql, recv).await.unwrap();
});
sender.send(Bytes::from("a,b\r\nc,d")).unwrap();
drop(sender);
recv_task.await?;