行为举止 Fork/Join 的芭蕾舞女演员 Fork/Join

Question

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

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 吗？因为我创建了一个全局的，但是我收到了未定义变量的错误，所以我需要为每个工人创建一个新的。

谢谢，

日本

Answer 1

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

行为举止 Fork/Join 的芭蕾舞女演员 Fork/Join

Ballerina Fork/Join with sql:ClientConnector behaivor

ballerina