1 use std::{env, error::Error, io, process};
2
run() -> Result<(), Box<dyn Error>>3 fn run() -> Result<(), Box<dyn Error>> {
4 let query = match env::args().nth(1) {
5 None => return Err(From::from("expected 1 argument, but got none")),
6 Some(query) => query,
7 };
8
9 let mut rdr = csv::Reader::from_reader(io::stdin());
10 let mut wtr = csv::Writer::from_writer(io::stdout());
11
12 wtr.write_record(rdr.byte_headers()?)?;
13
14 for result in rdr.byte_records() {
15 let record = result?;
16 // `query` is a `String` while `field` is now a `&[u8]`, so we'll
17 // need to convert `query` to `&[u8]` before doing a comparison.
18 if record.iter().any(|field| field == query.as_bytes()) {
19 wtr.write_record(&record)?;
20 }
21 }
22
23 wtr.flush()?;
24 Ok(())
25 }
26
main()27 fn main() {
28 if let Err(err) = run() {
29 println!("{}", err);
30 process::exit(1);
31 }
32 }
33