tst1602.mal

一个内存数据库的源代码这是服务器端还有客户端

	int_1M:= bat.new(:oid,:lng,1000000);

	i:= 1000000:lng;
barrier	sj_a:= true;
	i:= i-1;
	uj_a := i;
	vj_a := calc.>=(uj_a,0);
barrier	tj_a:= vj_a;
	xj_a := bat.insert(int_1M,nil:oid,i);
redo	sj_a;
exit	tj_a;
exit	sj_a;

        t := alarm.time();
        ug_a := bat.reverse(int_1M);
        vg_a := algebra.join(int_1M,ug_a);
        wg_a := aggr.count(vg_a);
        xg_a := io.printf("#count %d = ",wg_a);
        x:= alarm.time();
        yg_a := calc.-(x,t);
	   ah_a := io.printf("%d ms\n",yg_a);


        t := alarm.time();
        ug_a := bat.reverse(int_1M);
        vg_a := algebra.join(int_1M,ug_a);
        wg_a := aggr.count(vg_a);
        xg_a := io.printf("#count %d = ",wg_a);
        x:= alarm.time();
        yg_a := calc.-(x,t);
		ah_a := io.printf("%d ms\n",yg_a);

        t := alarm.time();
        ug_a := bat.reverse(int_1M);
        vg_a := algebra.join(int_1M,ug_a);
        wg_a := aggr.count(vg_a);
        xg_a := io.printf("#count %d = ",wg_a);
        x:= alarm.time();
        yg_a := calc.-(x,t);
        ah_a := io.printf("%d ms\n",yg_a);


        t := alarm.time();
        ug_a := bat.reverse(int_1M);
        vg_a := algebra.join(int_1M,ug_a);
        wg_a := aggr.count(vg_a);
        xg_a := io.printf("#count %d = ",wg_a);
        x:= alarm.time();
        yg_a := calc.-(x,t);
        ah_a := io.printf("%d ms\n",yg_a);

	M2:= bat.new(:lng,:lng,1000000);
	i:= 1000000:lng;
barrier	sj_b:= true;
	i:= i-1;
	uj_b := i;
	vj_b := calc.>=(uj_b,0);
barrier	tj_b:= vj_b;
	xj_b := bat.insert(M2,i,i);
redo	sj_b;
exit	tj_b;
exit	sj_b;

        t := alarm.time();
        ug_b := bat.reverse(M2);
        vg_b := algebra.join(M2,ug_b);
        wg_b := aggr.count(vg_b);
        xg_b := io.printf("#count %d = ",wg_b);
        x:= alarm.time();
        yg_b := calc.-(x,t);
       ah_b := io.printf("%d ms\n",yg_b);


        t := alarm.time();
        ug_b := bat.reverse(M2);
        vg_b := algebra.join(M2,ug_b);
        wg_b := aggr.count(vg_b);
        xg_b := io.printf("#count %d = ",wg_b);
        x:= alarm.time();
        yg_b := calc.-(x,t);
       ah_b := io.printf("%d ms\n",yg_b);

        t := alarm.time();
        ug_b := bat.reverse(M2);
        vg_b := algebra.join(M2,ug_b);
        wg_b := aggr.count(vg_b);
        xg_b := io.printf("#count %d = ",wg_b);
        x:= alarm.time();
        yg_b := calc.-(x,t);
       ah_b := io.printf("%d ms\n",yg_b);


        t := alarm.time();
        ug_b := bat.reverse(M2);
        vg_b := algebra.join(M2,ug_b);
        wg_b := aggr.count(vg_b);
        xg_b := io.printf("#count %d = ",wg_b);
        x:= alarm.time();
        yg_b := calc.-(x,t);
      ah_b := io.printf("%d ms\n",yg_b);