/
db-conn.js
51 lines (44 loc) · 1.23 KB
/
db-conn.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
'use strict';
const xsenv = require('@sap/xsenv');
const createTable =
'CREATE TABLE IF NOT EXISTS Users \
( \
id serial, \
name varchar(100), \
color varchar(100), \
material varchar(100), \
PRIMARY KEY (id) \
)';
// const dropTable = 'DROP TABLE Users'; // eslint-disable-line no-unused-vars
// const insertRow = "INSERT INTO users(name,color,material) values('SpongeBob','yellow','sponge')"; // eslint-disable-line no-unused-vars
function returnUriToDB() {
var uri = '';
if (process.env.VCAP_SERVICES) {
// running in cloud
uri = xsenv.cfServiceCredentials('sapcpcfhw-db').uri;
} else {
console.log('running locally is not supported');
}
return uri;
}
function getDB(cb) {
let pgp = require('pg-promise')({
// Initialization Options
});
var db = pgp(returnUriToDB());
let sql = createTable;
db.query(sql)
.then(function () {
console.log('database initialized');
cb(null, db);
return;
})
.catch((err) => {
console.log(err);
cb(err, null);
return;
});
}
module.exports = {
getDB: getDB
};