const { Client } = require('pg');


function conectarBBDD() {

    const conectionPG = {
        user: 'postgres',
        password: 'maxhito',
        host: 'localhost',  // Localhost es MI COMPUTADOR
        database: 'postgres',
        port: '5432',
    };

    const crudPG = new Client(conectionPG);
    crudPG.connect();

    return crudPG;
}

function desconectarBBDD(conexion) {
    conexion.end();
}


// Confección de una consulta general
function hacerSelect(tabla) {
    const cone = conectarBBDD();
    cone.query('select * from ' + tabla)
        .then(respuesta => {
            console.log(respuesta.rows)
            desconectarBBDD(cone);
        })
        .catch( error => {
            console.log("Hicimos la morición")
            console.log(error)
            desconectarBBDD(cone);
        });
}

// Confección de un delete para la tabla en la que está trabajando
function eliminar(nombre) {
    const cone = conectarBBDD();
    cone.query("delete from gatito where nombre='"+ nombre + "'")
        .then(respuesta => {
            console.log("Se eliminó correctamente")
            desconectarBBDD(cone);
        })
        .catch( error => {
            console.log("Hicimos la morición")
            console.log(error)
            desconectarBBDD(cone);
        });
}
//insert into usuarios (nombre,clave) values ('Marcelo','River');

// Confección de un insert para una tabla determinada
function insertar(id, nombre) {
    const cone = conectarBBDD();
    let sqlConsulta = "insert into gatito (id, nombre) values ("+ id + ", " + "'" + nombre + "')";
    console.log(sqlConsulta);
    cone.query(sqlConsulta)
        .then(respuesta => {
            console.log("Se ingresó correctamente")
            desconectarBBDD(cone);
        })
        .catch( error => {
            console.log("Hicimos la morición")
            console.log(error)
            desconectarBBDD(cone);
        });
}

// Confección de una actualizacion para una tabla determinada
function actualizar(id, nombre) {
    const cone = conectarBBDD();
    let sqlUpdate = "update  gatito set nombre='" + nombre + "' where id=" + id;
    console.log(sqlUpdate);
    cone.query(sqlUpdate)
        .then(respuesta => {
            console.log("Se actualizó correctamente")
            desconectarBBDD(cone);
        })
        .catch( error => {
            console.log("Hicimos la morición")
            console.log(error)
            desconectarBBDD(cone);
        });
}



// LLAMADA A LAS FUNCIONES

//insertar(2, "Gato Felix");
//actualizar(1, "gato regalito");
hacerSelect('gatito');