java与python的深度融合之数据查询

from cn.ijingxi.intelControl.python import jxpython

@jx.defSQL
def test():
    """
    from ObjTag,People
    select People.Name as peopleName type string,ObjTag.TagID as tag type int
    where ObjTag.ID == People.ID and People.Name as pname != ?
    """
    pass

#接口访问策略：只要是正常的登录用户都可访问
@ActiveRight(policy = ActiveRight.Policy.NormalUser)
#为该函数提供REST功能，访问点的url是：/jxc/query
@REST
public static jxHttpData query(Map<String, Object> ps, jxJson Param) throws Exception {
    #从session中取得当前用户
    String sid = (String) ps.get("SessionID");
    UUID pid = jxSession.getPeopleID(sid);
    #由于是NormalUser许可，所以这两个404是画蛇添足，这是为了防止哪天没想开将访问策略修改为不需登录也可访问
    if (pid == null)
        return new jxHttpData(404, "用户未找到");
    People p = (People) People.getByID(People.class, pid);
    if (p == null)
        return new jxHttpData(404, "用户未找到");

    SelectSql sql = null;
    jxSession s = jxSession.search(sid);
    #res是脚本名
    String res = Param.getSubValueString("res");
    #安装脚本
    scene ms = installToSession(s, p, res);

    String active = Param.getSubValueString("filter");
    if (active != null) {
        #用户自定义的查询筛选器
        sql = getSQL(p, active);
        utils.checkAssert(sql != null, "{}未定义筛选器：{}", p.Name, active);
    } else {
        #执行一个预定义好的查询语句
        active = Param.getSubValueString("active");
        utils.checkAssert(active != null, "{} 未指定明确的查询入口", res);

        #权限检查。jxpi的权限检查分为操作权限和读权限，这里检查的是操作权限，在执行每个python函数时都会自动进行权限检查
        #但由于这里的pyghon函数只相当于是给类sql语句起了个名字，并不会被真正执行，所以类sql语句的查询需要显式进行权限检查
        boolean accept = authorize(py, p, active);
        if (!accept)
            return new jxHttpData(403, "{}没有权限执行：{}-{}", p.Name, res, active);

        sql = getSQL(ms, active);
        utils.checkAssert(sql != null, "{}的{}未正确定义查询语句", res, active);
    }

    jxHttpData rs = new jxHttpData(200, "OK");
    for (jxJson sub : Param)
        setParam(sql, sub.getName(), sub.getValue());

    #执行查询，结果是名为result的json数组。根据各数据项的显示格式自动进行格式化，如果用户没有权限读取某数据项则显示为：没有访问权限
    jxJson json = sceneUtils.query(ms, sql);
    rs.addJson(json);

    return rs;
}