Ballerina /Join with sql:ClientConnector行为

Question

我在服务上创建了一个资源，用于并行两个DB选择，使用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吗？因为我创建了一个全局变量，但是我收到了一个未定义变量的错误，所以我需要为每个工作人员创建一个新的变量。

谢谢,

JP

Answer 1

我们改进了巴列利纳工人的设计。现在，它们可以从父作用域访问变量，这意味着现在您可以在多个工作人员、资源之间共享sql:ClientConnector。您可以在本文档中找到有关此设计的更多信息。0hMtrs38QJheyYaw/edit?ts=58e1c3e6#