(gelöst) node red mysql werte addieren

[druckstick.at]

Hallo Allerseits!
Ich hoffe ich bin damit im richtigen Forum und vor allem im richtigen Bereich...

Ich möchte die Summe von Werten, einzelner Benutzer, einer mysql Spalte.

Bsp.: Spalte A sind die User, Spalte B sind Zahlen

User X kommt in Spalte A 50x vor, somit auch dazugehörige Werte in Spalte B

Ich weiß zwar wie ich nur die Werte von dem User X abfragen kann, bin aber viel zu unerfahren im Programmieren, dass ich da noch eine Berechnung einfügen kann.

Hier mein Filter:

msg.topic = "SELECT * FROM Testtabelle WHERE Spalte1 = '" + msg.payload.person + "'; "
return msg;

Mit den Werten aus meinem Filter fange ich so nichts an, da ich für jede Zeile ein Objekt bekomme....

Ich verwende node-red-node-mysql

Das Thema mySQL und node red ist leider sehr mager im Netzt vertreten, die meisten tutorials gehen auf den letzten oder höchsten Wert....

Vielen Dank im Voraus!```
code_text

[druckstick.at]

mir wurde wo anders die Lösung gezeigt...

hier die nodes:

[
    {
        "id": "e6a27dd296678be6",
        "type": "tab",
        "label": "Flow 1",
        "disabled": false,
        "info": "",
        "env": []
    },
    {
        "id": "d6c1203fb44c3759",
        "type": "inject",
        "z": "e6a27dd296678be6",
        "name": "Abfrage Spalte User",
        "props": [
            {
                "p": "payload.user",
                "v": "user1",
                "vt": "str"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "x": 130,
        "y": 40,
        "wires": [
            [
                "81a8cf372d40c91e"
            ]
        ]
    },
    {
        "id": "81a8cf372d40c91e",
        "type": "function",
        "z": "e6a27dd296678be6",
        "name": "abfragen bestimter User",
        "func": "msg.topic = \"SELECT * FROM Testtabelle WHERE Spalte1 = '\" + msg.payload.user + \"'; \"\nreturn msg;\n\n",
        "outputs": 1,
        "timeout": 0,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 370,
        "y": 40,
        "wires": [
            [
                "a04426f825a7bb9a"
            ]
        ]
    },
    {
        "id": "84d8dc35e5843902",
        "type": "split",
        "z": "e6a27dd296678be6",
        "name": "Array in einzelne Nachrichten",
        "splt": ",",
        "spltType": "str",
        "arraySplt": 1,
        "arraySpltType": "len",
        "stream": false,
        "addname": "",
        "x": 880,
        "y": 40,
        "wires": [
            [
                "21f5008ae1bd8072"
            ]
        ]
    },
    {
        "id": "21f5008ae1bd8072",
        "type": "change",
        "z": "e6a27dd296678be6",
        "name": "Daten auf payload",
        "rules": [
            {
                "t": "move",
                "p": "payload.Spalte2",
                "pt": "msg",
                "to": "payload",
                "tot": "msg"
            }
        ],
        "action": "",
        "property": "",
        "from": "",
        "to": "",
        "reg": false,
        "x": 150,
        "y": 140,
        "wires": [
            [
                "3f428eaec9a2c230"
            ]
        ]
    },
    {
        "id": "3f428eaec9a2c230",
        "type": "join",
        "z": "e6a27dd296678be6",
        "name": "Daten zurück in Array",
        "mode": "custom",
        "build": "array",
        "property": "payload",
        "propertyType": "msg",
        "key": "topic",
        "joiner": ",",
        "joinerType": "str",
        "accumulate": false,
        "timeout": "2",
        "count": "",
        "reduceRight": false,
        "reduceExp": "",
        "reduceInit": "",
        "reduceInitType": "",
        "reduceFixup": "",
        "x": 420,
        "y": 140,
        "wires": [
            [
                "b2fb82ad2edb5201"
            ]
        ]
    },
    {
        "id": "a04426f825a7bb9a",
        "type": "mysql",
        "z": "e6a27dd296678be6",
        "mydb": "410735f8711c0cb6",
        "name": "Datenbanknerküpfung",
        "x": 620,
        "y": 40,
        "wires": [
            [
                "84d8dc35e5843902"
            ]
        ]
    },
    {
        "id": "b2fb82ad2edb5201",
        "type": "calculator",
        "z": "e6a27dd296678be6",
        "name": "Summe berechnen",
        "inputMsgField": "payload",
        "outputMsgField": "payload",
        "operation": "sum",
        "constant": "",
        "round": false,
        "truncate": false,
        "decimals": 0,
        "decimals2": 0,
        "x": 630,
        "y": 140,
        "wires": [
            [
                "fe5ea3b2656a760a"
            ]
        ]
    },
    {
        "id": "fe5ea3b2656a760a",
        "type": "debug",
        "z": "e6a27dd296678be6",
        "name": "debug",
        "active": true,
        "tosidebar": true,
        "console": false,
        "tostatus": true,
        "complete": "true",
        "targetType": "full",
        "statusVal": "payload",
        "statusType": "auto",
        "x": 790,
        "y": 140,
        "wires": []
    },
    {
        "id": "4108711c0cb6",
        "type": "MySQLdatabase",
        "name": "",
        "host": "xxxxxx",
        "port": "3306",
        "db": "xxxxx",
        "tz": "",
        "charset": "UTF8"
    }
]