package service;
import javax.annotation.PostConstruct;
//import javax.activation.DataSource;
import javax.annotation.Resource;
import javax.ws.rs.*;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.core.Context;


import jdk.nashorn.internal.objects.annotations.Getter;

import java.sql.*;
import javax.sql.*;




//@Resource(name="mariadb",lookup="jboss/mariadb");


@Path("service")
public class RestService{

    @Resource(lookup="java:/PostgresXADS") private DataSource ds;
    private Connection conn;
    /*
    String url = "jdbc:postgresql://127.0.0.1:5433/test";
    Connection conn;
    */
    String error = "";


    public RestService(){
        try {

            //DriverManager.registerDriver(new com.mariadb.jdbc.Driver ());
            //Class.forName("com.postgresql.jdbc.Driver").newInstance();
            //conn = DriverManager.getConnection(url,"root","root");
            //error = "connesso";
        } catch (Exception e) {
            error = e.getMessage();
        }
    }



    @GET
    @Path("insert/{id}/{name}/{age}")
    public String insert_record(@PathParam("id") int id, @PathParam("name") String name, @PathParam("age") int age){
        try {
            conn = ds.getConnection();

            String insertNewUserSQL = "INSERT INTO \"user\" (id, name, age) VALUES (?, ?, ?)";
            PreparedStatement pstmt = conn.prepareStatement(insertNewUserSQL);
            pstmt.setInt(1, id);
            pstmt.setString(2, name);
            pstmt.setInt(3, age);
            pstmt.executeUpdate();

            return "<h1>DONE</h1>";
        }catch (Exception e){

            return "<h1>"+e.getMessage()+"</h1>";
        }
    }


    @GET
    @Path("viewall")
    public String show_users(/*@Context UriInfo info non trova classe*/){

        try{


            String order = "name"; //info.getQueryParameters().getFirst("order");
            //return "=====> "+order;

            String query = "SELECT * FROM \"user\"";
            if (order!=""){
                query+=" ORDER BY \""+order+"\"";
                //return query;
            }

            conn = ds.getConnection();
            Statement t = conn.createStatement();
            ResultSet rs = t.executeQuery(query);

            String tmp="<table>";
            while (rs.next()) {

                tmp+="<tr>";
                tmp+="<td>"+rs.getInt("id")+"</td>";
                tmp+="<td>"+rs.getString("name")+"</td>";
                tmp+="<td>"+rs.getInt("age")+"</td>";
                tmp+="</tr>";
            }
            tmp+="</table>";

            return tmp;

        }catch (Exception e){
            return e.getMessage();
        }
    }


    @GET
    @Path("view/{id}")
    public String sayHello(@PathParam("id") int id) {

        String tmp = "";

        try {
            conn = ds.getConnection();
            Statement t = conn.createStatement();
            ResultSet rs = t.executeQuery("SELECT name FROM \"user\" WHERE id = "+id);

            while (rs.next()) {
                String txt = rs.getString("name")+"<br/>";
                System.out.println(txt);
                tmp += txt;
            }
        } catch (Exception e) {
            error+=e.getMessage();
        }


        return "<h1>"+error+" -- "+tmp+"</h1>";
    }
}