Ballerina Fork/Join mit sql: ClientConnector behaivor

Question

habe ich eine Ressource auf einem Dienst zwei parallelisieren DB wählt unter Verwendung Fork/Join und den Fehler an der zweiten Arbeitskraft erhalten:

Ausnahme in workerdemodb2: Fehler in ballerina Programm :

Wenn ich einen der Arbeiter ersetzen, die eine fest codierte json-Variable anstelle der sql: ClientConnect.select zurückgibt ... alles funktioniert gut.

Beispiel des Arbeiters:

  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; 

       } 
      } 

Eine andere Sache ... Kann ich wieder verwenden eine SQL: ClientConnector mit verschiedenen Arbeitskräften? Da ich eine globale Variable erstellt habe, aber eine nicht definierte Variable erhalten habe, musste ich eine neue Variable für jeden Arbeiter erstellen.

Danke,

JP

Answer 1

wir das Design von Ballerina Arbeiter verbessert haben. Jetzt können sie auf Variablen aus ihren übergeordneten Bereichen zugreifen, was bedeutet, dass Sie jetzt einen sql: ClientConnector für mehrere Worker-Ressourcen freigeben können. Weitere Informationen zu diesem Design finden Sie in diesem Dokument. https://docs.google.com/document/d/1ovnsu_Ifjysjg3OUH0QE3aalnV_0hMtrs38QJheyYaw/edit?ts=58e1c3e6#