add

Author: Aries Yuwono

test-complete/nodejs-documents-transaction-withstate.js

@@ -0,0 +1,113 @@
+/*
+ * Copyright 2014-2015 MarkLogic Corporation
+ *
+ * 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 should = require('should');
+
+var testconfig = require('../etc/test-config-qa.js');
+
+var marklogic = require('../');
+var q = marklogic.queryBuilder;
+var db = marklogic.createDatabaseClient(testconfig.restWriterConnection);
+
+describe('Transaction with state test', function() {
+  
+  var tid = 0;
+  var tid2 = 0;
+  var hostId = 0;
+
+  it('should do transaction with state', function(done) {
+    db.transactions.open({transactionName: 'stateTransaction', timeLimit: 30, withState: true})
+    .result(function(response) {
+      //console.log(JSON.stringify(response, null, 2));
+      response.should.have.property('cookies');
+      var cookie = response.cookies[0];
+      hostId = cookie.substring(cookie.indexOf('=') + 1);
+      tid = response.txid;
+      return db.documents.write({
+        txid: tid,
+        uri: '/test/state/transaction/doc1.json',
+        contentType: 'application/json',
+        content: {firstname: 'John', lastname: 'Doe', txKey: tid}
+      }).result();
+    })
+    .then(function(response) {
+      //console.log(JSON.stringify(response, null, 2));
+      response.documents[0].uri.should.equal('/test/state/transaction/doc1.json');
+      return db.transactions.read(tid).result();
+    })
+    .then(function(response) {
+      //console.log(JSON.stringify(response, null, 2));
+      response['transaction-status']['host']['host-id'].should.equal(hostId);
+      response['transaction-status']['transaction-id'].should.equal(tid);
+      response['transaction-status']['time-limit'].should.equal('30');
+      return db.transactions.rollback(tid).result();
+    })
+    .then(function(response) {
+      //console.log(JSON.stringify(response, null, 2));
+      response.finished.should.equal('rollback');
+      return db.documents.read({uris: '/test/state/transaction/doc1.json'}).result(); 
+    })
+    .then(function(response) {
+      //console.log(JSON.stringify(response, null, 2));
+      response.length.should.equal(0);
+      return db.transactions.open({transactionName: 'stateTransaction2', timeLimit: 60, withState: true}).result();
+    })
+    .then(function(response) {
+      //console.log(JSON.stringify(response, null, 2));
+      response.should.have.property('cookies');
+      var cookie = response.cookies[0];
+      hostId = cookie.substring(cookie.indexOf('=') + 1);
+      tid2 = response.txid;
+      return db.documents.write({
+        txid: tid2,
+        uri: '/test/state/transaction/doc1.json',
+        contentType: 'application/json',
+        content: {firstname: 'John', lastname: 'Adams', txKey: tid2}
+      }).result();
+    })
+    .then(function(response) {
+      //console.log(JSON.stringify(response, null, 2));
+      return db.transactions.read(tid2).result();
+    })
+    .then(function(response) {
+      //console.log(JSON.stringify(response, null, 2));
+      response['transaction-status']['host']['host-id'].should.equal(hostId);
+      response['transaction-status']['transaction-name'].should.equal('stateTransaction2');
+      response['transaction-status']['time-limit'].should.equal('60');
+      return db.transactions.commit(tid2).result();
+    })
+    .then(function(response) {
+      //console.log(JSON.stringify(response, null, 2));
+      response.finished.should.equal('commit');
+      return db.documents.read({uris: '/test/state/transaction/doc1.json'}).result(); 
+    })
+    .then(function(response) {
+      //console.log(JSON.stringify(response, null, 2));
+      response[0].content.lastname.should.equal('Adams');
+      response[0].content.txKey.should.equal(tid2);
+      return db.documents.remove('/test/state/transaction/doc1.json').result(); 
+    })
+    .then(function(response) {
+      response.removed.should.equal(true);
+      //console.log(JSON.stringify(response, null, 2));
+      done();
+    }, done);
+    /*.catch(function(error) {
+      console.log(error);
+      done();
+    }, done);*/
+  });
+});
+