Basic test for transactions

Author: jakewins

src/v1/internal/connector.js

@@ -219,6 +219,7 @@ class Connection {
   }
 
   _handleMessage( msg ) {
+  
     switch( msg.signature ) {
       case RECORD:
         this._currentObserver.onNext( msg.fields[0] );

src/v1/result.js

@@ -113,6 +113,4 @@ class Result {
   }
 }
 
-export default {
-  Result
-}
+export default Result

src/v1/session.js

@@ -18,7 +18,8 @@
  */
 
 import StreamObserver from './internal/stream-observer';
-import {Result} from './result';
+import Result from './result';
+import Transaction from './transaction';
 
 /**
   * A Session instance is used for handling the connection and
@@ -40,7 +41,7 @@ class Session {
   /**
    * Run Cypher statement
    * Could be called with a statement object i.e.: {statement: "MATCH ...", parameters: {param: 1}}
-   * or with the statement and parameters as separate arguments.
+   * or with the statem ent and parameters as separate arguments.
    * @param {mixed} statement - Cypher statement to execute
    * @param {Object} parameters - Map with parameters to use in statement
    * @return {Result} - New Result
@@ -57,6 +58,10 @@ class Session {
     return new Result( streamObserver, statement, parameters );
   }
 
+  beginTransaction() {
+    return new Transaction(this);
+  }
+ 
   /**
    * Close connection
    * @param {function()} cb - Function to be called on connection close

src/v1/transaction.js

@@ -0,0 +1,36 @@
+/**
+ * Copyright (c) 2002-2015 "Neo Technology,"
+ * Network Engine for Objects in Lund AB [http://neotechnology.com]
+ *
+ * This file is part of Neo4j.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+class Transaction {
+  constructor( session ) {
+    this._session = session;
+    this._session.run("BEGIN");
+  }
+
+  run(statement, parameters) {
+    return this._session.run(statement, parameters)
+  }
+
+  commit() {
+    return this._session.run("COMMIT");
+  }
+  
+}
+
+export default Transaction;

test/v1/transaction.test.js

@@ -0,0 +1,53 @@
+/**
+ * Copyright (c) 2002-2015 "Neo Technology,"
+ * Network Engine for Objects in Lund AB [http://neotechnology.com]
+ *
+ * This file is part of Neo4j.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+var neo4j = require("../../lib/v1");
+var StatementType = require("../../lib/v1/result-summary").statementType;
+
+fdescribe('transaction', function() {
+
+  var driver, session;
+
+  beforeEach(function(done) {
+    driver = neo4j.driver("bolt://localhost");
+    session = driver.session();
+
+    session.run("MATCH (n) DETACH DELETE n").then(done);
+  });
+
+  it('should handle simple transaction', function(done) {
+    // When
+    var tx = session.beginTransaction();
+    tx.run("CREATE (:TXNode1)");
+    tx.run("CREATE (:TXNode2)");
+    tx.commit()
+      .then(function() {
+        session.run("MATCH (t1:TXNode1), (t2:TXNode2) RETURN count(t1), count(t2)").then(function(records) {
+            
+            expect( records.length ).toBe( 1 );
+            expect( records[0]['count(t1)'].toInt() )
+              .toBe( 1 );
+            expect( records[0]['count(t2)'].toInt() )
+              .toBe( 1 );
+            done();
+          });
+      });
+  });
+
+});