/*

Descarregar drivers
Afegir-ho al classpath (per a carregar les classes que fem servir.
export CLASSPATH=$CLASSPATH:/Users/maria/Downloads/postgresql.jar:/Users/maria/Downloads/mysql-connector-java.jar




*/


import java.sql.*;  // (1) importa les classes del JDBC
public class HolaPG {
    public static void main(String[] args) {
        // components de la cadena de connexió
        //userMySQL: maria
        //passMySQL: maria
        String usuari   = "postgres";
        String password = "maria";
        String host     = "localhost";
        String bd       = "testbd";


        //jdbc:postgresql:jdbc:mysql:
        String cadenaConnexio // (2) composa la cadena de connexió
            = "jdbc:postgresql://" + host
            + "/"                + bd
            + "?user="           + usuari
            + "&password="       + password;

        // connexió
        Connection conn=null;
        try {
            // (3) realitza la connexió
            conn = DriverManager.getConnection(cadenaConnexio);
            System.out.println("Connectat a la base de dades " + bd);
            //createEQUIPO(conn, bd);
            //createJUGADORES(conn, bd);
            //cargaEQUIPO(conn, bd);
            //cargaJUGADORES(conn, bd);
            insertaJUGADOR(conn, bd, 10, 2, "messi", 5, 25);




        } catch (SQLException e) {
            System.out.println("ERROR: no s'ha pogut connectar: " + e);
        } finally {
            try{
                if (conn!=null) {
                    conn.close(); // (4) tanca la connexió
                }
            } catch (Exception e) {
                System.out.println("ERROR: no s'ha pogut desconnectar: " + e);
            }
        }
    }
              public static void createEQUIPO(Connection con, String BDNombre) throws SQLException {
                String createString = "CREATE TABLE IF NOT EXISTS EQUIPO " +
                "(TEAM_ID integer NOT NULL," +
                "EQ_NOMBRE varchar(40) NOT NULL," +
                "ESTADIO varchar(40) NOT NULL," +
                "POBLACION varchar(20) NOT NULL," +
                "PROVINCIA varchar(20) NOT NULL," +
                "COD_POSTAL char(5)," +
                "PRIMARY KEY (TEAM_ID))";


                Statement stmt = null;
                try {
                stmt = con.createStatement();
                stmt.executeUpdate(createString);
                System.out.println("taula creada correctament");

                } catch (SQLException e) {
                System.out.println("ERROR: no s'ha pogut connectar: " + e);
                } finally {
                stmt.close();
                }
                }
        public static void createJUGADORES(Connection con, String BDNombre) throws SQLException {
        String createString = "CREATE TABLE IF NOT EXISTS JUGADORES " +
    "(PLAYER_ID integer NOT NULL," +
    "TEAM_ID integer NOT NULL,"+
    "NOMBRE varchar(40) NOT NULL," +
    "DORSAL integer NOT NULL," +
    "EDAD integer NOT NULL," +
    "PRIMARY KEY (PLAYER_ID)," +
    "FOREIGN KEY (TEAM_ID) REFERENCES EQUIPO (TEAM_ID))";

            Statement stmt = null;
            try {
            stmt = con.createStatement();
            stmt.executeUpdate(createString);
            System.out.println("jugadors donats d'alta");
            } catch (SQLException e) {
            System.out.println("ERROR: no s'ha pogut connectar: " + e);
            } finally {
            stmt.close();
            }
            }

            public static void cargaEQUIPO(Connection con, String BDNombre) throws SQLException {
    Statement stmt = null;
    try {
        stmt = con.createStatement();
        stmt.executeUpdate("INSERT INTO EQUIPO (TEAM_ID, EQ_NOMBRE,ESTADIO, POBLACION, PROVINCIA, COD_POSTAL) VALUES (1,'ESTEPONA','MONTERROSO','ESTEPONA','MALAGA','29680')");
        stmt.executeUpdate("INSERT INTO EQUIPO (TEAM_ID, EQ_NOMBRE,ESTADIO, POBLACION, PROVINCIA, COD_POSTAL) VALUES (2,'ALCORCON','SANTO DOMINGO','ALCORCON','MADRID','28924')");
        stmt.executeUpdate("INSERT INTO EQUIPO (TEAM_ID, EQ_NOMBRE,ESTADIO, POBLACION, PROVINCIA, COD_POSTAL) VALUES (3,'PORCUNA','SAN CRISTOBAL','PORCUNA','JAEN','23790')");

    } catch (SQLException e) {
    System.out.println("ERROR: no s'ha pogut connectar: " + e);
    } finally {
    stmt.close();
    }
}
public static void cargaJUGADORES(Connection con, String BDNombre) throws SQLException
    {
        Statement stmt = null;
        try {
            stmt = con.createStatement();



            //Cargando datos de Estepona
            stmt.executeUpdate("INSERT INTO JUGADORES (PLAYER_ID, TEAM_ID ,NOMBRE, DORSAL, EDAD) VALUES (1,1,'JOSE ANTONIO',1,42)");

            stmt.executeUpdate("INSERT INTO JUGADORES (PLAYER_ID, TEAM_ID ,NOMBRE, DORSAL, EDAD) VALUES (2,1,'IGNACIO',2,62)");

            stmt.executeUpdate("INSERT INTO JUGADORES (PLAYER_ID, TEAM_ID ,NOMBRE, DORSAL, EDAD) VALUES (3,1,'DIEGO',3,20)");
            //Cargando datos de Alcorcón
            stmt.executeUpdate("INSERT INTO JUGADORES (PLAYER_ID, TEAM_ID ,NOMBRE, DORSAL, EDAD) VALUES (4,2,'TURRION',1,37)");

            stmt.executeUpdate("INSERT INTO JUGADORES (PLAYER_ID, TEAM_ID ,NOMBRE, DORSAL, EDAD) VALUES (5,2,'LUIS ABEL',2,37)");

            stmt.executeUpdate("INSERT INTO JUGADORES (PLAYER_ID, TEAM_ID ,NOMBRE, DORSAL, EDAD) VALUES (6,2,'ISAAC',3,40)");
            //Cargando datos de Porcuna
            stmt.executeUpdate("INSERT INTO JUGADORES (PLAYER_ID, TEAM_ID ,NOMBRE, DORSAL, EDAD)VALUES (7,3,'JUAN FRANCISCO',1,33)");

            stmt.executeUpdate("INSERT INTO JUGADORES (PLAYER_ID, TEAM_ID ,NOMBRE, DORSAL, EDAD) VALUES (8,3,'PARRA',2,37)");

            stmt.executeUpdate("INSERT INTO JUGADORES (PLAYER_ID, TEAM_ID ,NOMBRE, DORSAL, EDAD) VALUES (9,3,'RAUL',3,19)");
        } catch (SQLException e) {
            System.out.println("ERROR: no s'ha pogut connectar: " + e);
        } finally {
            stmt.close();
        }
}

        public static void insertaJUGADOR(Connection con, String BDNombre, int player_id,int team_id,String nombre,int dorsal,int edad)throws SQLException {
            Statement stmt = null;
            try {
                stmt = con.createStatement();
                stmt = con.createStatement(
                ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
                ResultSet rs = stmt.executeQuery("SELECT * FROM  JUGADORES");
                rs.moveToInsertRow();
                rs.updateInt("PLAYER_ID", player_id);
                rs.updateInt("TEAM_ID", team_id);
                rs.updateString("NOMBRE", nombre);
                rs.updateInt("DORSAL", dorsal);
                rs.updateInt("EDAD", edad);
                rs.insertRow();
                rs.beforeFirst();
            } catch (SQLException e ) {
                System.out.println("ERROR: no s'ha pogut connectar: " + e);
            } finally {
                stmt.close();
            }
    }
}