Skip to content

Instantly share code, notes, and snippets.

@niftydevelopment
Created January 22, 2018 15:54
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save niftydevelopment/736598b2a8ec5daebfa6aa07f9a9696a to your computer and use it in GitHub Desktop.
Save niftydevelopment/736598b2a8ec5daebfa6aa07f9a9696a to your computer and use it in GitHub Desktop.
var Promise = require('promise');
var pgp = require('pg-promise')({
noWarnings: true,
capSQL: true // capitalize all generated SQL
});
var fs = require('fs');
let readTableData = require('./../disk/readTableData');
var confString = JSON.parse(fs.readFileSync('./db.config.json', 'utf8'));
exports.load = (descriptor, resource) => {
const db = pgp(confString.dbConnection);
return new Promise((resolve, reject) => {
readTableData.read().then(tableData => {
});
db.task(function* (t) {
//let t = confString.schema + "." + dbtable
//db.none('INSERT INTO ' + t + '(info) VALUES($1)', [user]);
let dbtable = resource.tables[0];
var q = pgp.helpers.insert(data, Object.keys(data[0]), confString.schema + "." + dbtable);
q = q.replace('\"' + confString.schema + "." + dbtable + '\"', confString.schema + "." + dbtable);
console.log('----------------->', dbtable);
return yield db.none(q);
/*
connection.none(q).then((r) => {
resolve(r);
}).catch((e) => {
reject(e);
});
*/
//let user = yield t.none('SELECT * FROM atlas.kontrollforetag');
//return yield t.one('SELECT * FROM atlas.faltarende');
}).then(events => {
resolve(null);
}).catch(error => {
reject(error);
});
});
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment