package BazyDanych;

import java.sql.Connection;
        import java.sql.DriverManager;
        import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
        import java.sql.SQLException;
        import java.sql.Statement;

public class BazyDanych {

    public static void zad12(Connection con) {
        try{
            System.out.println("\nZAD12");
            Statement zapytanieA = con.createStatement();
            String sqlA="SELECT * FROM Tabela1";
            ResultSet wynik_zapytaniaA = zapytanieA.executeQuery(sqlA);
            ResultSetMetaData wynikA = wynik_zapytaniaA.getMetaData();
            int ile_kolumnA = wynikA.getColumnCount();
            while(wynik_zapytaniaA.next()) {
                for (int i=1;i<=ile_kolumnA;i++) {
                    System.out.print(wynik_zapytaniaA.getString(i)+" | ");
                }
                System.out.println();
            }
            System.out.println();

            Statement zapytanieB = con.createStatement();
            String sqlB="SELECT * FROM Tabela2";
            ResultSet wynik_zapytaniaB = zapytanieB.executeQuery(sqlB);
            ResultSetMetaData wynikB = wynik_zapytaniaB.getMetaData();
            int ile_kolumnB = wynikB.getColumnCount();
            while(wynik_zapytaniaB.next()) {
                for (int i=1;i<=ile_kolumnB;i++) {
                    System.out.print(wynik_zapytaniaB.getString(i)+" | ");
                }
                System.out.println();
            }
        }
        catch(SQLException error_polaczenie) {
            System.out.println("Błąd połączenia z bazą danych");}
    }

    public static void zad13(Connection con){
        try{
            System.out.println("\nZAD13");
            Statement zapytanieA = con.createStatement();

            String sqlA="SELECT Tabela1.nazwisko,"
                      + "DATEDIFF(YEAR,dataUrodzenia,GETDATE()) AS wiek,miasto\n"
                      + "FROM Tabela1 INNER JOIN Tabela2 \n"
                      + "ON Tabela1.nazwisko=Tabela2.nazwisko";

            ResultSet wynik_zapytaniaA = zapytanieA.executeQuery(sqlA);
            ResultSetMetaData wynikA = wynik_zapytaniaA.getMetaData();
            int ile_kolumnA = wynikA.getColumnCount();
            while(wynik_zapytaniaA.next()) {
                for (int i=1;i<=ile_kolumnA;i++) {
                    System.out.print(wynik_zapytaniaA.getString(i)+" / ");
                }
                System.out.println();
            }
            System.out.println();
        }
        catch(SQLException error_polaczenie) {
            System.out.println("Błąd połączenia z bazą danych");}
    }

    public static void zad14(Connection con){
        try{
            System.out.println("ZAD14");
            Statement zapytanieA = con.createStatement();

            String sqlA="SELECT nazwisko FROM Tabela1 WHERE "
                    + "DATEDIFF(YEAR, dataUrodzenia, GETDATE())="
                    + "(SELECT MIN(DATEDIFF(YEAR, dataUrodzenia, GETDATE())) FROM Tabela1)";

            ResultSet wynik_zapytaniaA = zapytanieA.executeQuery(sqlA);
            ResultSetMetaData wynikA = wynik_zapytaniaA.getMetaData();
            int ile_kolumnA = wynikA.getColumnCount();
            while(wynik_zapytaniaA.next()) {
                for (int i=1;i<=ile_kolumnA;i++) {
                    System.out.print(wynik_zapytaniaA.getString(i)+" | ");
                }
                System.out.println();
            }
        }
        catch(SQLException error_polaczenie) {
            System.out.println("Błąd połączenia z bazą danych");}
    }

    public static void zad15(Connection con){
        try{
            System.out.println("\nZAD15");
            Statement zapytanieA = con.createStatement();

            String sqlA="SELECT COUNT(nazwisko) AS [ilość mieszkańców], miasto\n"
                      + "from tabela2\n"
                      + "group by miasto";

            ResultSet wynik_zapytaniaA = zapytanieA.executeQuery(sqlA);
            ResultSetMetaData wynikA = wynik_zapytaniaA.getMetaData();
            int ile_kolumnA = wynikA.getColumnCount();
            while(wynik_zapytaniaA.next()) {
                for (int i=1;i<=ile_kolumnA;i++) {
                    System.out.print(wynik_zapytaniaA.getString(i)+" | ");
                }
                System.out.println();
            }
        }
        catch(SQLException error_polaczenie) {
            System.out.println("Błąd połączenia z bazą danych");}
    }

    public static void main(String[] args) {

        Connection con;
        try{
            Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
            con = DriverManager.getConnection("jdbc:sqlserver://"+
            "153.19.7.13:1401;databaseName=kbohdanowicz;"+
            "user=kbohdanowicz;password=253933;");
            System.out.println("Połączono z bazą danych");

            zad12(con);
            zad13(con);
            zad14(con);
            zad15(con);

            con.close();
        }
        catch(SQLException error_polaczenie) {
            System.out.println("Błąd połączenia z bazą danych");}
        catch(ClassNotFoundException error_sterownik) {
            System.out.println("Brak sterownika");}
        }
    }