npm jdbc example

var JDBC = require('jdbc');
var jinst = require('jdbc/lib/jinst');
var async = require('async');

if (!jinst.isJvmCreated()) {
  jinst.addOption("-Xrs");
  jinst.setupClasspath(['./jar/terajdbc4.jar',
                        './jar/tdgssconfig.jar']);
}

var config = {
    libpath: './jar/terajdbc4.jar',
    libs: ['./jar/tdgssconfig.jar'],
    drivername: 'com.teradata.jdbc.TeraDriver',
    url: 'jdbc:teradata://teradata.com/charset=UTF8,DBS_PORT=1025,user=user,password=pass',
    // optionally
    //user: 'user',
    //password: 'pass',
};

var db = new JDBC(config);

db.reserve(function(err, connObj)
{
    if (connObj)
    {
      console.log("Using connection: " + connObj.uuid);
      var conn = connObj.conn;

      // Query the database.
      asyncjs.series([
        function(callback)
        {
          // Select statement example.
          conn.createStatement(function(err, statement)
          {
            if (err)
            {
              callback(err);
            }
            else
            {
              statement.setFetchSize(100, function(err)
              {
                if (err)
                {
                  callback(err);
                }
                else
                {
                    //Execute a query
                    statement.executeQuery("SELECT COUNT(*) FROM rtl_amr.iaCustomerViewDaily;",
                      function(err, resultset)
                      {
                        if (err)
                        {
                          callback(err)
                        }
                        else
                        {
                          resultset.toObjArray(function(err, results)
                          {
                            //Printing number of records
                            if (results.length > 0)
                            {
                              console.log("Record count: " + results.length);
                              console.log(results);
                            }
                            callback(null, resultset);
                          });
                        }
                    });
                }
              });
            }
          });
        },
      ], function(err, results)
      {
        // Results can also be processed here.
        // Release the connection back to the pool.
        db.release(connObj, function(err)
        {
          if (err)
          {
            console.log(err.message);
          }
        });
      });
    }
});