1

我在服务上创建了一个资源，以使用 Fork/Join 并行化两个数据库选择，并在第二个工作人员处收到错误：

workerdemodb2 中的异常：芭蕾舞女演员程序中的错误：8

如果我替换返回硬编码 json 变量的工作人员之一，而不是 sql:ClientConnect.select... 一切正常。

工人的例子：

            worker emp (message m) {
                string dbURL = "jdbc:oracle:thin:@localhost:49161/XE";
                string username = "vatrox";
                string password = "vatrox";
                map propertiesMap = {"jdbcUrl":dbURL, "username":username, "password":password};
                sql:ClientConnector empDBConnector = create sql:ClientConnector(propertiesMap);
                sql:Parameter[] params = [];

                try {
                    datatable dt = sql:ClientConnector.select(empDBConnector, "select empno,ename,job,mgr,hiredate,sal,comm,deptno from emp", params);
                    json payload = datatables:toJson(dt);
                    message response = {};
                    messages:setJsonPayload(response, payload);
                    reply response;

                }
                catch (exception e) {
                    message response = {};
                    messages:setJsonPayload(response, responseException("select emp",e));
                    reply response;

                }
            }

另一件事......我可以与不同的工作人员重用 sql:ClientConnector 吗？因为我创建了一个全局变量，但是我收到了未定义变量的错误，所以我需要为每个工作人员创建一个新变量。

谢谢，

J.P

4

1 回答 1

0

我们改进了芭蕾舞演员的设计。现在他们可以从其父范围访问变量，这意味着现在您可以在多个工作人员、资源之间共享一个 sql:ClientConnector。您可以在本文档中找到有关此设计的更多信息。https://docs.google.com/document/d/1ovnsu_Ifjysjg3OUH0QE3aalnV_0hMtrs38QJheyYaw/edit?ts=58e1c3e6#

于 2017-04-03T17:23:40.223 回答