package com.assessment.drones.repository;

import com.fasterxml.jackson.databind.ObjectMapper;
import net.minidev.json.JSONValue;
import org.json.JSONArray;
import org.json.JSONObject;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
import org.springframework.stereotype.Repository;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;


public class CanvasjsChartData {

    private static JdbcTemplate jdbcTemplate;
    static Map<Object,Object> map = null;
    static List<List<DataPointModel>> list = new ArrayList<List<DataPointModel>>();
    static List<DataPointModel> dataPoints1 = new ArrayList<DataPointModel>();



    static {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/canvasjs_db");
        dataSource.setUsername("root");
        dataSource.setPassword("comsc");
        jdbcTemplate = new JdbcTemplate(dataSource);
    }

    public static class DataPointModel {
        int x;
        int y;

        public int getX() {
            return x;
        }
        public void setX(int x) {
            this.x = x;
        }
        public int getY() {
            return y;
        }
        public void setY(int y) {
            this.y = y;
        }
    }

    public static class DatabaseConnectionException  extends RuntimeException{

        private static final long serialVersionUID = 1L;

        public DatabaseConnectionException(String message) {
            super(message);
        }
    }

    private static void getDataPoints(){
        String sql = "select id AS 'user id', email from user JSON;";


        try {
            dataPoints1 = jdbcTemplate.query(sql, new RowMapper<DataPointModel>() {

                @Override
                public DataPointModel mapRow(ResultSet rs, int rowNum) throws SQLException {
                    DataPointModel dataPoint = new DataPointModel();

                    dataPoint.setX(rs.getInt("y"));
                    dataPoint.setY(rs.getInt("label"));

//

                    return dataPoint;
                }});
        }
        catch(Exception e){
            dataPoints1 = null;
            throw new DatabaseConnectionException("Error while getting dataPoints");
        }
        list.add(dataPoints1);
    }

    public static List<List<DataPointModel>> getCanvasjsDataList() {
        getDataPoints();
        return list;
    }

}