-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathdboperations.js
60 lines (52 loc) · 1.82 KB
/
dboperations.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
var config = require('./dbconfig');
const sql = require('mysql'); //This is how we load libraries in Node.js
const sql1 = require('mssql');
async function getOrders(){
console.log(config.server);
try{
//let pool = await sql.connect(config);
//config.log("trying to connect with DB");
//let pool = await sql.connect(config);
//let products = await pool.request().query("SELECT * FROM wpx2_wc_order_stats where order_");
var orderId = 635;
//let products = await pool.request().input('input_parameter', sql.Int, orderId).query("SELECT * from wpx2_wc_order_stats where Id = @input_parameter");
//return products.recordsets;
let pool = sql.createConnection(config);
pool.connect();
pool.query(`SELECT * FROM giftsdmm_test`, function(err, rows, fields)
{
if (err) throw err;
console.log(rows[0]);
});
//console.dir(result)
}
catch (error){
console.log(error);
}
}
async function getOrder(orderId){
try{
let pool = await sql.connect(config);
//let product = await pool.request().input('input_parameter', sql.Int, orderId).query("SELECT * from TableName where Id = @input_parameter");
//return product.recordsets;
return;
}
catch (error){
console.log(error);
}
}
//async function addOrder(order){
// try{
// let pool = await sql.connect(config);
// let insertProduct = await pool.request()
// .input('Id', sql.Int, orderId).query("SELECT * from TableName where Id = @input_parameter");
// return products.recordsets;
// }
// catch (error){
// console.log(error);
// }
//}
module.exports ={
getOrders : getOrders,
getOrder : getOrder
}