-
Notifications
You must be signed in to change notification settings - Fork 3
/
consultaDB.js
95 lines (86 loc) · 2.94 KB
/
consultaDB.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
const oracledb = require('oracledb');
oracledb.outFormat = oracledb.OUT_FORMAT_OBJECT;
try {
oracledb.initOracleClient({ libDir: 'C:\\oracle\\instantclient_12_2' });
} catch (err) {
console.error('Oracle Instant Client não encontrado!');
console.error(err);
process.exit(1);
}
//FUNÇÃO DE CONSULTA AO BANCO DE DADOS ORACLE UTILIZANDO CALLBACK
function getUsuario(query, params, callback) {
oracledb.getConnection({
user: "askint",
password: 'askint',
connectString: "bcprod-scan.ASKBCLDA.LOCAL/bcprod"
},
function (err, connection) {
if (err) {
console.log(err.message);
return callback(err);
}
connection.execute(
query, params,
function (err, result) {
if (err) {
console.log(err.message);
return callback(err);
}
if (result.rows.length > 0) {
return callback(null, result.rows);
} else {
return callback(null, false);
}
}
);
}
);
}
exports.getUsuario = getUsuario;
// CHAMADA DA FUNÇÃO getUsuario
var query = "select * from agenda where re=:id";
getUsuario(query, [5594], function (err, result) {
if (!err) {
if (result === false) {
console.log("não encontrou")
} else {
console.log(result[0].NOME) //chamando um item do objeto
console.log(result); // chamado o objeto completo
}
}
});
//FUNÇÃO DE CONSULTA AO BANCO DE DADOS ORACLE UTILIZANDO PROMISSE
function getFuncionario(id) {
return new Promise(async function (resolve, reject) {
let connection;
try {
connection = await oracledb.getConnection({
user: "askint",
password: 'askint',
connectString: "bcprod-scan.ASKBCLDA.LOCAL/bcprod"
});
const result = await connection.execute(`SELECT * FROM agenda WHERE re = :id`, [id]);
if (result.rows.length > 0) {
console.log("Result is:", result.rows);
var string = JSON.stringify(result.rows);
var dados = JSON.parse(string);
console.log(dados[0].NOME);
return dados
} else {
console.log("Não foram encontrados registros ")
}
} catch (err) {
reject(err);
} finally {
if (connection) {
try {
await connection.release();
} catch (e) {
console.error(e);
}
}
}
});
}
getFuncionario(6903); // CHAMADA DA FUNÇÃO
exports.getFuncionario = getFuncionario;