/*
 * Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
 * Click nbfs://nbhost/SystemFileSystem/Templates/Project/Maven2/JavaApp/src/main/java/${packagePath}/${mainClassName}.java to edit this template
 */
package com.megatim.queryadhoc;

import com.megatim.queryadhoc.enums.SgbdType;
import com.megatim.queryadhoc.enums.TypeDonnee;
import com.megatim.queryadhoc.exceptions.ConnectionException;
import com.megatim.queryadhoc.exceptions.ConnectionParameterException;
import com.megatim.queryadhoc.exceptions.IllegalFormatDateException;
import com.megatim.queryadhoc.exceptions.NotSupportedDataBaseException;
import com.megatim.queryadhoc.model.ConnectionParameter;
import com.megatim.queryadhoc.model.DbColumnDescription;
import com.megatim.queryadhoc.query.insert.impl.PostgresInsertQuery;
import com.megatim.queryadhoc.query.select.impl.PostgresSelectQuery;
import com.megatim.queryadhoc.table.DataBaseTable;
import java.io.File;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author ASUS
 */
public class App {

    private static final String TABLE_NAME = "users";
    private static final String DATABASE_NAME = "test_query";
    private static final String OUTPUT_DIR = "C:\\Users\\ASUS\\Documents\\DATAS\\Export";

    public static void main(String[] args) {
//        tableExists();
//        isDatabaseAvailable();
//        insert();
        select();
    }

    private static ConnectionParameter mySqlConnectionParameters() {
        return new ConnectionParameter(3306, DATABASE_NAME, "mela", "127.0.0.1", "mela");
    }

    private static ConnectionParameter postgresConnectionParameters() {
        return new ConnectionParameter(5432, DATABASE_NAME, "postgres", "127.0.0.1", "mela");
    }

    private static ConnectionParameter sqlServerConnectionParameters() {
        return new ConnectionParameter(1433, DATABASE_NAME, "sa", "192.168.1.210", "Mgt@9090");
    }

    private static void isDatabaseAvailable() {
        try {
            boolean bool = new DataBaseTable(SgbdType.POSTGRESQL, postgresConnectionParameters())
                    .isDatabaseAvailable();
            System.out.println("Result : " + bool);
        } catch (NotSupportedDataBaseException | ConnectionParameterException ex) {
            Logger.getLogger(App.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
        }
    }

    private static void tableExists() {
        try {
            boolean bool = new DataBaseTable(SgbdType.POSTGRESQL, postgresConnectionParameters())
                    .tableExists("users1");
            System.out.println("Result : " + bool);
        } catch (NotSupportedDataBaseException | ConnectionParameterException | ConnectionException ex) {
            Logger.getLogger(App.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
        }
    }

    private static void select() {
        try {
//            List<Map<String, Object>> data = new DataBaseTable()
//                    .select(SgbdType.POSTGRESQL, postgresConnectionParameters())
//                    .execute(TABLE_NAME, Arrays.asList("userName", "dateaction"));
//
//            data.stream().forEach(l -> {
//                l.forEach((k, v) -> {
//                    System.out.println(k + ", " + v);
//                });
//            });
            new DataBaseTable(SgbdType.POSTGRESQL, postgresConnectionParameters())
                    .select()
                    .execute(TABLE_NAME, columns(), OUTPUT_DIR, TABLE_NAME, false);
        } catch (NotSupportedDataBaseException ex) {
            Logger.getLogger(App.class.getName()).log(Level.SEVERE, null, ex);
        } catch (Exception ex) {
            Logger.getLogger(App.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    private static void insert() {
        try {
            File dataFile = new File("C:\\Users\\ASUS\\Documents\\DATAS\\Export\\USERS20250129102052.txt");
            new DataBaseTable(SgbdType.POSTGRESQL, postgresConnectionParameters())
                    .insert()
                    .execute(TABLE_NAME, columns(), dataFile);
        } catch (NotSupportedDataBaseException ex) {
            Logger.getLogger(App.class.getName()).log(Level.SEVERE, null, ex);
        } catch (Exception ex) {
            Logger.getLogger(App.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    private static void postgresSelectQuery() {
        try {
//            List<Map<String, Object>> data = new PostgresSelectQuery(connectionParameters()).execute("ref000018_caaadm", Arrays.asList());
//System.out.println("***************** size " + data.size());
//            System.out.println("" + data.get(0));
            new PostgresSelectQuery(postgresConnectionParameters()).execute("users", columns(), TABLE_NAME, OUTPUT_DIR, true);

        } catch (Exception ex) {
            Logger.getLogger(App.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    private static void postgresInsertQuery() {
        File dataFile = new File("C:\\Users\\ASUS\\Documents\\DATAS\\Export\\USERS20250127160445.txt");
        try {
            new PostgresInsertQuery(postgresConnectionParameters()).execute(TABLE_NAME, columns(), data());
        } catch (Exception ex) {
            Logger.getLogger(App.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    private static List<DbColumnDescription> columns() {
        try {
            List<DbColumnDescription> cols = new ArrayList<>();
//        cols.add(new DbColumnDescription("code_adnt", TypeDonnee.ALPHANUMERIQUE, 10, 1));
//        cols.add(new DbColumnDescription("valeur", TypeDonnee.ALPHANUMERIQUE, 20, 2));
//        cols.add(new DbColumnDescription("code_val", TypeDonnee.ALPHANUMERIQUE, 30, 3));
//        cols.add(new DbColumnDescription("qua_ti_col", TypeDonnee.ALPHANUMERIQUE, 30, 4));
//        cols.add(new DbColumnDescription("te_cpt_cons", TypeDonnee.ALPHANUMERIQUE, 50, 5));

            cols.add(new DbColumnDescription("username", TypeDonnee.ALPHANUMERIQUE, 4, 1, null, null, 0));
            cols.add(new DbColumnDescription("montant", TypeDonnee.NUMERIQUE, 10, 2, null, null, 0));

            DbColumnDescription desc = new DbColumnDescription("dateaction", TypeDonnee.DATE, 10, 3, "yyyyMMdd", "-", 0);
            cols.add(desc);

            return cols;
        } catch (IllegalFormatDateException ex) {
            Logger.getLogger(App.class.getName()).log(Level.SEVERE, null, ex);
            return null;
        }
    }

    private static List<Map<String, Object>> data() {
        List<Map<String, Object>> data = new ArrayList<>();
        Map<String, Object> map = new HashMap<>();

        map.put("username", "Samory");
        map.put("montant", "000025");
        map.put("dateaction", "2025-02-06");
        data.add(map);

        return data;
    }
}