joeferner
diff --git a/‎lib/nodeJavaBridge.js‎
Lines changed: 6 additions & 6 deletions b/‎lib/nodeJavaBridge.js‎
Lines changed: 6 additions & 6 deletions
diff --git a/‎src/java.cpp‎
Lines changed: 1 addition & 0 deletions b/‎src/java.cpp‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎testIntegration/jdbc/enduranceTest.js‎
Lines changed: 40 additions & 0 deletions b/‎testIntegration/jdbc/enduranceTest.js‎
Lines changed: 40 additions & 0 deletions
diff --git a/‎testIntegration/jdbc/mysql-connector-java-5.1.22-bin.jar‎
813 KB b/‎testIntegration/jdbc/mysql-connector-java-5.1.22-bin.jar‎
813 KB
diff --git a/‎testIntegration/jdbc/sqljdbc.jar‎
550 KB b/‎testIntegration/jdbc/sqljdbc.jar‎
550 KB
diff --git a/‎testIntegration/jdbc/sqljdbc4.jar‎
571 KB b/‎testIntegration/jdbc/sqljdbc4.jar‎
571 KB
@@ -5,16 +5,16 @@ var binaryPath = path.resolve(path.join(__dirname, "../build/Release/nodejavabri
 var bindings = require(binaryPath);
 
 var java = module.exports = new bindings.Java();
-java.classpath.push(__dirname + "/../commons-lang3-node-java.jar");
-java.classpath.push(__dirname + "/../src-java");
+java.classpath.push(path.resolve(__dirname, "../commons-lang3-node-java.jar"));
+java.classpath.push(path.resolve(__dirname, __dirname, "../src-java"));
 java.nativeBindingLocation = binaryPath;
 
 var MODIFIER_PUBLIC = 1;
 var MODIFIER_STATIC = 8;
 
-java.import = function (name) {
+java.import = function(name) {
   var clazz = java.findClassSync(name); // TODO: change to Class.forName when classloader issue is resolved.
-  var result = function () {
+  var result = function() {
     var args = [name];
     for (var i = 0; i < arguments.length; i++) {
       args.push(arguments[i]);
@@ -29,10 +29,10 @@ java.import = function (name) {
     if (((fields[i].getModifiersSync() & MODIFIER_PUBLIC) === MODIFIER_PUBLIC)
       && ((fields[i].getModifiersSync() & MODIFIER_STATIC) === MODIFIER_STATIC)) {
       var fieldName = fields[i].getNameSync();
-      result.__defineGetter__(fieldName, function (name, fieldName) {
+      result.__defineGetter__(fieldName, function(name, fieldName) {
         return java.getStaticFieldValue(name, fieldName);
       }.bind(this, name, fieldName));
-      result.__defineSetter__(fieldName, function (name, fieldName, val) {
+      result.__defineSetter__(fieldName, function(name, fieldName, val) {
         java.setStaticFieldValue(name, fieldName, val);
       }.bind(this, name, fieldName));
     }
 
@@ -131,6 +131,7 @@ v8::Handle<v8::Value> Java::createJVM(JavaVM** jvm, JNIEnv** env) {
   // create vm options
   int vmOptionsCount = optionsArray->Length() + 1;
   JavaVMOption* vmOptions = new JavaVMOption[vmOptionsCount];
+  //printf("classPath: %s\n", classPath.str().c_str());
   vmOptions[0].optionString = strdup(classPath.str().c_str());
   for(uint32_t i=0; i<optionsArray->Length(); i++) {
     v8::Local<v8::Value> arrayItemValue = optionsArray->Get(i);
 
@@ -0,0 +1,40 @@
+'use strict';
+
+//var dbServerName = '';
+//var dbPort = 1433;
+//var dbName = '';
+//var dbUserId = '';
+//var dbPassword = '';
+//var dbConnectString = 'jdbc:sqlserver://' + dbServerName + ':' + dbPort + ';databaseName=' + dbName + ';selectMethod=direct;responseBuffering=adaptive;packetSize=0;programName=nodeJavaTest;hostProcess=nodeJavaTest;sendStringParametersAsUnicode=false;';
+//var dbConnectionClass = 'com.microsoft.sqlserver.jdbc.SQLServerDriver';
+
+var dbUserId = 'test';
+var dbPassword = 'test';
+var dbConnectString = "jdbc:mysql://localhost/test";
+var dbConnectionClass = 'com.mysql.jdbc.Driver';
+
+var path = require('path');
+var java = require('../../');
+java.classpath.push(path.join(__dirname, 'sqljdbc4.jar'));
+java.classpath.push(path.join(__dirname, 'mysql-connector-java-5.1.22-bin.jar'));
+var DriverManager = java.import('java.sql.DriverManager');
+
+var loopCount = 0;
+while (true) {
+  console.log('loopCount:', loopCount);
+  java.findClassSync(dbConnectionClass);
+  var conn = DriverManager.getConnectionSync(dbConnectString, dbUserId, dbPassword);
+  console.log("connected");
+  var statement = conn.createStatementSync();
+  var queryString = "select * from Person";
+  var rs = statement.executeQuerySync(queryString);
+  var metaData = rs.getMetaDataSync();
+  var columnCount = metaData.getColumnCountSync();
+  while (rs.nextSync()) {
+    for(var i=1; i<=columnCount; i++) {
+      console.log(rs.getObjectSync(i));
+    }
+  }
+  conn.closeSync();
+  loopCount++;
+}