QueryCallFunction.R

dol_to_euro = function (dol) dol * 89 / 100
emp = new.table("emp", "PostgreSQL", "postgre.config", "public")
minsalary = 2500
q3 = select(function (x) { res = new.env(); res$empno = x$empno; res$ename = x$ename;
              res$salary = dol_to_euro(x$sal); res },
     where(function (x) x$sal >= minsalary,
     from(emp)))
results3 = query.force(q3)
for (r in results3) { print (sprintf("%d, %s, %d", r$empno, r$ename, r$salary)) }