graph_test.go 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152
  1. package main
  2. import (
  3. "log"
  4. "testing"
  5. )
  6. func TestCheckInvestRelation(t *testing.T) {
  7. session, pool, err := ConnectToNebula(HostList, UserName, PassWord)
  8. if err != nil {
  9. log.Fatalf("Failed to connect to Nebula Graph: %v", err)
  10. }
  11. defer pool.Close()
  12. defer session.Release()
  13. names := []string{"新疆拓普丰联网络信息技术有限公司",
  14. "上海元藩投资有限公司",
  15. "海南清鹤鸣企业管理咨询合伙企业(有限合伙)",
  16. "华芳创业投资有限公司",
  17. "北京剑鱼信息技术有限公司"}
  18. //res, err := CheckLegalRelationsGraph(session, names, 3)
  19. has, res, err := CheckLegalRelationships5(session, names, 3, 1)
  20. if err != nil {
  21. log.Println(res, err, has)
  22. }
  23. log.Println(has, res)
  24. }
  25. func TestCheckLegalRelationships(t *testing.T) {
  26. client, err := NewNebulaClient(HostList, UserName, PassWord)
  27. if err != nil {
  28. log.Fatal("连接失败:", err)
  29. }
  30. defer client.Close()
  31. names := []string{"华芳创业投资有限公司", "北京剑鱼信息技术有限公司", "河南折扣牛哟有限公司", "上海元藩投资有限公司"}
  32. has, res, err := client.CheckLegalRelationships(names, 3, 0)
  33. log.Println(has, res, err)
  34. }
  35. func TestFetchLegalByVid(t *testing.T) {
  36. session, pool, err := ConnectToNebula(HostList, UserName, PassWord)
  37. if err != nil {
  38. log.Fatalf("Failed to connect to Nebula Graph: %v", err)
  39. }
  40. defer pool.Close()
  41. defer session.Release()
  42. vid := "fb7c72258ec3f57bedd0657b0c3e90d2"
  43. res, err := getLegalByVid(session, vid)
  44. log.Println(res, err)
  45. }