aerospike - npm Package Compare versions

Comparing version 1.0.30 to 1.0.31

aerospike-1.0.31.tgz

examples/scan.js

		@@ -134,3 +134,4 @@ /*******************************************************************************

		var query = client.query(argv.namespace, argv.set );
		var options = { nobins:false, concurrent: true, select: ['i', 's'] }
		var query = client.query(argv.namespace, argv.set, options );

		@@ -156,6 +157,1 @@ var stream = query.execute();
		});
		/*******************************************************************************
		*
		* Perform the operation
		*
		******************************************************************************/

lib/aerospike.js

		@@ -149,3 +149,2 @@ var as = require('../build/Release/aerospike.node')
		queryObj.setQueryType(as.queryType.QUERYUDF);
		return null;
		}
		@@ -168,3 +167,3 @@ else if(queryObj.hasAggregation)
		{
		query.setQueryType(as.queryType.SCANUDF);
		queryObj.setQueryType(as.queryType.SCANUDF);
		}
		@@ -171,0 +170,0 @@ else if(queryObj.hasAggregation)

package.json

		{
		"name" : "aerospike",
		"version" : "1.0.30",
		"version" : "1.0.31",
		"description" : "Aerospike Client Library",
		@@ -5,0 +5,0 @@ "tags" : [ "aerospike", "database", "nosql" ],

test/put.js

		@@ -491,3 +491,41 @@ /*******************************************************************************
		});
		it('should check generation and then update record only if generation is equal (CAS)', function(done) {

		// generators
		var kgen = keygen.integer(options.namespace, options.set);
		var mgen = metagen.constant({ttl: 1000});
		var rgen = recgen.record({i: valgen.integer(), s: valgen.string()});

		// values
		var key = kgen();
		var meta = mgen(key);
		var record = rgen(key, meta);

		// write the record then check
		client.put(key, record, meta, function(err, key) {
		expect(err).to.be.ok();
		expect(err.code).to.equal(status.AEROSPIKE_OK);
		// check the content of the record
		client.get(key, function(err, record, metadata, key) {
		expect(err).to.be.ok();
		expect(err.code).to.equal(status.AEROSPIKE_OK);
		var mgen = metagen.constant({gen:1})
		var meta = mgen(key);
		var writePolicy = { gen: aerospike.policy.gen.EQ};
		client.put(key, record, meta, writePolicy, function(err, key){
		expect(err).to.be.ok();
		expect(err.code).to.equal(status.AEROSPIKE_OK);
		client.get(key, function( err, record, metadata, key) {
		expect(err).to.be.ok();
		expect(err.code).to.equal(status.AEROSPIKE_OK);
		expect(metadata.gen).to.equal(2);
		client.remove(key, function(err, key){
		done();
		});
		});
		});
		});
		});
		});

		});

test/scan.js

		@@ -103,3 +103,4 @@ /*******************************************************************************
		it('should query all the records', function(done) {


		this.timeout(5000);
		// counters
		@@ -130,2 +131,4 @@ var total = 100;
		it('should query and select no bins', function(done) {

		this.timeout(5000);
		var total = 100;
		@@ -153,2 +156,4 @@ var count = 0;
		it('should query and select only few bins in the record', function(done) {

		this.timeout(5000);
		var total = 99;
		@@ -176,3 +181,3 @@ var count = 0;
		it('should do a scan background and check for the status of scan job ', function(done) {
		var args = { scanUDF: {module: 'scan', funcname: 'updateRecord'}}
		var args = { UDF: {module: 'scan', funcname: 'updateRecord'}}
		var scanBackground = client.query( options.namespace, options.set, args);
		@@ -179,0 +184,0 @@

aerospike-1.0.30.tgz

src/main/client/query.cc

Sorry, the diff of this file is not supported yet

src/main/util/conversions.cc

Sorry, the diff of this file is not supported yet

New alerts