Andres2908
74 lines
1.9 KiB
JavaScript
74 lines
1.9 KiB
JavaScript
require('./config');
|
|
const mariadb = require('mariadb');
|
|
|
|
const pool1 = mariadb.createPool({
|
|
host: process.env.SAT_HOST,
|
|
user: process.env.SAT_USER,
|
|
password: process.env.SAT_PASSWORD,
|
|
database: process.env.SATL_DB,
|
|
});
|
|
|
|
const pool2 = mariadb.createPool({
|
|
host: process.env.HOST_DB,
|
|
user: process.env.USER_DB,
|
|
password: process.env.PASSWORD_DB,
|
|
database: process.env.SATE_DB,
|
|
});
|
|
|
|
const obtenerIdCarrera = async (numeroCuenta) => {
|
|
const conn = await pool1.getConnection().catch((err) => {
|
|
throw new Error('No se pudo conectar con la db. ' + err);
|
|
});
|
|
|
|
return conn
|
|
.query(`SELECT id_carrera FROM alumno WHERE id_cuenta = ${numeroCuenta}`)
|
|
.then((rows) => {
|
|
conn.end();
|
|
// console.log(rows[0]);
|
|
// if (rows[0].length === 0) return null;
|
|
return rows[0];
|
|
})
|
|
.catch((err) => {
|
|
conn.end();
|
|
throw new Error('Hubo un problema con el querry.' + err);
|
|
});
|
|
};
|
|
|
|
const obtenerCarrera = async (idCarrera) => {
|
|
const conn = await pool1.getConnection().catch((err) => {
|
|
throw new Error('No se pudo conectar con la db. ' + err);
|
|
});
|
|
|
|
return conn
|
|
.query(`SELECT id_carrera FROM carrera WHERE id_carrera = ${idCarrera}`)
|
|
.then((rows) => {
|
|
conn.end();
|
|
return rows[0];
|
|
})
|
|
.catch((err) => {
|
|
conn.end();
|
|
throw new Error('Hubo un problema con el querry.' + err);
|
|
});
|
|
};
|
|
|
|
const usuarioInscrito = async (numeroCuenta) => {
|
|
const conn = await pool2.getConnection().catch((err) => {
|
|
throw new Error('No se pudo conectar con la db. ' + err);
|
|
});
|
|
|
|
return conn
|
|
.query(
|
|
`INSERT INTO alumno_inscrito(id_cuenta,id_periodo,id_plataforma,realizo_pago,platica) values(${numeroCuenta}, 20, 4, 1, 1)`
|
|
)
|
|
.then((rows) => {
|
|
conn.end();
|
|
return rows[0];
|
|
})
|
|
.catch((err) => {
|
|
conn.end();
|
|
throw new Error('Hubo un problema con el querry.' + err);
|
|
});
|
|
};
|
|
|
|
module.exports = { obtenerIdCarrera, obtenerCarrera, usuarioInscrito };
|