嬴图Java驱动提供一系列数据结构，用于应用与图数据库的交互。
所有数据结构均支持getter方法获取属性，以及setter方法设定属性值。
Node
Node对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
uuid |
Long | / | 点_uuid |
id |
String | / | 点_id |
schema |
String | / | 点所属的Schema名称 |
values |
Value |
/ | 点属性键值对 |
RequestConfig requestConfig = new RequestConfig();
requestConfig.setGraph("miniCircle");
Response response = driver.gql("MATCH (n) RETURN n LIMIT 5", requestConfig);
List<Node> nodes = response.alias("n").asNodes();
System.out.println("ID of the first node: " + nodes.get(0).getID());
System.out.println("Name of the first node: " + nodes.get(0).get("name"));
ID of the first node: ULTIPA800000000000004B
Name of the first node: Claire89
Edge
Edge对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
uuid |
Long | / | 边_uuid |
fromUuid |
Long | / | 边起点的_uuid |
to |
Long | / | 边终点的_uuid |
from |
String | / | 边起点的_id |
toId |
String | / | 边终点的_id |
schema |
String | / | 边所属的Schema名称 |
values |
Value |
/ | 边属性键值对 |
RequestConfig requestConfig = new RequestConfig();
requestConfig.setGraph("miniCircle");
Response response = driver.gql("MATCH ()-[e]->() RETURN e LIMIT 3", requestConfig);
List<Edge> edges = response.alias("e").asEdges();
for (Edge edge : edges) {
System.out.println(edge.getValues());
}
{toUuid=108, uuid=1661, fromUuid=59, timestamp=Sun Oct 14 06:27:42 CST 2018}
{toUuid=15, uuid=31, fromUuid=59}
{toUuid=1012, uuid=1368, fromUuid=59, datetime=2019-03-23T17:09:12}
Path
Path对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
nodeUUids |
List<Long> | / | 路径中点的_uuid列表 |
edgeUuids |
List<Long> | / | 路径中边的_uuid列表 |
nodes |
Map<Long, Node> |
{} |
路径中点的映射，其中键是点的_uuid，值是相应的点 |
edges |
Map<Long, Edge> |
{} |
路径中边的映射，其中键是边的_uuid，值是相应的边 |
Path对象支持的方法：
方法 |
返回值 |
描述 |
|---|---|---|
length() |
int | 获取路径长度，即路径中的边数量 |
RequestConfig requestConfig = new RequestConfig();
requestConfig.setGraph("miniCircle");
Response response = driver.gql("MATCH p = ()-[]-()-[]-() RETURN p LIMIT 3", requestConfig);
Graph graph = response.alias("p").asGraph();
System.out.println("Nodes in each returned path:");
List<Path> paths = graph.getPaths();
for (Path path : paths) {
System.out.println(path.getNodeUUIDs());
}
Nodes in each returned path:
[6196955286285058052, 7998395137233256457, 8214567919347040275]
[6196955286285058052, 7998395137233256457, 8214567919347040275]
[6196955286285058052, 7998395137233256457, 5764609722057490441]
Graph
Graph对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
paths |
List<Path> |
/ | 返回的路径列表 |
nodes |
Map<Long, Node> |
{} |
图中点的映射，其中键是点的_uuid，值是相应的点 |
edges |
Map<Long, Edge> |
{} |
图中边的映射，其中键是边的_uuid，值是相应的边 |
Graph对象支持的方法：
方法 |
参数 |
返回值 |
描述 |
|---|---|---|---|
addNode() |
node: Node |
/ | 向nodes中新增一个点 |
addEdge() |
edge: Edge |
/ | 向edges中新增一条边 |
RequestConfig requestConfig = new RequestConfig();
requestConfig.setGraph("miniCircle");
Response response = driver.gql("MATCH p = ()-[]-()-[]-() RETURN p LIMIT 3", requestConfig);
Graph graph = response.alias("p").asGraph();
System.out.println("Nodes in each returned path:");
List<Path> paths = graph.getPaths();
for (Path path : paths) {
System.out.println(path.getNodeUUIDs());
}
System.out.println("----------");
System.out.println("Nodes in the graph formed by all returned paths:");
System.out.println(graph.getNodes().keySet());
Nodes in each returned path:
[6196955286285058052, 7998395137233256457, 8214567919347040275]
[6196955286285058052, 7998395137233256457, 8214567919347040275]
[6196955286285058052, 7998395137233256457, 5764609722057490441]
----------
Nodes in the graph formed by all returned paths:
[8214567919347040275, 6196955286285058052, 7998395137233256457, 5764609722057490441]
GraphSet
GraphSet对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
id |
String | / | 图ID |
name |
String | / | 图名称 |
totalNodes |
Long | / | 图中点的总数 |
totalEdges |
Long | / | 图中边的总数 |
shards |
List<String> | [] |
用来存储图的Shard服务器的ID列表 |
partitionBy |
String | Crc32 |
用于图分片的哈希函数，包括Crc32、Crc64WE、Crc64XZ和CityHash64 |
status |
String | / | 图状态，包括NORMAL、LOADING_SNAPSHOT、CREATING、DROPPING和SCALING |
description |
String | / | 图描述 |
slotNum |
int | 0 | 图分片使用的槽数量 |
Response response = driver.gql("SHOW GRAPH");
List<GraphSet> graphs = response.alias("_graph").asGraphSets();
for (GraphSet graph : graphs) {
System.out.println(graph.getName());
}
DFS_EG
cyber
netflow
Schema
Schema对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
name |
String | / | Schema名称 |
dbType |
DBType |
/ | Schema类型，包括DBNODE和DBEDGE |
properties |
List<Property> |
/ | 与Schema关联的属性列表 |
description |
String | / | Schema描述 |
total |
Long | 0 | 属于该Schema的点或边总数 |
id |
int | / | Schema ID |
stats |
List<SchemaStat> |
/ | 一个SchemaStat对象列表，每个SchemaStat对象包含属性name（schema名称）、dbType（schema类型）、fromSchema（起点schema）、toSchema（终点schema）以及count（点或边的数量） |
RequestConfig requestConfig = new RequestConfig();
requestConfig.setGraph("miniCircle");
Response response = driver.gql("SHOW NODE SCHEMA", requestConfig);
List<Schema> schemas = response.alias("_nodeSchema").asSchemas();
for (Schema schema : schemas) {
System.out.println(schema.getName());
}
default
account
celebrity
country
movie
Property
Property对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
name |
String | / | 属性名 |
type |
Ultipa.PropertyType |
/ | 属性值类型，包括INT32、UINT32、INT64、UINT64、FLOAT、DOUBLE、DECIMAL、STRING、TEXT、DATETIME、TIMESTAMP、BLOB、BOOL、POINT、LIST、SET、MAP、UUID、ID、FROM、FROM_UUID、TO、TO_UUID、IGNORE和UNSET |
subType |
List<Ultipa.PropertyType> |
/ | 如果type为LIST或SET，设定其元素类型；列表内只能包括一个UltipaPropertyType，且只能为INT32、UINT32、INT64、UINT64、FLOAT、DOUBLE、DECIMAL、STRING、TEXT、DATETIME或TIMESTAMP |
schema |
String | / | 属性关联的Schema名称 |
description |
String | / | 属性描述 |
lte |
Boolean | / | 属性是否加载到引擎（LTE） |
read |
Boolean | / | 属性是否可读 |
write |
Boolean | / | 属性是否可写 |
encrypt |
String | / | 属性加密方法，包括AES128、AES256、RSA和ECC |
decimalExtra |
DecimalExtra |
/ | DECIMAL类型的精度（1到65）和标度（0到30） |
RequestConfig requestConfig = new RequestConfig();
requestConfig.setGraph("miniCircle");
Response response = driver.gql("SHOW NODE account PROPERTY", requestConfig);
List<Property> properties = response.alias("_nodeProperty").asProperties();
for (Property property : properties) {
System.out.println(property.getName());
}
title
profile
age
name
logo
Attr
Attr对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
name |
String | / | 返回的别名 |
values |
List<Object> | / | 返回值 |
propertyType |
Ultipa.PropertyType |
/ | 返回结果的类型 |
RequestConfig requestConfig = new RequestConfig();
requestConfig.setGraph("miniCircle");
Response response = driver.gql("MATCH (n:account) RETURN n.name LIMIT 3", requestConfig);
Attr attr = response.alias("n.name").asAttr();
System.out.println("name: " + attr.getName());
System.out.println("values: " + attr.getValues());
System.out.println("type: " + attr.getPropertyType());
name: n.name
values: ['Velox', 'K03', 'Lunatique']
type: STRING
Table
Table对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
name |
String | / | 表名称 |
headers |
List<Header> |
/ | 表头 |
rows |
List<List<Object>> | / | 表中的行 |
Table对象支持的方法：
方法 |
返回值 |
描述 |
|---|---|---|
toKV() |
List<Value> |
将表中的所有行转换成字典列表 |
RequestConfig requestConfig = new RequestConfig();
requestConfig.setGraph("miniCircle");
Response response = driver.gql("MATCH (n:account) RETURN table(n._id, n.name) LIMIT 3", requestConfig);
Table table = response.get(0).asTable();
System.out.println("Header:");
for (Header header : table.getHeaders()) {
System.out.println(header.getPropertyName() + " - " + header.getPropertyType());
}
System.out.println("First Row:");
List<Value> rows = table.toKV();
if (!rows.isEmpty()) {
System.out.println(rows.get(0));
}
Header:
n._id - STRING
n.name - STRING
First Row:
{n._id=ULTIPA800000000000003B, n.name=Velox}
HDCGraph
HDCGraph对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
name |
String | / | HDC图名称 |
graphName |
String | / | HDC图的源图名称 |
status |
String | / | HDC图状态 |
stats |
String | / | HDC图的统计信息 |
isDefault |
String | / | 是否为源图的默认HDC图 |
hdcServerName |
String | / | 托管HDC图的HDC服务器名称 |
hdcServerStatus |
String | / | 托管HDC图的HDC服务器状态 |
config |
String | / | HDC图的配置 |
RequestConfig requestConfig = new RequestConfig();
requestConfig.setGraph("miniCircle");
Response response = driver.uql("hdc.graph.show()", requestConfig);
List<HDCGraph> hdcGraphs = response.alias("_hdcGraphList").asHDCGraphs();
for (HDCGraph hdcGraph : hdcGraphs) {
System.out.println(hdcGraph.getName() + " on " + hdcGraph.getHdcServerName());
}
miniCircle_hdc_graph on hdc-server-1
miniCircle_hdc_graph2 on hdc-server-2
Algo
Algo对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
name |
String | / | 算法名称 |
type |
String | / | 算法类型 |
version |
String | / | 算法版本 |
params |
List<AlgoParam> |
/ | 算法参数，每个AlgoParam有属性name和desc |
writeSupportType |
String | / | 算法支持的回写类型 |
canRollback |
String | / | 算法版本是否可回退 |
configContext |
String | / | 算法配置文件内容 |
Response response = driver.uql("show().hdc('hdc-server-1')");
List<Algo> algos = response.alias("_algoList").asAlgos();
for (Algo algo : algos) {
System.out.println(algo.getName() + " supports writeback types: " + algo.getWriteSupportType());
}
fastRP supports writeback types: DB,FILE
struc2vec supports writeback types: DB,FILE
Index
Index对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
id |
str | / | 索引ID |
name |
str | / | 索引名称 |
properties |
str | / | 索引关联的属性 |
schema |
str | / | 索引关联的schema |
status |
str | / | 索引状态 |
size |
str | / | 索引大小（单位：字节） |
dbType |
DBType |
/ | 索引类型，包括DBNODE和DBEDGE |
requestConfig = RequestConfig(graph="miniCircle")
response = Conn.gql("SHOW NODE INDEX", requestConfig)
indexList = response.alias("_nodeIndex").asIndexes()
for index in indexList:
print(index.schema, "-", index.properties, "-", index.schema)
account - gender(6),year - account
Privilege
Privilege对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
name |
str | / | 权限名称 |
level |
PrivilegeLevel |
/ | 权限级别，包括SystemLevel和Graphlevel |
response = Conn.uql("show().privilege()")
privileges = response.alias("_privilege").asPrivileges()
graphPrivileges = [privilege.name for privilege in privileges if privilege.level == PrivilegeLevel.Graphlevel]
print("Graph Privileges:", graphPrivileges)
systemPrivileges = [privilege.name for privilege in privileges if privilege.level == PrivilegeLevel.SystemLevel]
print("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', '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对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
name |
str | / | 策略名称 |
systemPrivileges |
List[str] | / | 策略中包含的系统权限 |
graphPrivileges |
Dict[str,List[str]] | / | 策略中包含的图集权限；在字典中，键是图集名称，值是相应的图集权限 |
propertyPrivileges |
PropertyPrivilege |
/ | 策略中包含的属性权限；PropertyPrivilege有node和edge两个属性，都是PropertyPrivilegeElement对象 |
policies |
List[str] | / | 策略中包含的其他策略 |
PropertyPrivilegeElement对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
read |
List[List[str]] | / | 一个元素均为列表的列表；内部的每个列表包含三个字符串，分别指定图、schema和属性 |
write |
List[List[str]] | / | 一个元素均为列表的列表；内部的每个列表包含三个字符串，分别指定图、schema和属性 |
deny |
List[List[str]] | / | 一个元素均为列表的列表；内部的每个列表包含三个字符串，分别指定图、schema和属性 |
response = Conn.uql("show().policy('Tester')")
policy = response.alias("_policy").asPolicies()
print("Graph Privileges:", policy.graphPrivileges)
print("System Privileges:", policy.systemPrivileges)
print("Property Privileges:")
print("- Node (Read):", policy.propertyPrivileges.node.read)
print("- Node (Write):", policy.propertyPrivileges.node.write)
print("- Node (Deny):", policy.propertyPrivileges.node.deny)
print("- Edge (Read):", policy.propertyPrivileges.edge.read)
print("- Edge (Write):", policy.propertyPrivileges.edge.write)
print("- Edge (Deny):", policy.propertyPrivileges.edge.deny)
print("Policies:", policy.policies)
Graph Privileges: {'amz': ['ALGO', 'INSERT', 'DELETE', 'UPSERT'], 'StoryGraph': ['UPDATE', 'READ']}
System Privileges: ['TRUNCATE', 'KILL', 'TOP']
Property Privileges:
- Node (Read): [['*', '*', '*']]
- Node (Write): []
- Node (Deny): []
- Edge (Read): []
- Edge (Write): [['amz', '*', '*'], ['alimama', '*', '*']]
- Edge (Deny): [['miniCircle', 'review', 'value, timestamp']]
Policies: ['sales', 'manager']
User
User对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
username |
str | / | 用户名 |
password |
str | / | 密码 |
createdTime |
datetime | / | 用户创建时间 |
systemPrivileges |
List[str] | / | 授予用户的系统权限 |
graphPrivileges |
Dict[str,List[str]] | / | 授予用户的图集权限；在字典中，键是图集名称，值是相应的图集权限 |
propertyPrivileges |
PropertyPrivilege |
/ | 授予用户的属性权限；PropertyPrivilege有node和edge两个属性，都是PropertyPrivilegeElement对象 |
policies |
List[str] | / | 授予用户的策略 |
PropertyPrivilegeElement对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
read |
List[List[str]] | / | 一个元素均为列表的列表；内部的每个列表包含三个字符串，分别指定图、schema和属性 |
write |
List[List[str]] | / | 一个元素均为列表的列表；内部的每个列表包含三个字符串，分别指定图、schema和属性 |
deny |
List[List[str]] | / | 一个元素均为列表的列表；内部的每个列表包含三个字符串，分别指定图、schema和属性 |
response = Conn.uql("show().user('johndoe')")
user = response.alias("_user").asUsers()
print("Created Time:", user.createdTime)
print("Graph Privileges:", user.graphPrivileges)
print("System Privileges:", user.systemPrivileges)
print("Property Privileges:")
print("- Node (Read):", user.propertyPrivileges.node.read)
print("- Node (Write):", user.propertyPrivileges.node.write)
print("- Node (Deny):", user.propertyPrivileges.node.deny)
print("- Edge (Read):", user.propertyPrivileges.edge.read)
print("- Edge (Write):", user.propertyPrivileges.edge.write)
print("- Edge (Deny):", user.propertyPrivileges.edge.deny)
print("Policies:", user.policies)
Created Time: 2025-04-02 11:08:38
Graph Privileges: {'amz': ['ALGO', 'INSERT', 'DELETE', 'UPSERT'], 'StoryGraph': ['UPDATE', 'READ']}
System Privileges: ['TRUNCATE', 'KILL', 'TOP']
Property Privileges:
- Node (Read): [['*', '*', '*']]
- Node (Write): []
- Node (Deny): []
- Edge (Read): []
- Edge (Write): [['amz', '*', '*'], ['alimama', '*', '*']]
- Edge (Deny): [['miniCircle', 'review', 'value, timestamp']]
Policies: ['sales', 'manager']
Process
Process对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
processId |
str | / | 进程ID |
processQuery |
str | / | 进程执行的语句 |
status |
str | / | 进程状态 |
duration |
str | / | 任务的运行时长（单位：秒） |
response = Conn.uql("top()")
processes = response.alias("_top").asProcesses()
for process in processes:
print(process.processId)
1049435
Job
Job对象包含以下属性：
属性 |
类型 |
默认 |
描述 |
|---|---|---|---|
id |
str | / | 作业ID |
graphName |
str | / | 作业执行所在的图名称 |
query |
str | / | 作业执行的语句 |
type |
str | / | 作业类型 |
errNsg |
str | / | 作业错误信息 |
result |
str | / | 作业结果 |
startTime |
str | / | 作业开始时间 |
endTime |
str | / | 作业结束时间 |
status |
str | / | 作业状态 |
progress |
str | / | 作业的进度更新，例如提示回写操作已开始 |
requestConfig = RequestConfig(graph="miniCircle")
response = Conn.gql("SHOW JOB", requestConfig)
jobs = response.alias("_job").asJobs()
for job in jobs:
if job.status == "FAILED":
print(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