trololo

package lotto_bazy;

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;

public class Database extends Operacje {

	public static Connection conn;
	public static Statement stat;


    public static void main(String[] args) {

        String baza = "Nagrody";
        Operacje oper= new Operacje();

        try {
            Class.forName("org.sqlite.JDBC");
        } catch (ClassNotFoundException e) {
            System.err.println("Brak sterownika JDBC");
            e.printStackTrace();
        }

        try {
            conn = DriverManager.getConnection("jdbc:sqlite:"+baza+".db");
            stat = conn.createStatement();
        } catch (SQLException e) {
            System.err.println("Problem z otwarciem polaczenia");
            e.printStackTrace();
        }

    Database start = new Database();

   System.out.println("--Wcisnij [ 1 ] zeby stworzyc tabele z rekordami lub [ 2 ] aby wyjsc do menu--");

    Scanner odczyt = Scanner(System.in);

    String x= odczyt.nextLine();

     if(x == "1"){

    start.createTabele();
    start.read("lista_lotto.txt");

     }
     else
     {
    	oper.Menu();
     }

   if(x == "0") {
	   start.closeConnection();
	   System.exit(0);
   }

           }



 /////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
    boolean dropDB() throws SQLException {

        String win = "DROP TABLE if EXISTS nagrody;";
        stat.execute(win);

        String pkt = "DROP TABLE if EXISTS punkty_obslugi;";
        stat.execute(pkt);
 return true;

    }



    public boolean createTabele(){



    	String createNagroda="CREATE TABLE IF NOT EXISTS nagroda(id INTEGER PRIMARY KEY AUTOINCREMENT, kwota_wygranej double, miasto VARCHAR(20) , ulica VARCHAR(40), data VARCHAR(20));";
  //  	String createPunkt= "CREATE TABLE IF NOT EXISTS pkt_obslugi(id INTEGER PRIMARY KEY AUTOINCREMENT, miasto VARCHAR(30) , ulica VARCHAR(40) UNIQUE);";

    	try{
    		stat.execute(createNagroda);
   // 		stat.execute(createPunkt);
    		System.out.println("Stworzono tabele \n");

    	return true;
    	} catch (SQLException e) {
            e.printStackTrace();
            System.out.println("Blad przy tworzeniu tabeli!");
            return false;
        }


    }


	//    private Statement stat;

	    String[][] read(String path) {

	        BufferedReader br = null;
	        List<String> line = new ArrayList<>();

	        String baza = "Nagrody";
	        try {
	            Class.forName("org.sqlite.JDBC");
	        } catch (ClassNotFoundException e) {
	            System.err.println("Brak sterownika JDBC");
	            e.printStackTrace();
	        }

	        try {
	            conn = DriverManager.getConnection("jdbc:sqlite:"+baza+".db");
	            stat = conn.createStatement();
	        } catch (SQLException e) {
	            System.err.println("Problem z otwarciem polaczenia");
	            e.printStackTrace();
	        }


	        try {
	            String CurrentLine;

	            br = new BufferedReader(new FileReader(path));

	            while ((CurrentLine = br.readLine()) != null) {
	                line.add(CurrentLine);
	            }

	        } catch (IOException e) {
	            e.printStackTrace();
	        } finally {
	            try {
	                if (br != null) {
	                    br.close();
	                }
	            } catch (IOException ex) {
	                ex.printStackTrace();
	            }
	        }


	    	return sortFile(line);
	    }


	    private String[][] sortFile(List<String> lista)
	    {
	        String[][] line = new String[lista.size()][5];
	      ;
	        for(int i = 0; i < lista.size(); i++) {
	            String[] zmienna = lista.get(i).split(" -- ");
	            line[i][0] = zmienna[0];
	            line[i][1] = zmienna[1];
	            line[i][2] = zmienna[2];
	            line[i][3] = zmienna[3];
	            line[i][4] = zmienna[4].replace(',', '.');

	            try {
	            //	String x=zmienna[0];
	            	String miasto= zmienna[1];
	            	String ulica= zmienna[2];
	            	String data= zmienna[3];
	            	String money= zmienna[4];

	                String tab1=
	                "insert into nagroda ( kwota_wygranej, miasto, ulica, data) values ('"+ money +"','" +miasto+ "','"+ ulica +"','"+data+"');";

	                stat.execute(tab1);

	          //      System.out.println(("Utworzono nagrodę: "+x));

	        //        String tab2="insert into pkt_obslugi (miasto, ulica) values ('"+miasto+"','"+ulica+"');";

	      //          stat.execute(tab2);

	            } catch (SQLException e) {
	                System.err.println("Blad przy wstawianiu nagrody");
	                e.printStackTrace();
	                System.out.println(line[i][0]);
	            }


	        }

	        return line;
	    }




    private static Scanner Scanner(InputStream in) {
			// TODO Auto-generated method stub
			return null;
		}
/////////////////////////////////////////////////////////////////////////////////////////////////////
    public void Menu(){


    	System.out.print(
    			"0- Wyjscie z programu  \n"
    			+ "1- Wyswietlenie wszystkich wynikow  \n"
    			+ "2- Wybor dowolnej komendy (oczywiscie w jezyku sql) \n"
    			+ "3- Wybor, jakie wyniki chcesz wyswietlic \n" //SELECT
    			+ "4- Miasto z najwieksza liczba wygranych \n"
    			+ "5- Adres punktu gdzie bylo najwiecej wygranych \n"
    			+ "6- Porownanie miast i ich zsumowane wysokosci nagrod \n"
    			+ "7-  \n"
    			+ "8-  \n"
    			+ "9-  \n"
    			);

    	Scanner odczyt= new Scanner(System.in);
    	try{
    	int i= odczyt.nextInt();
    	}
    	finally{


    	switch (odczyt.nextInt()){
    	case(1):{                        }
    	case(2):{                        }
    	case(3):{                        }
    	case(4):{                        }
    	case(5):{                        }
    	case(6):{                        }
    	case(7):{                        }
    	case(8):{                        }
    	case(9):{                        }
    	case(0):{        break;          }




    	}


    	}


     }


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

	public void closeConnection() {
        try {
            conn.close();
        } catch (SQLException e) {
            System.err.println("Problem z zamknieciem polaczenia");
            e.printStackTrace();
        }
    }

}