se agrego el query para la base de profesors de dsc

This commit is contained in:
2021-09-13 15:47:14 -05:00
parent 2cff201087
commit 43a01ddaae
5 changed files with 3203 additions and 38 deletions
+9
View File
@@ -0,0 +1,9 @@
var mysql = require('mysql');
const connection = mysql.createConnection({
host: '132.248.80.194',
user: 'des_georg',
database: 'Betelgeuse_dat_prof',
password: 'emp140'
});
module.exports = connection;
+3115 -9
View File
File diff suppressed because it is too large Load Diff
+50 -29
View File
@@ -1,39 +1,60 @@
const connection = require('../conf/connection');
const express = require('express');
var app = express();
const express = require('express')
var app = express()
const sql = require('mssql')
async function traer() {
}
const query = require('./sqlQuery/queryBdProfesores')
app.get('/busca_profesor', async(req, res) => {
try {
let pass = "67NHA*Y";
// make sure that any items are correctly URL encoded in the connection string
await sql.connect(`mssql://USR_REDINVESTIGACION:${pass}@132.248.180.228/DB_ARES`)
const result = await sql.query `EXEC DB_ARES.dbo.SPD_CONSULTA_DATOS_PROFESORES_RED_INVESTIGACION;`
//console.log(result);
if(typeof result === 'undefined' || typeof result.recordsets === 'undefined' || typeof result.recordsets[0] === 'undefined'){
res.status(400).json({error: true, msj: 'error al hacer la consulta a sitemas', desc: result})
return;
}
let aux = [];
await result.recordsets[0].forEach(element => {
let r = aux.find(item => item.Rfc == element.Rfc);
//console.log(element + ' ' + r);
if (r == undefined)
aux.push(element);
});
res.status(200).json({ data: aux, error: false });
return;
} catch (err) {
// app.get('/busca_profesor', async(req, res) => {
// try {
// let pass = "67NHA*Y";
// // make sure that any items are correctly URL encoded in the connection string
// await sql.connect(`mssql://USR_REDINVESTIGACION:${pass}@132.248.180.228/DB_ARES`)
// const result = await sql.query `EXEC DB_ARES.dbo.SPD_CONSULTA_DATOS_PROFESORES_RED_INVESTIGACION;`
// //console.log(result);
// if(typeof result === 'undefined' || typeof result.recordsets === 'undefined' || typeof result.recordsets[0] === 'undefined'){
// res.status(400).json({error: true, msj: 'error al hacer la consulta a sitemas', desc: result})
// return;
// }
// let aux = [];
// await result.recordsets[0].forEach(element => {
// let r = aux.find(item => item.Rfc == element.Rfc);
// //console.log(element + ' ' + r);
// if (r == undefined)
// aux.push(element);
// });
// res.status(200).json({ data: aux, error: false });
// return;
// } catch (err) {
// console.log(err)
// res.status(400).json({error: true, msj: 'error al crear la consulta con sistemas', desc: err});
// return
// }
// })
app.get('/getProfesores', async(req, res) => {
try{
let getProfesoresQuery = `SELECT * FROM profesor;`
let getProfesoresResponse = await query(getProfesoresQuery).then(getProfesoresResponse =>{
console.log(getProfesoresResponse)
res.status(200).json({error: false, msj: 'Exito al obtener la respuesta', data: getProfesoresResponse})
return
}).catch(err =>{
console.log(err)
res.status(400).json({error: false, msj: 'Ocurrio un error al traer los datos del profesor', desc: err})
return
})
}
catch(err){
console.log(err)
res.status(400).json({error: true, msj: 'error al crear la consulta con sistemas', desc: err});
res.status(500).json({error: false, msj: 'Ocurrio un error al traer los datos del profesor', desc: err})
return
}
})
module.exports = app;
+17
View File
@@ -0,0 +1,17 @@
const queryBdProfesores = require('./sqlQuey/queryBdProfesores')
let getProfesores = async () =>{
return new Promise( async (resolve, reject) => {
try{
let getProfesoresQuery = `SELECT * FROM profesor;`
let getProfesoresResponse = await queryBdProfesores(getProfesoresQuery)
resolve(getProfesoresResponse)
}
catch(err){
console.log(err)
reject(err)
}
})
}
module.exports = getProfesores
+12
View File
@@ -0,0 +1,12 @@
const connection = require('../../conf/baseProfesoresDSC')
function query(consulta) {
return new Promise(function(resolve, reject) {
connection.query(`${consulta}`, (error, results, files) => {
if (error) reject(error);
resolve(results);
});
})
}
module.exports = query