Database Querying

Request Configuration

All querying methods support an optional request configuration parameter (RequestConfig or InsertRequestConfig) to customize the behavior of requests made to the database. This parameter allows you to specify various settings, such as graphset name, timeout, and host, to tailor your requests according to your needs.

RequestConfig

RequestConfig defines the information needed when sending non-insert type of requests to the database.

Go
package main

import (
  "log"

  "github.com/ultipa/ultipa-go-sdk/sdk"
  "github.com/ultipa/ultipa-go-sdk/sdk/configuration"
)

func main() {

  config, _ := configuration.NewUltipaConfig(&configuration.UltipaConfig{
    Hosts:    []string{"192.168.1.85:60061", "192.168.1.86:60061", "192.168.1.87:60061"},
    Username: "***",
    Password: "***",
  })

  conn, _ := sdk.NewUltipa(config)

  requestConfig := &configuration.RequestConfig{
    GraphName:   "miniCircle",
    RequestType: configuration.RequestType_Task,
  }

  uqlResult, err := conn.Uql("find().nodes({@account.year > 2000}) as nodes return nodes{*} limit 5", requestConfig)

  log.Print(uqlResult, err)

}

RequestConfig has the following fields:

InsertRequestConfig

InsertRequestConfig defines the settings needed when sending data insertion or deletion requests to the database.

Go
package main

import (
  ultipa "github.com/ultipa/ultipa-go-sdk/rpc"
  "github.com/ultipa/ultipa-go-sdk/sdk"
  "github.com/ultipa/ultipa-go-sdk/sdk/configuration"
  "github.com/ultipa/ultipa-go-sdk/sdk/structs"
)

func main() {

  config, _ := configuration.NewUltipaConfig(&configuration.UltipaConfig{
    Hosts:    []string{"192.168.1.85:60061", "192.168.1.86:60061", "192.168.1.87:60061"},
    Username: "***",
    Password: "***",
  })

  conn, _ := sdk.NewUltipa(config)

  requestConfig := &configuration.RequestConfig{
    GraphName: "test",
  }
  insertRequestConfig := &configuration.InsertRequestConfig{
    RequestConfig: requestConfig,
    InsertType:    ultipa.InsertType_OVERWRITE,
  }

  var nodes []*structs.Node

  newNode1 := structs.NewNode()
  newNode1.Schema = "card"
  newNode1.ID = "ULTIPA8000000000000001"
  newNode1.Set("amount", float32(3235.2))
  nodes = append(nodes, newNode1)

  newNode2 := structs.NewNode()
  newNode2.Schema = "client"
  newNode2.ID = "ULTIPA8000000000000007"
  newNode2.Set("level", int32(77))
  nodes = append(nodes, newNode2)

  conn.InsertNodesBatchAuto(nodes, insertRequestConfig)

}

InsertRequestConfig has the following fields: