import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.sql.Connection;
import java.sql.PreparedStatement;

public class MultiThreadServer extends Thread {

    public static void main(String[] args) {

        System.out.println("Server");

        ServerSocket server;

        try {
            server = new ServerSocket(1111);

            while (true) {
                Socket client = server.accept();
                MultiThreadServer mt = new MultiThreadServer(client);
                mt.start();
            }

        } catch (Exception e) {
            System.out.println(e.getMessage());
        }

    }
    //------------------------------------------------------------------------------------------------------------------

    private Socket server;


    public MultiThreadServer(Socket socket) {
        setServer(socket);
    }


    //Setter
    public void setServer(Socket server) {
        this.server = server;
    }


    //run - Methode
    public void run() {
        boolean activeClient = false;

        try {
            BufferedReader reader = new BufferedReader(new InputStreamReader(server.getInputStream()));
            PrintWriter writer = new PrintWriter(new OutputStreamWriter(server.getOutputStream()));

            String input = reader.readLine();

            if (input.equals("helloServer")) {
                activeClient = true;
                writer.println("CONNECTED");
                writer.flush();

                System.out.println("Connected with Client");
            }

            input = reader.readLine();

            try (Connection conn = DatabaseConnection.getConnection();) {

                while (!input.equals("EXIT")) {

                    insertInDatabase(input, conn);

                    input = reader.readLine();
                }
            }

            System.out.println("EXIT");


        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }

    private void insertInDatabase(String data, Connection conn) {


        try  {

            String[] arr = data.split(";");
            PreparedStatement pStmt = conn.prepareStatement("INSERT INTO WORKERS VALUES (?,?,?,?)");
            pStmt.setInt(1, Integer.parseInt(arr[0]));
            pStmt.setString(2, arr[1]);
            pStmt.setString(3, arr[2]);
            pStmt.setString(4, arr[3]);

            pStmt.execute();

            System.out.println("new Data inserted");

            pStmt.addBatch();

        } catch (Exception e) {
            System.out.println(e.getMessage());
        }

    }


}


import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.ArrayList;
import java.util.concurrent.TimeUnit;

public class Client {

    public static void main(String[] args) {
        System.out.println("Client");

        Client one = new Client("127.0.0.1", 1111);
        one.start();

    }
    //------------------------------------------------------------------------------------------------------------------

    private String ip;
    private int port;

    public Client(String ip, int port) {
        setPort(port);
        setIp(ip);
    }

    //Setter
    public void setPort(int port) {
        this.port = port;
    }

    public void setIp(String ip) {
        this.ip = ip;
    }

    private void start() {
        try {
            Socket clientSocket = new Socket(ip, port);

            BufferedReader reader = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
            PrintWriter writer = new PrintWriter(new OutputStreamWriter(clientSocket.getOutputStream()));

            //Anmeldung
            writer.println("helloServer");
            writer.flush();


            //Anwort von Server
            if(reader.readLine().equals("CONNECTED")){
                System.out.println("\tconnected");
            }


            //Übertragungsprotokoll
            //ID;firstName;lastName;location
            DomParser one = new DomParser();
            ArrayList<String> list = one.readIn("C:\\Users\\Andreas\\Desktop\\employees.xml");

            for(int i = 0; i<list.size(); i++){
                writer.println(list.get(i));
                writer.flush();
                System.out.println("\t"+list.get(i));
                TimeUnit.SECONDS.sleep(1);
            }


            writer.println("EXIT");
            writer.flush();



        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }
}

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class DatabaseConnection {

    private static Connection con = null;

    static {
        String url = "jdbc:h2:~/test";
        String user = "sa";
        String pass = "";


        try {
            con = DriverManager.getConnection(url, user, pass);
        } catch (SQLException e) {
            e.printStackTrace();
        }

    }

    public static Connection getConnection() {
        return con;
    }

}

import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;

import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import java.io.File;
import java.util.ArrayList;

public class DomParser {


    public DomParser() {}


    public ArrayList<String> readIn(String path) {

        ArrayList<String> myList = new ArrayList<>();

        try {
            //Get Document Builder
            DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
            DocumentBuilder builder = factory.newDocumentBuilder();

            //Build Document
            Document document = builder.parse(new File(path));

            //Normalize the XML Structure; It's just too important !!
            document.getDocumentElement().normalize();

            //Get all employees
            NodeList nList = document.getElementsByTagName("employee");

            for (int i = 0; i < nList.getLength(); i++) {
                Node node = nList.item(i);
                if (node.getNodeType() == Node.ELEMENT_NODE) {
                    String temp = "";

                    Element eElemt = (Element) node;
                    temp+=eElemt.getAttribute("id")+";";
                    temp+=eElemt.getElementsByTagName("firstName").item(0).getTextContent()+";";
                    temp+=eElemt.getElementsByTagName("lastName").item(0).getTextContent()+";";
                    temp+=eElemt.getElementsByTagName("location").item(0).getTextContent();

                    myList.add(temp);

                }
            }

        } catch (Exception e) {
            System.out.println(e.getMessage());
        }


        return myList;

    }


}


///////////////////////////////////////////////////////////////
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static ServerSocket socket = null;

    public static void main(String[] args) {
        try {
            socket = new ServerSocket(5464);
            while(true){
                Socket client = socket.accept();
                ClientThread clientThread = new ClientThread(client);
                clientThread.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

import java.io.*;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client extends Thread {
    private String clientName;

    public Client(String name){
        this.clientName = name;
    }

    @Override
    public void run() {
        try {
            Socket socket = new Socket("127.0.0.1", 5464);
            OutputStream out = socket.getOutputStream();
            ObjectOutputStream objectOut = new ObjectOutputStream(out);
            InputStream in = socket.getInputStream();
            ObjectInputStream objectIn = new ObjectInputStream(in);
            //connect
            objectOut.writeUTF("connect");
            objectOut.flush();
            //send data
            School xmlData = new School();
            objectOut.writeObject(xmlData);
            objectOut.flush();
            System.out.println(objectIn.readUTF());
            //disconnect
            objectOut.writeUTF("disconnect");
            objectOut.flush();
            System.out.println(objectIn.readUTF());
            socket.close();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}

import java.io.*;
import java.net.Socket;

public class ClientThread extends Thread {
    private Socket socket;
    public ClientThread(Socket serverSocket) {
        this.socket = serverSocket;
    }
    @Override
    public void run() {
        try {
            OutputStream out = socket.getOutputStream();
            ObjectOutputStream objectOut = new ObjectOutputStream(out);
            InputStream in = socket.getInputStream();
            ObjectInputStream objectIn = new ObjectInputStream(in);
            String s;
            while (!(s = objectIn.readUTF()).equals("disconnect")) {
                if (s.equals("connect")) {
                    System.out.println(s);
                    School data = (School) objectIn.readObject();
                    printOutput(data);
                    objectOut.writeUTF("server received data");
                    objectOut.flush();
                }
            }
            System.out.println(s);
            objectOut.writeUTF("u got disconnected");
            objectOut.flush();
        } catch (IOException | ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    private void printOutput(School data) {

        data.getAllRegisterEntries().forEach(employee -> {
            System.out.println(employee.getEntryID());
            System.out.println(employee.getDate());
            System.out.println(employee.getEntryType());
            System.out.println(employee.getEntryText());
            System.out.println(employee.getTeacher());
        });

    }
}

import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import org.xml.sax.SAXException;

import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import java.io.File;
import java.io.IOException;
import java.io.Serializable;
import java.util.ArrayList;

public class School implements Serializable {
    private ArrayList<RegisterEntry>allRegisterEntries;

    public School() {
        this.allRegisterEntries = new ArrayList<>();
        getXmlData(buildDoc());

    }
    public ArrayList<RegisterEntry> getAllRegisterEntries() {
        return allRegisterEntries;
    }
    public NodeList buildDoc(){
        try {
            String filename = "data.xml";
            File file = new File(filename);
            DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance();
            DocumentBuilder documentBuilder = documentBuilderFactory.newDocumentBuilder();
            Document document = documentBuilder.parse(file);
            return document.getElementsByTagName("RegisterEntry");
        } catch (ParserConfigurationException | SAXException | IOException e) {
            e.printStackTrace();
        }
        return null;
    }

    public void getXmlData(NodeList nodeList){
        for (int i = 0; i < nodeList.getLength(); i++) {
            Node node = nodeList.item(i);
            //get all Entry details
            Element element = (Element) node;
            //String id = node.getAttributes().getNamedItem("id").getNodeValue();
            int id = Integer.parseInt(element.getAttribute("entyrID"));
            String date = element.getElementsByTagName("Date").item(0).getTextContent();
            String entryType = element.getElementsByTagName("EntryType").item(0).getTextContent();
            String entryText = element.getElementsByTagName("EntryText").item(0).getTextContent();
            String teacher = element.getElementsByTagName("Teacher").item(0).getTextContent();
            //add RegisterEntry to list
            RegisterEntry e = new RegisterEntry(id, date, entryType, entryText,teacher);
            allRegisterEntries.add(e);
        }
    }


}

import java.io.Serializable;

public class RegisterEntry implements Serializable {

    private int entryID;
    private String date;
    private String entryType;
    private String entryText;
    private String teacher;

    public RegisterEntry(int entryID, String date, String entryType, String entryText, String teacher) {
        this.entryID = entryID;
        this.date = date;
        this.entryType = entryType;
        this.entryText = entryText;
        this.teacher = teacher;
    }

    public int getEntryID() {
        return entryID;
    }

    public String getDate() {
        return date;
    }

    public String getEntryType() {
        return entryType;
    }

    public String getEntryText() {
        return entryText;
    }

    public String getTeacher() {
        return teacher;
    }
    @Override
    public String toString()
    {
        return "RegisterEntry [id=" + entryID + ", date=" + date + ", entryType=" + entryType + ", entryText=" + entryText + ", teacher=" + teacher+"]";
    }
}

public class Main {
    public static void main(String[] args) {
        Client client = new Client("1");
        client.start();
    }
}

///////////////////////////////////////


public class Main {
    public static void main(String  [] args){

        Training training = new Training("Training.xml");
        System.out.println(training.calcEinheit(training.getEinheiten().get(0)));



    }
}


import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import org.xml.sax.SAXException;

import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import java.io.File;
import java.io.IOException;
import java.util.ArrayList;

public class Training {
    private ArrayList<TrainingsEinheit> einheiten;

    public Training(ArrayList<TrainingsEinheit> einheiten) {
        this.einheiten = einheiten;
    }

    public Training(String path) {
        einheiten = new ArrayList<>();
        readDoc(getDoc(path));
    }

    public NodeList getDoc(String path){  // lest xml Datei aus und gibt nodelist zurück
        File inputFile = new File(path);
        try {
            DocumentBuilderFactory dbFactory = DocumentBuilderFactory.newInstance();
            DocumentBuilder dBuilder = dbFactory.newDocumentBuilder();
            Document doc = dBuilder.parse(inputFile);
            NodeList list = doc.getChildNodes();
            return list;
        }catch (ParserConfigurationException e) {
            e.printStackTrace();
        }catch (IOException e) {
            e.printStackTrace();
        }catch (SAXException e) {
            e.printStackTrace();
        }
        return null;
        }

    public void readDoc(NodeList list){ //sucht aus den Nodes die Trainingseinheiten rekursiv
        for(int i=0; i<list.getLength(); i++)
        {
            Node n = list.item(i);
            if(n.getNodeName().equals("Training")){
                readDoc(n.getChildNodes());
            }else if(n.getNodeName().equals("TrainingsEinheit")){
                einheiten.add(new TrainingsEinheit(n));
            }
        }
    }

    public String calcEinheit(TrainingsEinheit einheit) {

        return "Trainingseinheit vom "+einheit.getDatum();
    }



    public ArrayList<TrainingsEinheit> getEinheiten() {
        return einheiten;
    }
}

import org.w3c.dom.Node;
import org.w3c.dom.NodeList;

import java.text.DateFormat;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;

public class TrainingsEinheit {
    private LocalDate datum;
    private ArrayList<Person> mitglieder=new ArrayList<>();
    private ArrayList<SportAktivitaet> aktivitaeten=new ArrayList<>();


    public TrainingsEinheit(LocalDate datum, ArrayList<Person> mitglieder, ArrayList<SportAktivitaet> aktivitaeten) {
        this.datum = datum;
        this.mitglieder = mitglieder;
        this.aktivitaeten = aktivitaeten;
    }

    public TrainingsEinheit(Node node) { // liest Datum, Mitlgieder und Sportaktivitaeten aus den Nodes aus
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("dd-MM-yyyy");
        NodeList list = node.getChildNodes();
        for(int i=0; i<list.getLength(); i++){
            Node n = list.item(i);
            if(n.getNodeName().equals("Datum")){
                datum = LocalDate.parse(list.item(i).getTextContent(), formatter);
            }
            if(n.getNodeName().equals("Mitglieder") && n.hasChildNodes()){
                getMitglieder(n.getChildNodes());
            }
            if(n.getNodeName().equals("Sportaktivitaet") && n.hasChildNodes()){
                aktivitaeten.add(new SportAktivitaet(n));
            }
        }
    }

    private void getMitglieder(NodeList list) { // liest alle Mitglieder aus
        for(int i = 0; i<list.getLength();i++){
            Node n = list.item(i);
            if(n.getNodeName().equals("Person")){
                mitglieder.add(new Person(n.getChildNodes().item(0).getNodeValue()));
            }
        }
    }

    public TrainingsEinheit(LocalDate datum, Person person, ArrayList<SportAktivitaet> aktivitaeten) {
        this.datum = datum;
        this.mitglieder = new ArrayList<Person>();
        this.mitglieder.add(person);
        this.aktivitaeten = aktivitaeten;
    }

    @Override
    public String toString() {
        return "TrainingsEinheit{" +
                "datum=" + datum +
                ", mitglieder=" + mitglieder +
                ", aktivitaeten=" + aktivitaeten +
                '}';
    }

    public LocalDate getDatum() {
        return datum;
    }

    public ArrayList<Person> getMitglieder() {
        return mitglieder;
    }

    public ArrayList<SportAktivitaet> getAktivitaeten() {
        return aktivitaeten;
    }
}

import org.w3c.dom.Node;
import org.w3c.dom.NodeList;

import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;

public class SportAktivitaet{
    private String name;
    private LocalDateTime start;
    private LocalDateTime ende;
    private String geraet;
    private ArrayList<TrainingsDaten> daten=new ArrayList<>();

    public SportAktivitaet(String name, LocalDateTime start, LocalDateTime ende, String geraet, ArrayList<TrainingsDaten> daten) {
        this.name = name;
        this.start = start;
        this.ende = ende;
        this.geraet = geraet;
        this.daten = daten;
    }

    public SportAktivitaet(String name, LocalDateTime start, LocalDateTime ende, ArrayList<TrainingsDaten> daten) {
        this.name = name;
        this.start = start;
        this.ende = ende;
        this.daten = daten;
    }

    public String getName() {
        return name;
    }

    public LocalDateTime getStart() {
        return start;
    }

    public LocalDateTime getEnde() {
        return ende;
    }

    public String getGeraet() {
        return geraet;
    }

    public ArrayList<TrainingsDaten> getDaten() {
        return daten;
    }

    public SportAktivitaet(Node node){ // Liest Start,Ende, Trainingsgeraet und TrainingsDaten aus
        if(node.hasAttributes()){
            name=node.getAttributes().getNamedItem("name").getNodeValue();
        }
        NodeList list = node.getChildNodes();
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("dd-MM-yyyy HH:mm:ss");
        for(int i=0; i<list.getLength(); i++){
            Node n = list.item(i);
            //System.out.println(n.getTextContent());
            switch(n.getNodeName()){
                case "Start":
                    start = LocalDateTime.parse(list.item(i).getTextContent(), formatter);
                    break;
                case "Ende":
                    ende = LocalDateTime.parse(list.item(i).getTextContent(), formatter);
                    break;
                case "Geraet":
                    geraet=n.getChildNodes().item(0).getNodeValue();
                    break;
                case "Daten":
                    NodeList nodelist = n.getChildNodes();
                    for(int j=0;j<nodelist.getLength();j++){
                        Node datennode = nodelist.item(j);
                        if(datennode.getNodeName().equals("TrainingsDaten") && datennode.hasChildNodes()){
                            daten.add(new TrainingsDaten(datennode));
                        }
                    }
                    break;
            }
        }
        outputDuration();
        getAvg();
    }

    public void outputDuration(){ // berechnet gesamte Dauer der Sportaktivitaetn
        int stunden = this.ende.getHour()-this.start.getHour();
        int minuten = this.ende.getMinute()-this.start.getMinute();
        int sekunden= this.ende.getSecond()-this.start.getSecond();
        String dauer = stunden + ":" + minuten + ":" + sekunden;
        System.out.println("Gesamtdauer: "+dauer);
    }

    public void getAvg(){
        double durchschnittPuls = 0;
        double durchschnittGeschwindigkeit = 0;
        for (TrainingsDaten trainingsdaten : this.daten) {
            durchschnittPuls += trainingsdaten.getPuls();
            durchschnittGeschwindigkeit += trainingsdaten.getGeschwindigkeit();
        }
        durchschnittPuls = durchschnittPuls / this.daten.size();
        durchschnittGeschwindigkeit = durchschnittGeschwindigkeit / this.daten.size();
        System.out.println("Durchschnittspuls: " + durchschnittPuls + "\nDurchschnittsgeschwindigkeit: " + durchschnittGeschwindigkeit);
    }

}

import org.w3c.dom.Node;
import org.w3c.dom.NodeList;

import java.time.LocalDate;
import java.time.LocalDateTime;

public class TrainingsDaten {
    private String zeit;
    private int geschwindigkeit;
    private int puls;
    private Wegpunkt wegpunkt;

    public TrainingsDaten(String zeit, int puls, Wegpunkt wegpunkt) {
        this.zeit = zeit;
        this.puls = puls;
        this.wegpunkt = wegpunkt;
    }

    public TrainingsDaten(String zeit, int puls) {
        this.zeit = zeit;
        this.puls = puls;
    }

    public TrainingsDaten(Node node){ // liest zeitpunkt, Geschw, Puls und Wegpunkte aus
        if(node.hasAttributes()){
            zeit=(node.getAttributes().getNamedItem("zeitpunkt").getNodeValue());
        }
        NodeList list = node.getChildNodes();
        for(int i=0; i<list.getLength(); i++){
            Node n = list.item(i);
            if(n.getNodeName().equals("Geschwindigkeit")){
                geschwindigkeit = Integer.parseInt(n.getChildNodes().item(0).getNodeValue());
            }
            if(n.getNodeName().equals("Puls")){
                puls = Integer.parseInt(n.getChildNodes().item(0).getNodeValue());
            }
            if(n.getNodeName().equals("Wegpunkt")){
                wegpunkt = new Wegpunkt(n);
            }
        }
    }

    @Override
    public String toString() {
        return "TrainingsDaten{" +
                "zeit=" + zeit +
                ", geschwindigkeit=" + geschwindigkeit +
                ", puls=" + puls +
                ", wegpunkt=" + wegpunkt +
                '}';
    }

    public String getZeit() {
        return zeit;
    }

    public int getGeschwindigkeit() {
        return geschwindigkeit;
    }

    public int getPuls() {
        return puls;
    }

    public Wegpunkt getWegpunkt() {
        return wegpunkt;
    }
}

public class Person { // Eine Klasse für eine Person mit einem Namen
    private String name;

    public Person(String name) {
        this.name = name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getName() {
        return name;
    }

}


import org.w3c.dom.Node;
import org.w3c.dom.NodeList;

public class Wegpunkt {
    private String name;
    private double laenge;
    private double breite;

    public Wegpunkt(String name, double laenge, double breite) {
        this.name = name;
        this.laenge = laenge;
        this.breite = breite;
    }

    public Wegpunkt(Node node){ // Liest Namen, Laengengrad und Breitengrad des Wegpunkts aus
        if(node.hasAttributes()){
            name=node.getAttributes().getNamedItem("name").getNodeValue();
        }
        NodeList list = node.getChildNodes();
        for(int i=0; i<list.getLength(); i++){
            Node n = list.item(i);
            if(n.getNodeName().equals("Laenge")){
                laenge=Double.parseDouble(n.getChildNodes().item(0).getNodeValue());
            }
            if(n.getNodeName().equals("Breite")){
                breite=Double.parseDouble(n.getChildNodes().item(0).getNodeValue());

            }
        }
    }

    @Override
    public String toString() {
        return "Wegpunkt{" +
                "name='" + name + '\'' +
                ", laenge=" + laenge +
                ", breite=" + breite +
                '}';
    }

    public String getName() {
        return name;
    }

    public double getLaenge() {
        return laenge;
    }

    public double getBreite() {
        return breite;
    }
}