summaryrefslogtreecommitdiff
path: root/src/Csv/mod.rs
blob: 29e1acaf645fba8b37a5ac15605d3c687e86918f (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
use std::fs::File;
use std::io;
use std::io::BufRead;

/**
  Represents a CSV file 
  **/

pub struct CsvFile {
	path : String,
	delim : String,
	pub header : Vec<String>,
	pub content : Vec<Vec<String>>,
	has_header : bool
}

impl CsvFile {
	pub fn new(path: &str, delim: &str, header: bool) -> CsvFile {
		CsvFile {
			path : String::from(path),
			delim: String::from(delim),
			header : Vec::new(),
			content : Vec::new(),
			has_header : header 
		}

	}

	// TODO nicht gleich viele spalten
	fn parse_line(line : String, delim: &str) -> Vec<String> {
		let mut columns : Vec<String> = Vec::new();
		for column in line.split(delim).collect::<Vec<&str>>() {
			columns.push(column.to_string());	
		}
		columns
	}


	pub fn read_file(path: &str, delim: &str, header: bool) -> Result<CsvFile, io::Error> {
		let fd = File::open(path)?;
		let reader = io::BufReader::new(fd);
		let mut column_names : Vec<String> = Vec::new();
		let mut lines : Vec<Vec<String>> = Vec::new();
		let mut first = true;
		
		for line in reader.lines() {
			let line = line?;
			if header && first {
				column_names.append(&mut CsvFile::parse_line(line, delim));
				first = false;
			} else {
				lines.push(CsvFile::parse_line(line, delim));
			}
		}
		
		Ok(CsvFile { path: String::from(path),
			     delim : String::from(delim),
			     header : column_names,
			     content : lines,
			     has_header: header } )
	}
}