fix(interactive): fix comparison between RTAny numeric types (#4399)

As titled.

Fix #4396

Author: zhanglei1949

flex/engines/graph_db/runtime/adhoc/operators/scan.cc

@@ -137,9 +137,17 @@ static bl::result<Context> scan_vertices_no_expr_impl(
     std::vector<int64_t> gids;
     for (size_t i = 0; i < input_ids.size(); i++) {
       if (input_ids[i].type != PropertyType::Int64()) {
-        RETURN_BAD_REQUEST_ERROR("Expect int64 type for global id");
+        if (input_ids[i].type == PropertyType::Int32()) {
+          LOG(WARNING) << "Implicitly convert int32 to int64 when scan vertex "
+                          "with global id";
+          gids.push_back(input_ids[i].AsInt32());
+        } else {
+          RETURN_BAD_REQUEST_ERROR("Expect int64 type for global id, but got" +
+                                   input_ids[i].type.ToString());
+        }
+      } else {
+        gids.push_back(input_ids[i].AsInt64());
       }
-      gids.push_back(input_ids[i].AsInt64());
     }
     return Scan::filter_gids(
         txn, scan_params, [](label_t, vid_t) { return true; }, gids);

flex/engines/graph_db/runtime/common/rt_any.cc

@@ -443,32 +443,44 @@ int RTAny::numerical_cmp(const RTAny& other) const {
   switch (type_.type_enum_) {
   case RTAnyType::RTAnyTypeImpl::kI64Value:
     switch (other.type_.type_enum_) {
-    case RTAnyType::RTAnyTypeImpl::kI32Value:
-      return value_.i64_val - other.value_.i32_val;
-    case RTAnyType::RTAnyTypeImpl::kF64Value:
-      return value_.i64_val - other.value_.f64_val;
+    case RTAnyType::RTAnyTypeImpl::kI32Value: {
+      auto res = value_.i64_val - other.value_.i32_val;
+      return res > 0 ? 1 : (res == 0 ? 0 : -1);
+    }
+    case RTAnyType::RTAnyTypeImpl::kF64Value: {
+      auto res = value_.i64_val - other.value_.f64_val;
+      return res > 0 ? 1 : (res == 0 ? 0 : -1);
+    }
     default:
       LOG(FATAL) << "not support for "
                  << static_cast<int>(other.type_.type_enum_);
     }
     break;
   case RTAnyType::RTAnyTypeImpl::kI32Value:
     switch (other.type_.type_enum_) {
-    case RTAnyType::RTAnyTypeImpl::kI64Value:
-      return value_.i32_val - other.value_.i64_val;
-    case RTAnyType::RTAnyTypeImpl::kF64Value:
-      return value_.i32_val - other.value_.f64_val;
+    case RTAnyType::RTAnyTypeImpl::kI64Value: {
+      auto res = value_.i32_val - other.value_.i64_val;
+      return res > 0 ? 1 : (res == 0 ? 0 : -1);
+    }
+    case RTAnyType::RTAnyTypeImpl::kF64Value: {
+      auto res = value_.i32_val - other.value_.f64_val;
+      return res > 0 ? 1 : (res == 0 ? 0 : -1);
+    }
     default:
       LOG(FATAL) << "not support for "
                  << static_cast<int>(other.type_.type_enum_);
     }
     break;
   case RTAnyType::RTAnyTypeImpl::kF64Value:
     switch (other.type_.type_enum_) {
-    case RTAnyType::RTAnyTypeImpl::kI64Value:
-      return value_.f64_val - other.value_.i64_val;
-    case RTAnyType::RTAnyTypeImpl::kI32Value:
-      return value_.f64_val - other.value_.i32_val;
+    case RTAnyType::RTAnyTypeImpl::kI64Value: {
+      auto res = value_.f64_val - other.value_.i64_val;
+      return res > 0 ? 1 : (res == 0 ? 0 : -1);
+    }
+    case RTAnyType::RTAnyTypeImpl::kI32Value: {
+      auto res = value_.f64_val - other.value_.i32_val;
+      return res > 0 ? 1 : (res == 0 ? 0 : -1);
+    }
     default:
       LOG(FATAL) << "not support for " << static_cast<int>(type_.type_enum_);
     }
@@ -528,13 +540,6 @@ bool RTAny::operator==(const RTAny& other) const {
     return value_.vertex == other.value_.vertex;
   } else if (type_ == RTAnyType::kDate32) {
     return value_.i64_val == other.value_.i64_val;
-  }
-
-  if (type_ == RTAnyType::kI64Value && other.type_ == RTAnyType::kI32Value) {
-    return value_.i64_val == other.value_.i32_val;
-  } else if (type_ == RTAnyType::kI32Value &&
-             other.type_ == RTAnyType::kI64Value) {
-    return value_.i32_val == other.value_.i64_val;
   } else if (type_ == RTAnyType::kF64Value) {
     return value_.f64_val == other.value_.f64_val;
   }

interactive_engine/compiler/src/main/java/com/alibaba/graphscope/cypher/integration/suite/graphAlgo/GraphAlgoQueries.java

@@ -241,4 +241,10 @@ public static QueryContext get_graph_algo_test13() {
                                 + " 1}>");
         return new QueryContext(query, expected);
     }
+
+    public static QueryContext get_graph_algo_test14() {
+        String query = "MATCH(a) where elementId(a) in [0] return a.id;";
+        List<String> expected = Arrays.asList("Record<{id: 0}>");
+        return new QueryContext(query, expected);
+    }
 }

interactive_engine/compiler/src/test/java/com/alibaba/graphscope/cypher/integration/graphAlgo/GraphAlgoTest.java

@@ -141,6 +141,13 @@ public void run_graph_query13_test() {
         Assert.assertEquals(testQuery.getExpectedResult().toString(), result.list().toString());
     }
 
+    @Test
+    public void run_graph_query14_test() {
+        QueryContext testQuery = GraphAlgoQueries.get_graph_algo_test14();
+        Result result = session.run(testQuery.getQuery());
+        Assert.assertEquals(testQuery.getExpectedResult().toString(), result.list().toString());
+    }
+
     @AfterClass
     public static void afterClass() {
         if (session != null) {