test143.js

if(typeof exports === 'object') {
	var assert = require("assert");
	var alasql = require('..');
} else {
	__dirname = '.';
};

describe('Test 143 streamfn', function() {

	it("1. Create database", function(done){
		alasql('CREATE DATABASE test143; use test143');
		done();
	});

	it("3. INNER JOIN on stream", function(done){

		test143(true);
		alasql.databases[alasql.useid].dbversion++
		test143(false);
		alasql.databases[alasql.useid].dbversion++
//		test143(true);
//		test143(false);
//		test143(true);

//console.log(res.length);
		done();
	});




	it("99. Drop database", function(done){
		alasql('DROP DATABASE test143');
		done();
	});
});

		function test143(dontcache) {
			var nc1=0,nc2 = 0, nc3 = 0;
			
			var myfn = function(i) {
				nc1++;
				if(i>=100) return;
				return {a:i, b:i+2};
			};
			myfn.dontcache = dontcache;


			var myfn2 = function(i) {
				nc2++;
				if(i>=100) return;
				for(var k=0;k<10;k++) {
					Math.random();
				}
				return {a:(i%25)+1, c:(i+1)*10};
			};
			myfn2.dontcache = dontcache;
		//		myfn3.dontcache = true;
				var tm = Date.now();
		//if(true) {
				var res = alasql('select q.a, q.b, t.a as ta, t.c from ? q INNER join ? t using a',[myfn,myfn2]);
				nc3 += res.length;

		//console.table(res);
//		console.log('INNER',res.length);
//if(false) {
				var res = alasql('select q.a, q.b, t.a as ta, t.c from ? q SEMI join ? t using a',[myfn,myfn2]);
				nc3 += res.length;
		//console.table(res);
		//console.log('SEMI', res.length);
		//}
				var res = alasql('select q.a, q.b, t.a as ta, t.c from ? q ANTI join ? t using a',[myfn,myfn2]);
				nc3 += res.length;
		//console.table(res);
		//console.log('ANTI', res.length);

		//if(true) {
				var res = alasql('select q.a, q.b, t.a as ta, t.c from ? q LEFT join ? t using a',[myfn,myfn2]);
				nc3 += res.length;
		//console.table(res);
		//console.log('LEFT',res.length);
		//		assert(res.length == 13013);

				var res = alasql('select q.a, q.b, t.a as ta, t.c from ? q RIGHT join ? t using a',[myfn,myfn2]);
				nc3 += res.length;
		//console.table(res);
		//console.log('RIGHT',res.length);
				//assert(res.length == 13039);

				var res = alasql('select q.a, q.b, t.a as ta, t.c from ? q OUTER join ? t using a',[myfn,myfn2]);
				nc3 += res.length;
		//console.table(res);
		//console.log('OUTER',res.length);
		//		assert(res.length == 13039);
//}
		//}
				// var res = alasql('select q.a, q.b, t.c from ? q OUTER join ? t using a '+
				// 	'EXCEPT select q.a, q.b, t.c from ? q LEFT join ? t using a',[myfn,myfn2,myfn,myfn2]);
				// console.log(res);



	//		console.log(res);
			tm = Date.now() - tm;
//			console.log(tm);
//			console.log(dontcache, nc1,nc2, nc3, tm/nc2);
		}