vbatts/nodejs-ex
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

update server.js

Browse source
This commit is contained in:
Fedora Cloud User 2015-05-25 07:57:49 +00:00
parent ac89e893ca
commit d45855dd95
1 changed files with 24 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

28
server.js
View file

@ -1,14 +1,31 @@
#!/usr/bin/env node
var util = require('util');
var postgresql_user = process.env.POSTGRESQL_USER || process.env.postgresql_user || "user";
var postgresql_pass = process.env.POSTGRESQL_PASSWORD || process.env.postgresql_password || "pass";
var postgresql_ip = process.env.POSTGRESQL_IP || process.env.postgresql_ip || "localhost";
var postgresql_port = process.env.POSTGRESQL_PORT || process.env.postgresql_port || 5432;
var postgresql_db = process.env.POSTGRESQL_DATABASE || process.env.postgresql_database || "db";
if (postgresql_user == null || postgresql_pass == null || postgresql_ip == null || postgresql_db == null){
console.log("Please check you have set the postgresql user/pass/db in nodejs-example container");
return
}
var pg = require("pg");
var conString = "pg://user:pass@localhost:5432/db";
//var conString = "pg://user:pass@localhost:5432/db";
var conString = util.format('pg://%s:%s@%s:%d/%s', postgresql_user,postgresql_pass,postgresql_ip,postgresql_port,postgresql_db);
console.log("conString is %s",conString);
var client = new pg.Client(conString);
client.connect();
client.query("CREATE TABLE IF NOT EXISTS cartridge(type varchar(64), version varchar(64))");
//client.query("INSERT INTO cartridge(type, version) values($1, $2)", ['nodejs', '0.10']);
//client.query("INSERT INTO cartridge(type, version) values($1, $2)", ['postgresql', '9.2']);
client.query("INSERT INTO cartridge(type, version) SELECT $1, $2 WHERE NOT EXISTS (SELECT type FROM cartridge WHERE type = $3)",['nodejs', '0.10','nodejs']);
var query = client.query("INSERT INTO cartridge(type, version) SELECT $1, $2 WHERE NOT EXISTS (SELECT type FROM cartridge WHERE type = $3)",['postgresql', '9.2','postgresql']);
query.on('end', function() {
client.end();
});
var http = require('http');
var url = require('url');
@ -24,14 +41,15 @@ var server = http.createServer(function (req, res) {
res.writeHead(200, {'Content-Type': 'text/plain'});
var myclient = new pg.Client(conString);
myclient.connect();
var query = myclient.query("SELECT type, version FROM cartridge ORDER BY type, version");
query.on("row", function (row, result) {
var myquery = myclient.query("SELECT type, version FROM cartridge ORDER BY type, version");
myquery.on("row", function (row, result) {
result.addRow(row);
//console.log(row)
});
query.on("end", function (result) {
myquery.on("end", function (result) {
myclient.end();
//console.log("end query");
res.write("Hello, Get data from postgreql : " + "\n");
res.write(JSON.stringify(result.rows, null, " ") + "\n");
res.end();
});