驱动数据结构体

嬴图Go驱动提供一系列数据类，用于应用与图数据库的交互。所有数据类均支持getter方法获取属性和setter方法设置属性。

Node

Node值包含以下字段：

requestConfig := &configuration.RequestConfig{
    Graph: "miniCircle",
}

response, _ := driver.Gql("MATCH (n) RETURN n LIMIT 5", requestConfig)
nodes, _, _ := response.Alias("n").AsNodes()

fmt.Println("ID of the first node:", nodes[0].GetID())
fmt.Println("Name of the first node:", nodes[0].GetValues().Get("name"))

ID of the first node: ULTIPA800000000000004B
Name of the first node: Claire89

Edge

Edge值包含以下字段：

requestConfig := &configuration.RequestConfig{
    Graph: "miniCircle",
}

response, _ := driver.Gql("MATCH ()-[e]->() RETURN e LIMIT 3", requestConfig)
edges, _, _ := response.Alias("e").AsEdges()

for _, edge := range edges {
    fmt.Println(edge.GetValues())
}

&{map[fromUuid:7 toUuid:13 uuid:110]}
&{map[datetime:2018-09-19T12:38:33.000Z fromUuid:7 timestamp:2018-09-19T12:38:33.000+08:00 toUuid:1032 uuid:1391]}
&{map[datetime:2018-12-07T01:56:00.000Z fromUuid:7 timestamp:2018-12-07T01:56:00.000+08:00 toUuid:1005 uuid:1390]}

Path

Path值包含以下字段：

Path值支持的方法：

requestConfig := &configuration.RequestConfig{
    Graph: "miniCircle",
}

response, _ := driver.Gql("MATCH p = ()-[]-()-[]-() RETURN p LIMIT 3", requestConfig)
graph, _ := response.Alias("p").AsGraph()

fmt.Println("Nodes in each returned path:")
paths := graph.Paths
for _, path := range paths {
    fmt.Println(path.NodeUUIDs)
}

Nodes in each returned path:
[6196955286285058053 7998395137233256458 8214567919347040276]
[6196955286285058053 7998395137233256458 8214567919347040276]
[6196955286285058053 7998395137233256458 5764609722057490442]

Graph

Graph值包含以下字段：

Graph值支持的方法：

requestConfig := &configuration.RequestConfig{
    Graph: "miniCircle",
}

response, _ := driver.Gql("MATCH p = ()-[]-()-[]-() RETURN p LIMIT 3", requestConfig)
graph, _ := response.Alias("p").AsGraph()

fmt.Println("Nodes in each returned path:")
paths := graph.Paths
for _, path := range paths {
    fmt.Println(path.NodeUUIDs)
}

fmt.Println("----------")
fmt.Println("Nodes in the graph formed by all returned paths:")
for key := range graph.Nodes {
    fmt.Print(key, " ")
}

Nodes in each returned path:
[6196955286285058053 7998395137233256458 8214567919347040276]
[6196955286285058053 7998395137233256458 8214567919347040276]
[6196955286285058053 7998395137233256458 5764609722057490442]
----------
Nodes in the graph formed by all returned paths:
6196955286285058053 7998395137233256458 8214567919347040276 5764609722057490442

GraphSet

GraphSet值包含以下字段：

response, _ := driver.Gql("SHOW GRAPH", nil)
graphs, _ := response.Alias("_graph").AsGraphSets()

for _, graph := range graphs {
    fmt.Println(graph.Name)
}

DFS_EG
cyber
netflow

Schema

Schema值包含以下字段：

requestConfig := &configuration.RequestConfig{
    Graph: "miniCircle",
}

response, _ := driver.Gql("SHOW NODE SCHEMA", requestConfig)
schemas, _ := response.Alias("_nodeSchema").AsSchemas()

for _, schema := range schemas {
    fmt.Println(schema.Name)
}

default
account
celebrity
country
movie

Property

Property值包含以下字段：

requestConfig := &configuration.RequestConfig{
    Graph: "miniCircle",
}

response, _ := driver.Gql("SHOW NODE account PROPERTY", requestConfig)
properties, _ := response.Alias("_nodeProperty").AsProperties()

for _, property := range properties {
    fmt.Println(property.Name)
}

title
profile
age
name
logo

Attr

Attr值包含以下字段：

requestConfig := &configuration.RequestConfig{
    Graph: "miniCircle",
}

response, _ := driver.Gql("MATCH (n:account) RETURN n.name LIMIT 3", requestConfig)
attr, _ := response.Alias("n.name").AsAttr()

fmt.Println("Name:", attr.Name)
fmt.Println("Values:", attr.Values)
fmt.Println("Type:", attr.PropertyType)

Name: n.name
Values: [Velox K03 Lunatique]
Type: STRING

Table

Table值包含以下字段：

Table值支持的方法：

requestConfig := &configuration.RequestConfig{
    Graph: "miniCircle",
}

response, _ := driver.Gql("MATCH (n:account) RETURN table(n._id, n.name) LIMIT 3", requestConfig)
table, _ := response.Get(0).AsTable()

fmt.Println("Header:")
for _, header := range table.Headers {
    fmt.Println(header)
}
rows := table.ToKV()
fmt.Println("First Row:", rows[0])

Header:
&{n._id STRING}
&{n.name STRING}
First Row: &{map[n._id:ULTIPA800000000000003B n.name:Velox]}

HDCGraph

HDCGraph值包含以下字段：

requestConfig := &configuration.RequestConfig{
    Graph: "miniCircle",
}

response, _ := driver.Gql("SHOW HDC GRAPH", requestConfig)
hdcGraphs, _ := response.Alias("_hdcGraphList").AsHDCGraphs()

for _, hdcGraph := range hdcGraphs {
    fmt.Println(hdcGraph.Name, "on", hdcGraph.HDCServerName)
}

miniCircle_hdc_graph on hdc-server-1
miniCircle_hdc_graph2 on hdc-server-2

Algo

Algo值包含以下字段：

response, _ := driver.Gql("SHOW HDC ALGO ON 'hdc-server-1'", nil)
algos, _ := response.Alias("_algoList").AsAlgos()

for _, algo := range algos {
    fmt.Print(algo.Name, " supports writeback type(s): ")
    if algo.WriteSupportType != "" {
    	fmt.Print(algo.WriteSupportType)
  	} else {
   	   fmt.Print("None")
  	}
  	fmt.Println()
}

fastRP supports writeback type(s): DB,FILE
schema_overview supports writeback type(s): None

Projection

Projection值包含以下字段：

requestConfig := &configuration.RequestConfig{
    Graph: "miniCircle",
}

response, _ := driver.Gql("SHOW PROJECTION", requestConfig)
projections, _ := response.Alias("_projectionList").AsProjections()

for _, projection := range projections {
    fmt.Println(projection.Name)
}

miniCircle_projection_1

Index

Index值包含以下字段：

requestConfig := &configuration.RequestConfig{
    Graph: "miniCircle",
}

response, _ := driver.Gql("SHOW NODE INDEX", requestConfig)
indexList, _ := response.Alias("_nodeIndex").AsIndexes()

for _, index := range indexList {
    fmt.Println(index.Schema, "-", index.Properties)
}

account - gender(6),year

Privilege

Privilege值包含以下字段：

response, _ := driver.Uql("show().privilege()", nil)
privileges, _ := response.Alias("_privilege").AsPrivileges()

var graphPrivileges []string
var systemPrivileges []string

for _, privilege := range privileges {
  	if privilege.Level == structs.GraphPrivilege {
    	graphPrivileges = append(graphPrivileges, privilege.Name)
  	} else {
    	systemPrivileges = append(systemPrivileges, privilege.Name)
  	}
}

fmt.Println("Graph Privileges:", graphPrivileges)
fmt.Println("System Privileges:", systemPrivileges)

Graph Privileges: [READ INSERT UPSERT UPDATE DELETE CREATE_SCHEMA DROP_SCHEMA ALTER_SCHEMA SHOW_SCHEMA RELOAD_SCHEMA CREATE_PROPERTY DROP_PROPERTY ALTER_PROPERTY SHOW_PROPERTY CREATE_FULLTEXT DROP_FULLTEXT SHOW_FULLTEXT CREATE_INDEX DROP_INDEX SHOW_INDEX LTE UFE CLEAR_JOB STOP_JOB SHOW_JOB ALGO CREATE_PROJECT SHOW_PROJECT DROP_PROJECT CREATE_HDC_GRAPH SHOW_HDC_GRAPH DROP_HDC_GRAPH COMPACT_HDC_GRAPH SHOW_VECTOR_INDEX CREATE_VECTOR_INDEX DROP_VECTOR_INDEX SHOW_CONSTRAINT CREATE_CONSTRAINT DROP_CONSTRAINT]
System Privileges: [TRUNCATE COMPACT CREATE_GRAPH SHOW_GRAPH DROP_GRAPH ALTER_GRAPH CREATE_GRAPH_TYPE SHOW_GRAPH_TYPE DROP_GRAPH_TYPE TOP KILL STAT SHOW_POLICY CREATE_POLICY DROP_POLICY ALTER_POLICY SHOW_USER CREATE_USER DROP_USER ALTER_USER SHOW_PRIVILEGE SHOW_META SHOW_SHARD ADD_SHARD DELETE_SHARD REPLACE_SHARD SHOW_HDC_SERVER ADD_HDC_SERVER DELETE_HDC_SERVER LICENSE_UPDATE LICENSE_DUMP GRANT REVOKE SHOW_BACKUP CREATE_BACKUP SHOW_VECTOR_SERVER ADD_VECTOR_SERVER DELETE_VECTOR_SERVER]

Policy

Policy值包含以下字段：

PropertyPrivilegeElement值包含以下字段：

response, _ := driver.Uql("show().policy('Tester')", nil)
policy, _ := response.Alias("_policy").AsPolicies()

fmt.Println("Graph Privileges:", policy[0].GraphPrivileges)
fmt.Println("System Privileges:", policy[0].SystemPrivileges)
fmt.Println("Property Privileges:")
fmt.Println("- Node (Read):", policy[0].PropertyPrivileges.Node.Read)
fmt.Println("- Node (Write):", policy[0].PropertyPrivileges.Node.Write)
fmt.Println("- Node (Deny):", policy[0].PropertyPrivileges.Node.Deny)
fmt.Println("- Edge (Read):", policy[0].PropertyPrivileges.Edge.Read)
fmt.Println("- Edge (Write):", policy[0].PropertyPrivileges.Edge.Write)
fmt.Println("- Edge (Deny):", policy[0].PropertyPrivileges.Edge.Deny)
fmt.Println("Policies:", policy[0].Policies)

Graph Privileges: map[*:[SHOW_PROPERTY READ SHOW_SCHEMA] alimama:[SHOW_JOB SHOW_INDEX] trans:[SHOW_JOB SHOW_INDEX]]
System Privileges: [ALTER_GRAPH SHOW_GRAPH]
Property Privileges:
- Node (Read): [[* * *]]
- Node (Write): []
- Node (Deny): []
- Edge (Read): [[alimama * timestamp]]
- Edge (Write): [[alimama edgx behavior] [alimama edgx timestamp]]
- Edge (Deny): []
Policies: [manager]

User

User值包含以下字段：

PropertyPrivilegeElement值包含以下字段：

response, _ := driver.Uql("show().user('johndoe')", nil)
user, _ := response.Alias("_user").AsUsers()

fmt.Println("Created Time:", user[0].CreatedTime)
fmt.Println("Graph Privileges:", user[0].GraphPrivileges)
fmt.Println("System Privileges:", user[0].SystemPrivileges)
fmt.Println("Property Privileges:")
fmt.Println("- Node (Read):", user[0].PropertyPrivileges.Node.Read)
fmt.Println("- Node (Write):", user[0].PropertyPrivileges.Node.Write)
fmt.Println("- Node (Deny):", user[0].PropertyPrivileges.Node.Deny)
fmt.Println("- Edge (Read):", user[0].PropertyPrivileges.Edge.Read)
fmt.Println("- Edge (Write):", user[0].PropertyPrivileges.Edge.Write)
fmt.Println("- Edge (Deny):", user[0].PropertyPrivileges.Edge.Deny)
fmt.Println("Policies:", user[0].Policies)

Created Time: 2025-04-02T11:08:38.000+08:00
Graph Privileges: map[*:[SHOW_PROPERTY READ SHOW_SCHEMA] alimama:[SHOW_JOB SHOW_INDEX] trans:[SHOW_JOB SHOW_INDEX]]
System Privileges: [ALTER_GRAPH SHOW_GRAPH]
Property Privileges:
- Node (Read): [[* * *]]
- Node (Write): []
- Node (Deny): []
- Edge (Read): [[alimama * timestamp]]
- Edge (Write): [[alimama edgx behavior] [alimama edgx timestamp]]
- Edge (Deny): []
Policies: [manager]

Process

Process值包含以下字段：

response, _ := driver.Gql("TOP", nil)
processes, _ := response.Alias("_top").AsProcesses()

for _, proprocess := range processes {
    fmt.Println(proprocess.ProcessId)
}

1049435

Job

Job值包含以下字段：

requestConfig := &configuration.RequestConfig{
  Graph: "miniCircle",
}

response, _ := driver.Gql("SHOW JOB", requestConfig)
jobs, _ := response.Alias("_job").AsJobs()

for _, job := range jobs {
    if job.Status == "FAILED" {
    	fmt.Println(job.Id, "-", job.ErrMsg, "-", job.Type)
    }
}

51 - Fulltext name already exists. - CREATE_FULLTEXT
42 - Fulltext name already exists. - CREATE_FULLTEXT
26 - [engine] uuids should be unsigned integer - HDC_ALGO
26_1 -  - HDC_ALGO
17 - [engine] all failed, because some nodes do not exist in db - HDC_ALGO
17_1 -  - HDC_ALGO