(iotdb) branch new_opc_server updated: fix

[justinchen]

This is an automated email from the ASF dual-hosted git repository.

justinchen pushed a commit to branch new_opc_server
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/new_opc_server by this push:
     new ef5c8755d41 fix
ef5c8755d41 is described below

commit ef5c8755d41466d1462600c21f2c323bb245929c
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Mon Dec 1 18:15:25 2025 +0800

    fix
---
 .../java/org/apache/iotdb/opcua/ClientTest.java    | 22 ++++++++++++++++++++++
 1 file changed, 22 insertions(+)

diff --git 
a/example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/ClientTest.java 
b/example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/ClientTest.java
index 62c2b2733af..3aea0cf25d1 100644
--- 
a/example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/ClientTest.java
+++ 
b/example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/ClientTest.java
@@ -20,12 +20,18 @@
 package org.apache.iotdb.opcua;
 
 import org.eclipse.milo.opcua.sdk.client.OpcUaClient;
+import org.eclipse.milo.opcua.stack.core.Identifiers;
 import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue;
 import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId;
+import org.eclipse.milo.opcua.stack.core.types.builtin.QualifiedName;
 import org.eclipse.milo.opcua.stack.core.types.builtin.StatusCode;
 import org.eclipse.milo.opcua.stack.core.types.builtin.Variant;
+import org.eclipse.milo.opcua.stack.core.types.enumerated.NodeClass;
 import org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn;
+import org.eclipse.milo.opcua.stack.core.types.structured.AddNodesItem;
+import org.eclipse.milo.opcua.stack.core.types.structured.AddNodesResponse;
 
+import java.util.Collections;
 import java.util.concurrent.CompletableFuture;
 
 public class ClientTest implements ClientExample {
@@ -58,6 +64,22 @@ public class ClientTest implements ClientExample {
 
     StatusCode writeStatus = client.writeValue(nodeId, writeValue).get();
     System.out.println("写入状态: " + writeStatus);
+
+    AddNodesResponse addStatus =
+        client
+            .addNodes(
+                Collections.singletonList(
+                    new AddNodesItem(
+                        new NodeId(2, "chen.grass").expanded(),
+                        Identifiers.Organizes,
+                        new NodeId(2, "chen.grass.bishop").expanded(),
+                        new QualifiedName(2, "bishop"),
+                        NodeClass.Variable,
+                        null,
+                        Identifiers.BaseDataVariableType.expanded())))
+            .get();
+    System.out.println("新增节点状态: " + addStatus);
+
     client.disconnect().get();
   }
 }