emps.v4_rekord

src/emps/v4_rekord/Employee.java

+package emps.v4_rekord;
+
+import java.time.LocalDate;
+
+public record Employee(int employeeId, String firstName, String lastName, String jobTitle, int salary, LocalDate hireDate,
+		String departmentName, String address, String postalCode, String city, String country) {
+    // Rekord to jest "taka klasa", dla której automatycznie tworzone są:
+    // - deklaracje podanych pól, które wszystkie są "private final"
+    // - konstruktor z wszystkimi parametrami
+    // - gettery do wszystkich pól, ale uwaga, nazwą metody jest po prostu "salary()", a nie "getSalary()"
+    // - toString, equals i hashCode w sposób standardowy dla klas typu "value object"
+
+    // Do rekordu można dodawać własne metody. Rekord może implementować interfejsy.
+    public String danePracownika() {
+        return String.format("%s %s (%s) zarabia %d", firstName, lastName, jobTitle, salary);
+    }
+
+    public static int dodaj(int x, int y) {
+    	return x + y;
+    }
+}

src/emps/v4_rekord/Grupowanie2.java

+package emps.v4_rekord;
+
+import java.util.List;
+import java.util.Map;
+import java.util.TreeMap;
+
+public class Grupowanie2 {
+	
+	public static void main(String[] args) {
+		List<Employee> emps = ObslugaCSV.wczytaj("emps.csv");
+		
+		Map<String, Integer> sumy = new TreeMap<>();
+		Map<String, Integer> ilosci = new TreeMap<>();
+
+		for(Employee emp : emps) {
+			int suma = sumy.getOrDefault(emp.jobTitle(), 0);
+			sumy.put(emp.jobTitle(), suma + emp.salary());
+			int ile = ilosci.getOrDefault(emp.jobTitle(), 0);
+			ilosci.put(emp.jobTitle(), ile+1);
+		}
+
+		for(String job : sumy.keySet()) {
+			int suma = sumy.get(job);
+			int ile = ilosci.get(job);
+			double srednia = (double)suma / ile;
+			System.out.printf("| %-32s | %2d | %8.2f |%n", job, ile, srednia);
+		}
+	}
+
+}

src/emps/v4_rekord/Grupowanie8.java

+package emps.v4_rekord;
+
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+public class Grupowanie8 {
+
+	public static void main(String[] args) {
+		List<Employee> emps = ObslugaCSV.wczytaj("emps.csv");
+		
+		Map<String, Double> grupy = emps.stream()
+				.collect(Collectors.groupingBy(
+						Employee::jobTitle,
+						Collectors.averagingInt(Employee::salary)));
+		
+		grupy.forEach((job, srednia) -> {
+			System.out.printf("%-32s → %8.2f%n", job, srednia);
+		});
+	}
+
+}

src/emps/v4_rekord/Grupowanie9.java

+package emps.v4_rekord;
+
+import java.util.IntSummaryStatistics;
+import java.util.Map;
+import java.util.TreeMap;
+import java.util.stream.Collectors;
+
+public class Grupowanie9 {
+
+	public static void main(String[] args) {
+		Map<String, IntSummaryStatistics> grupy = ObslugaCSV.wczytajStrumieniowo("emps.csv")
+				.collect(Collectors.groupingBy(
+						Employee::jobTitle,
+						TreeMap::new,
+						Collectors.summarizingInt(Employee::salary)));
+		
+		grupy.forEach((job, stats) -> {
+			System.out.printf("| %-32s | %2d | %5d | %8.2f | %5d |%n",
+	                job, stats.getCount(), stats.getMin(), stats.getAverage(), stats.getMax());
+		});
+	}
+
+}

src/emps/v4_rekord/ObslugaCSV.java

+package emps.v4_rekord;
+
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Scanner;
+import java.util.stream.Stream;
+
+public class ObslugaCSV {
+	public static List<Employee> wczytaj() {
+		// używa domyślnego pliku
+		return wczytaj("emps.csv");
+	}
+	
+	public static List<Employee> wczytaj(String sciezka) {
+		return wczytaj(new File(sciezka));
+	}
+	
+	public static List<Employee> wczytaj(File plik) {
+		List<Employee> emps = new ArrayList<>();
+		try(Scanner scanner = new Scanner(plik)) {
+			scanner.nextLine(); // pomijamy pierwszą linię
+			while(scanner.hasNextLine()) {
+				String linia = scanner.nextLine();
+				Employee emp = parsujLinie(linia);
+				emps.add(emp);
+			}
+		} catch (FileNotFoundException e) {
+			e.printStackTrace();
+			// w razie błędu (brak pliku) wypiszemy czerwone teksty na ekran, ale nie przerwiemy programu, tylko zwrócimy pustą listę
+		}
+		return emps;
+	}
+
+	public static Stream<Employee> wczytajStrumieniowo(Path plik) {
+		try {
+			return Files.lines(plik)
+					.skip(1)
+					.map(ObslugaCSV::parsujLinie);
+		} catch (IOException e) {
+			e.printStackTrace();
+			return Stream.empty();
+		}
+	}
+	
+	public static Stream<Employee> wczytajStrumieniowo(File plik) {
+		return wczytajStrumieniowo(plik.toPath());
+	}
+
+	public static Stream<Employee> wczytajStrumieniowo(String sciezka) {
+		return wczytajStrumieniowo(Path.of(sciezka));
+	}
+
+	public static Stream<Employee> wczytajStrumieniowo() {
+		return wczytajStrumieniowo("emps.csv");
+	}
+
+	public static void zapisz(List<Employee> lista, File plik) {
+		try(PrintWriter out = new PrintWriter(plik)) {
+			out.println(
+					"employee_id;first_name;last_name;job_title;salary;hire_date;department_name;address;postal_code;city;country");
+			for (Employee emp : lista) {
+				out.printf("%d;%s;%s;%s;%d;%s;%s;%s;%s;%s;%s\n", emp.employeeId(), emp.firstName(),
+						emp.lastName(), emp.jobTitle(), emp.salary(), emp.hireDate(),
+						emp.departmentName(), emp.address(), emp.postalCode(), emp.city(),
+						emp.country());
+			}
+		} catch (FileNotFoundException e) {
+			e.printStackTrace();
+		}
+	}
+
+	public static void zapisz(List<Employee> lista, String sciezka) {
+		zapisz(lista, new File(sciezka));
+	}
+
+	public static void zapisz(List<Employee> lista) {
+		zapisz(lista, "emps.csv");
+	}
+	
+	private static Employee parsujLinie(String linia) {
+		String[] t = linia.split(";", -1);
+		Employee emp = new Employee(Integer.parseInt(t[0]), t[1], t[2], t[3],
+				Integer.parseInt(t[4]), LocalDate.parse(t[5]),
+				t[6], t[7], t[8], t[9], t[10]);
+		return emp;
+	}
+
+}

src/emps/v4_rekord/P1_WypiszDane.java

+package emps.v4_rekord;
+
+import java.util.List;
+
+// Program dla każdego pracownika wypisuje tekst postaci
+// Steven King (President) zarabia 24000
+public class P1_WypiszDane {
+
+	public static void main(String[] args) {
+		List<Employee> emps = ObslugaCSV.wczytaj("emps.csv");
+		for(Employee emp : emps) {
+			// System.out.println(emp.getFirstName() + " " + emp.getLastName());
+			System.out.printf("Pracownik %s %s (%s) zarabia %s%n",
+					emp.firstName(), emp.lastName(), emp.jobTitle(), emp.salary());
+		}
+	}
+
+}
+
+// TODO napisać programy P2 P3 P4 działające tak, jak w wersji nieobiektowej,
+// ale w oparciu o listę obiektów Emeployee

src/emps/v4_rekord/P4_SredniaJedenJob_v3.java

+package emps.v4_rekord;
+
+import java.io.File;
+import java.util.List;
+import java.util.Set;
+import java.util.TreeSet;
+
+import javax.swing.JFileChooser;
+import javax.swing.JOptionPane;
+import javax.swing.filechooser.FileNameExtensionFilter;
+
+public class P4_SredniaJedenJob_v3 {
+
+	public static void main(String[] args) {
+		JFileChooser chooser = new JFileChooser(".");
+		chooser.setFileFilter(new FileNameExtensionFilter("Pliki CSV", "csv", "txt"));
+		int coSieStalo = chooser.showOpenDialog(null);
+		if(coSieStalo != JFileChooser.APPROVE_OPTION)
+			return;
+		
+		File plik = chooser.getSelectedFile();
+		List<Employee> emps = ObslugaCSV.wczytaj(plik);
+		
+		Set<String> jobs = new TreeSet<>();
+		for(Employee emp : emps) {
+			jobs.add(emp.jobTitle());
+		}
+		
+		String szukanyJob = (String)JOptionPane.showInputDialog(null, "Wybierz stanowisko", "Wybór",
+				JOptionPane.QUESTION_MESSAGE, null, jobs.toArray(), "Programmer");
+		if(szukanyJob == null)
+			return;
+		
+		double suma = 0;
+		int ile = 0;
+		for(Employee emp : emps) {
+			if(szukanyJob.equals(emp.jobTitle())) {
+				suma += emp.salary();
+				ile++;
+			}
+		}
+
+		if(ile > 0) {
+			double srednia = suma / ile;
+			JOptionPane.showMessageDialog(null, String.format(
+					"Na stanowisku %s pracuje %d osób.\nŚrednia pensja wynosi %.2f",
+					szukanyJob, ile, srednia));
+		} else {
+			JOptionPane.showMessageDialog(null, String.format("Nikt nie pracuje na stanowisku %s.", szukanyJob),
+					"Brak danych", JOptionPane.WARNING_MESSAGE);
+		}
+	}
+}

src/emps/v4_rekord/S2_Filtrowanie.java

+package emps.v4_rekord;
+
+public class S2_Filtrowanie {
+
+	public static void main(String[] args) {
+		ObslugaCSV.wczytajStrumieniowo("emps.csv")
+			.filter(emp -> emp.salary() >= 10_000)
+			.map(emp -> emp.firstName() + " " + emp.lastName() + " " + emp.salary())
+			.map(String::toUpperCase) // ew.  .map(s -> s.toUpperCase())
+			.forEach(System.out::println);
+	}
+
+}