import java.sql.*;
import java.io.*;


public class ListeInMySQL {
    public static void main(String[] args) throws Exception {
        //Treiber laden
        Class.forName( "com.mysql.jdbc.Driver" );

        //Verbindung zur Datenbank aufbauen (Name der Datenbank: test)
        String verbindung = "jdbc:mysql://localhost:3306/test";
        String benutzer = "root";
        String password = "";  //Datenbank besitzt kein Passwort
        Connection conn = DriverManager.getConnection(verbindung, benutzer, password);

        //Anweisungsobjekt erzeugen
        Statement stmt = conn.createStatement();

        String sql = "DROP TABLE personenListe;";
        stmt.execute(sql);

        sql = "CREATE TABLE personenListe (ID INT NOT NULL AUTO_INCREMENT, vorname VARCHAR(20), nachname VARCHAR(20), ort VARCHAR(20), PRIMARY KEY (ID));";
        stmt.execute( sql );

        //BufferedReader erzeugen
        BufferedReader br = null;

        try {
            br = new BufferedReader (new FileReader("personen.txt"));
        } catch(Exception e) {e.printStackTrace();}

        while(true) {
            String xs = br.readLine();

            if (xs!=null) {
                String[] spalten = xs.split(",",3);
                sql = "INSERT INTO personenListe (vorname, nachname, ort) VALUES (\""+spalten[0]+"\",\""+spalten[1]+"\",\""+spalten[2]+"\");";
                stmt.execute(sql);
            } else
                break;
        }

        System.out.println("Erfolgreich beendet!");
    }
}