initial commit

Author: brianc

.gitignore

@@ -0,0 +1 @@
+node_modules

index.js

@@ -0,0 +1,26 @@
+//you need to pass in the pg module
+//to have this module initialize the type parsers
+
+//technically you can just have this globally initialize
+//when its required but I think this is more explicit & cleaner.
+
+var pgParseFloats = module.exports = function(pg) {
+  //the type & OID match for the float types
+  var types = {
+    FLOAT4: 700,
+    FLOAT8: 701,
+    NUMERIC: 1700,
+    FLOAT4_ARRAY: 1021,
+    FLOAT8_ARRAY: 1022,
+    NUMERIC_ARRAY: 1231
+  };
+  //just use the built-in V8 parseFloat implementation
+  pg.types.setTypeParser(types.FLOAT4, 'text', parseFloat);
+  pg.types.setTypeParser(types.FLOAT8, 'text', parseFloat);
+  pg.types.setTypeParser(types.NUMERIC, 'text', parseFloat);
+
+  //TODO array parsers
+};
+
+//you can find the OID -> TYPE map like this:
+//client.query('select oid, typname from pg_type where typtype = \'b\' order by oid')

package.json

@@ -0,0 +1,28 @@
+{
+  "name": "pg-parse-float",
+  "version": "0.0.1",
+  "description": "restore parseFloat behavior to node-postgres (pg) - can be used as a reference for implementing other type parsing addons",
+  "main": "index.js",
+  "scripts": {
+    "test": "node test.js"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git://github.com/brianc/node-pg-parse-float"
+  },
+  "keywords": [
+    "postgres",
+    "float",
+    "parsing",
+    "type",
+    "conversion"
+  ],
+  "author": "Brian M. Carlson",
+  "license": "MIT",
+  "devDependencies": {
+    "async": "~0.2.7",
+    "okay": "~0.2.0",
+    "pg": "~1.0.0",
+    "mocha": "~1.9.0"
+  }
+}

test.js

@@ -0,0 +1,74 @@
+var timeoutSeconds = 5;
+var tid = setTimeout(function() {
+  throw new Error('Tests did not finish within ' + timeoutSeconds + ' seconds');
+}, timeoutSeconds * 1000);
+
+var assert = require('assert');
+var async = require('async');
+var ok = require('okay');
+var pg = require('pg');
+
+var setup = function() {
+  before(function(done) {
+    this.client = new pg.Client();
+    this.client.connect();
+    var client = this.client;
+    client.query('CREATE TEMP TABLE floatz(small FLOAT4, big FLOAT8, num NUMERIC)', ok(function(result) {
+      client.query('INSERT INTO floatz(small, big, num) VALUES($1, $2, $3)', [1.1, '2.2', 3.3], ok(function(result) {
+        done();
+      }));
+    }));
+  });
+};
+
+var teardown = function() {
+  after(function(done) {
+    this.client.on('end', done);
+    this.client.end();
+  });
+};
+
+describe('existing (string) functionality', function() {
+  setup();
+
+  it('returns floats as strings', function(done) {
+    var client = this.client;
+    client.query('SELECT * FROM floatz', ok(function(result) {
+      assert(result, 'should have returned result');
+      assert(result.rows, 'result should have rows');
+      assert.equal(result.rows.length, 1, 'should have 1 row but returned ' + result.rows.length);
+      var row = result.rows.pop();
+      assert.strictEqual(row.small, '1.1');
+      assert.strictEqual(row.big, '2.2');
+      assert.strictEqual(row.num, '3.3');
+      done();
+    }));
+  });
+
+  teardown();
+});
+
+describe('new (parseFloat) functionality', function() {
+  before(function() {
+    //load the pg-parse-float module
+    require(__dirname)(pg);
+  });
+
+  setup();
+
+  it('returns floats as floats', function(done) {
+    var client = this.client;
+    client.query('SELECT * FROM floatz', ok(function(result) {
+      assert(result, 'should have returned result');
+      assert(result.rows, 'result should have rows');
+      assert.equal(result.rows.length, 1, 'should have 1 row but returned ' + result.rows.length);
+      var row = result.rows.pop();
+      assert.strictEqual(row.small, 1.1);
+      assert.strictEqual(row.big, 2.2);
+      assert.strictEqual(row.num, 3.3);
+      done();
+    }));
+  });
+
+  teardown();
+});