initial commit

Author: wink

LICENSE

@@ -0,0 +1,22 @@
+ Copyright (c) 2010 Lee Smith <[email protected]>
+
+ Permission is hereby granted, free of charge, to any person
+ obtaining a copy of this software and associated documentation
+ files (the "Software"), to deal in the Software without
+ restriction, including without limitation the rights to use,
+ copy, modify, merge, publish, distribute, sublicense, and/or sell
+ copies of the Software, and to permit persons to whom the
+ Software is furnished to do so, subject to the following
+ conditions:
+
+ The above copyright notice and this permission notice shall be
+ included in all copies or substantial portions of the Software.
+
+ THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+ EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
+ OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+ NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
+ HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
+ WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
+ OTHER DEALINGS IN THE SOFTWARE.

README.md

@@ -0,0 +1,56 @@
+NAME
+----
+
+node-odbc - An asynchronous Node interface to unixodbc and it's supported drivers
+
+SYNOPSYS
+--------
+
+	var sys     = require("sys");
+	var odbc = require("odbc");
+
+	var db = new odbc.Database();
+	db.open("DRIVER={FreeTDS};SERVER=host;UID=user;PWD=password;DATABASE=dbname", function(err)
+	{
+		db.query("select * from table", function(err, rows)
+		{
+			sys.debug(sys.inspect(rows));
+			db.close(function(){});
+		}
+	});
+
+
+DESCRIPTION
+-----------
+
+unixODBC binding to node. Needs a properly configured odbc(inst).ini.  Tested locally using the FreeTDS and Postgres drivers.
+
+Installation
+------------
+
+- Make sure you have unixODBC installed and the drivers configured.
+- node-waf configure build
+
+BUGS
+----
+
+None known, but there might be one ;).
+
+
+TODO
+----
+
+- Not complete, supports connection management and querying.
+- Better (any?) error handling.
+- Tests
+- SQLGetData needs to support retrieving multiple chunks and concatenation in the case of large	column values
+
+ACKNOWLEDGEMENTS
+----------------
+
+- orlandov's node-sqlite binding was the framework I used to figure out using eio's thread pool to handle blocking calls since non blocking odbc doesn't seem to appear until 3.8.
+
+AUTHOR
+------
+
+Lee Smith ([email protected])

build.sh

@@ -0,0 +1,3 @@
+#!/bin/bash
+rm -rf build
+node-waf configure build

odbc.js

@@ -0,0 +1,75 @@
+/*
+  Copyright (c) 2010, Lee Smith <[email protected]>
+
+  Permission to use, copy, modify, and/or distribute this software for any
+  purpose with or without fee is hereby granted, provided that the above
+  copyright notice and this permission notice appear in all copies.
+
+  THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
+  WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
+  MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
+  ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
+  WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
+  ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
+  OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
+*/
+
+var sys = require("sys");
+var sqlite = require("./odbc_bindings");
+
+var Database = exports.Database = function () {
+    var self = this;
+    var db = new sqlite.Database();
+
+    db.__proto__ = Database.prototype;
+
+    db.addListener("ready", function () {
+        db.maybeDispatchQuery();
+    });
+
+    db.addListener("result", function () {
+        process.assert(db.currentQuery);
+            var callback = db.currentQuery[1];
+        var args = Array.prototype.slice.call(db.currentQuery[2]);
+        args.shift();
+        args.shift();
+
+        if(arguments[0])
+        {
+            arguments[0].query = db.currentQuery[0];
+        }
+
+        db.currentQuery = null;
+        if (callback) {
+            var newArgs = Array.prototype.slice.call(arguments);
+
+            for(var i = 0; i < args.length; i++) {
+                newArgs.push(args[i]);
+            }
+
+            callback.apply(db, newArgs);
+        }
+        db.maybeDispatchQuery();
+    });
+
+    return db;
+};
+
+Database.prototype = {
+    __proto__: sqlite.Database.prototype,
+    constructor: Database,
+};
+
+Database.prototype.maybeDispatchQuery = function () {
+    if (!this._queries) return;
+    if (!this.currentQuery && this._queries.length > 0) {
+        this.currentQuery = this._queries.shift();
+        this.dispatchQuery(this.currentQuery[0]);
+    }
+};
+
+Database.prototype.query = function(sql, callback) {
+    this._queries = this._queries || [];
+    this._queries.push([sql, callback, arguments]);
+    this.maybeDispatchQuery();
+};

odbc_bindings.node

@@ -0,0 +1 @@
+build/default/odbc_bindings.node