Files
zeekay f5aaeb712e Hanzo Graph — the engine, on zapdb, ZAP-native
Derived from Dgraph (github.com/dgraph-io/dgraph) at commit 64804bd2, Apache-2.0.
See NOTICE.

WHAT THIS IS. The graph engine as a Go library: posting lists, the DQL parser,
the type and tokenizer system, the index and schema layers, and the wire types.
39,170 lines of the upstream's 166,337.

THE STORE is github.com/luxfi/zapdb, a Badger fork that kept the package name,
the subpackages (options, pb, y) and the API — Open, OpenManaged, DB, Options —
so the 74 import sites are aliased rather than rewritten.

THE CODEC is ZAP. zapdb serializes with ZAP, not protobuf: its pb package builds
the ZAP types by default and the protobuf ones only under `-tags grpc`, a path
that does not compile (table/builder.go calls pb.Marshal, which that tag
removes). One call site in posting needed converting; every other type here is
Hanzo's own protobuf and is untouched.

NO TRANSPORT. An embedded engine dials nothing, so nothing here imports
google.golang.org/grpc. Removed: 20 transport functions in x, the generated
service stubs for Raft, Zero and Worker (1,657 lines), and the JWT helper —
identity belongs to IAM. The core called none of them.

NOT KEPT: worker, conn, raftwal, the cluster commands, the GraphQL layer and the
test harnesses. `query`, the DQL execution engine, went with them because it
depends on worker; parsing DQL is available here, executing it is not.

The history of the upstream project lives at github.com/dgraph-io/dgraph. This
repository begins at the derivation because three quarters of that history
describes code this fork does not carry.
2026-08-20 21:26:27 -07:00

101 lines
1.4 KiB
Go

/*
* SPDX-FileCopyrightText: © 2017-2026 Istari Digital, Inc.
* SPDX-License-Identifier: Apache-2.0
*/
package dql
import (
"testing"
"github.com/stretchr/testify/require"
)
func TestParseDQL(t *testing.T) {
testCases := []string{
`{ set {_:a <name> "Alice" .}}`,
"schema{}",
`upsert {
query {
ns(func: eq(dgraph.namespace.name, "ns1")) {
q as var
dgraph.namespace.id
}
}
mutation {
delete {
uid(q) * * .
}
}
}`,
`{
q(func: eq(dgraph.namespace.name, "ns1")) {
uid
dgraph.type
dgraph.namespace.id
}
}`,
` query test($a: int) {
q(func: uid(0x1)) {
x as count(uid)
p : math(x + $a)
}
}`,
`{
me(func: uid(1)) {
Upvote {
u as Author
}
count(val(u))
}
}`,
`{
user(func: uid(0x0a)) {
...fragmenta,...fragmentb
friends {
name
}
...fragmentc
hobbies
...fragmentd
}
me(func: uid(0x01)) {
...fragmenta
...fragmentb
}
}
fragment fragmenta {
name
}
fragment fragmentb {
id
}
fragment fragmentc {
name
}
fragment fragmentd {
id
}`,
`{
set {
<name> <is> <something> .
<hometown> <is> <san/francisco> .
}
delete {
<name> <is> <something-else> .
}
}`,
`{
<user-query>(func: uid(0x1)) {
name
}
}`,
}
for _, tc := range testCases {
_, err := ParseDQL(tc)
require.NoError(t, err)
}
}