test_60.mal

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

# Monet Mil to Mal compiler
# Copyright (c) 2001-2004, CWI. All rights reserved.

#Predefined code segment
#The compiler can not guarantee an accurate compilation,
#because MIL unlike MAL is a dynamically typed language.
#A few guidelines to maximize usefullness.
#- make the type of variables explicit, in particular 'nil'
#- upon advice of M2m to remap identifiers, change it in your program directly
#use the "mil_schema" for additional support routines
#	io.print("setoid(oid(20000000));");
	aa_a := calc.oid(20000000);
	ba_a := setoid(aa_a);
#	io.print("# For distributed processing it should be possible\n");
#	io.print("# split and re-distribute BATs.\n");
#	io.print("# This is supported by hashsplit, rangesplit,  and groupby operations.\n");
#	io.print("PROC groupby(bat b, bat  rng) : bat {");
function groupby(b:bat[:any$1,:any$2], rng:bat[:any$3,:any$4]):bat[:any$5,:any$6];
#	io.print(" VAR r := rng.reverse().number().reverse();");
	ca_a := bat.reverse(rng);
	da_a := number(ca_a);
	r := bat.reverse(da_a);
#	io.print(" VAR l := rng.number().reverse();");
	ea_a := number(rng);
	l := bat.reverse(ea_a);
#	io.print(" RETURN [select](l.project(b),l,r);");
	fa_a := project(l,b);
	return ga_a :=multiplex.tactics("select",fa_a,l,r);
end groupby;
#	io.print("var b:= bat.new(int,int);");
	b := bat.new(nil:int,nil:int);
#	io.print("b.insert(1,15);");
	ha_a := bat.insert(b,1,15);
#	io.print("b.insert(2,4);");
	ia_a := bat.insert(b,2,4);
#	io.print("b.insert(3,int(nil));");
	ja_a := calc.int(nil);
	ka_a := bat.insert(b,3,ja_a);
#	io.print("b.insert(4,16);");
	la_a := bat.insert(b,4,16);
#	io.print("b.insert(5,25);");
	ma_a := bat.insert(b,5,25);
#	io.print("b.insert(6,36);");
	na_a := bat.insert(b,6,36);
#	io.print("b.insert(7,49);");
	oa_a := bat.insert(b,7,49);
#	io.print("b.insert(8,64);");
	pa_a := bat.insert(b,8,64);
#	io.print("b.insert(9,int(nil));");
	qa_a := calc.int(nil);
	ra_a := bat.insert(b,9,qa_a);
#	io.print("b.insert(int(nil),int(nil));");
	sa_a := calc.int(nil);
	ta_a := calc.int(nil);
	ua_a := bat.insert(b,sa_a,ta_a);
#	io.print("b.insert(int(nil),81);");
	va_a := calc.int(nil);
	wa_a := bat.insert(b,va_a,81);
#	io.print("b.rename(\"b\");");
	xa_a := bat.setName(b,"b");
#	io.print("var rng:= bat.new(int,int);");
	rng := bat.new(nil:int,nil:int);
#	io.print("rng.insert(1,1);");
	ya_a := bat.insert(rng,1,1);
#	io.print("rng.insert(1,9);");
	ab_a := bat.insert(rng,1,9);
#	io.print("rng.insert(int(nil),9);");
	bb_a := calc.int(nil);
	cb_a := bat.insert(rng,bb_a,9);
#	io.print("rng.insert(1,int(nil));");
	db_a := calc.int(nil);
	eb_a := bat.insert(rng,1,db_a);
#	io.print("rng.insert(9,9);");
	fb_a := bat.insert(rng,9,9);
#	io.print("rng.insert(3,5);");
	gb_a := bat.insert(rng,3,5);
#	io.print("var bb := b.groupby(rng);");
	bb := groupby(b,rng);
#	io.print("bb.print();");
	hb_a := bat.print(bb);
#	io.print("bb@batloop() { $t.print(); }");
barrier	(ib_a,ib_aH,ib_aT) := newIterator(bb);
	jb_a := bat.print(ib_aT);
redo	(ib_a,ib_aH,ib_aT) := hasMoreElements(bb);
exit	(ib_a,ib_aH,ib_aT) ;
#	io.print("# other values;\n");
	x := bat.new(nil:int,nil:chr);
#	io.print("x.insert(1,'a');");
	kb_a := bat.insert(x,1,'a');
#	io.print("x.insert(2,'a');");
	lb_a := bat.insert(x,2,'a');
#	io.print("x.insert(3,'b');");
	mb_a := bat.insert(x,3,'b');
#	io.print("x.insert(4,'b');");
	nb_a := bat.insert(x,4,'b');
#	io.print("x.insert(5,'b');");
	ob_a := bat.insert(x,5,'b');
#	io.print("x.insert(6,'b');");
	pb_a := bat.insert(x,6,'b');
#	io.print("x.insert(7,'c');");
	qb_a := bat.insert(x,7,'c');
#	io.print("x.insert(8,'c');");
	rb_a := bat.insert(x,8,'c');
#	io.print("var t := bat.new(chr,chr);");
	t := bat.new(nil:chr,nil:chr);
#	io.print("t.insert('a','b');");
	sb_a := bat.insert(t,'a','b');
#	io.print("t.insert('c','c');");
	tb_a := bat.insert(t,'c','c');
#	io.print("t.insert('b','b');");
	ub_a := bat.insert(t,'b','b');
#	io.print("var xx:= x.groupby(t);");
	xx := groupby(x,t);
#	io.print("xx.print();");
	vb_a := bat.print(xx);
#	io.print("xx@batloop() { $t.print(); }");
barrier	(wb_a,wb_aH,wb_aT) := newIterator(xx);
	xb_a := bat.print(wb_aT);
redo	(wb_a,wb_aH,wb_aT) := hasMoreElements(xx);
exit	(wb_a,wb_aH,wb_aT) ;
#	io.print("# other values;\n");
	x := bat.new(nil:int,nil:str);
#	io.print("x.insert(1,\"a\");");
	yb_a := bat.insert(x,1,"a");
#	io.print("x.insert(2,\"a\");");
	ac_a := bat.insert(x,2,"a");
#	io.print("x.insert(3,\"b\");");
	bc_a := bat.insert(x,3,"b");
#	io.print("x.insert(4,\"b\");");
	cc_a := bat.insert(x,4,"b");
#	io.print("x.insert(5,\"b\");");
	dc_a := bat.insert(x,5,"b");
#	io.print("x.insert(6,\"b\");");
	ec_a := bat.insert(x,6,"b");
#	io.print("x.insert(7,\"c\");");
	fc_a := bat.insert(x,7,"c");
#	io.print("x.insert(8,\"c\");");
	gc_a := bat.insert(x,8,"c");
#	io.print("t:= bat.new(str,str);");
	t := bat.new(nil:str,nil:str);
#	io.print("t.rename(\"t\");");
	hc_a := bat.setName(t,"t");
#	io.print("t.insert(\"a\",\"b\");");
	ic_a := bat.insert(t,"a","b");
#	io.print("t.insert(\"c\",\"c\");");
	jc_a := bat.insert(t,"c","c");
#	io.print("t.insert(\"b\",\"b\");");
	kc_a := bat.insert(t,"b","b");
#	io.print("xx:= x.groupby(t);");
	xx := groupby(x,t);
#	io.print("xx.print();");
	lc_a := bat.print(xx);
#	io.print("xx@batloop() { $t.print(); }");
barrier	(mc_a,mc_aH,mc_aT) := newIterator(xx);
	nc_a := bat.print(mc_aT);
redo	(mc_a,mc_aH,mc_aT) := hasMoreElements(xx);
exit	(mc_a,mc_aH,mc_aT) ;
#	io.print("quit();");
	oc_a := clients.quit();
#Identifer 'rename' mapped to 'bat.setName'