Graph queries

curl -X POST "https://$OC_HOST/v1/tenants/$OC_TENANT/cypher" \
  -H "Authorization: Bearer $OC_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "cypher": "MATCH (o:orders {id: \"01JTRX9KQ3YH8K2WMX0F5JZAB7\"}) RETURN o.status, o.amount_cents",
    "default_schema": "shop.orders"
  }'

// No SDK wraps /cypher yet - all four tabs call the route directly.
const BASE = `https://${process.env.OC_HOST}/v1/tenants/${process.env.OC_TENANT}`;
const H = {
  "Authorization": `Bearer ${process.env.OC_TOKEN}`,
  "Content-Type":  "application/json",
};

async function cypher(query: string, defaultSchema?: string, params = {}) {
  const res = await fetch(`${BASE}/cypher`, {
    method: "POST",
    headers: H,
    body: JSON.stringify({
      cypher:         query,
      default_schema: defaultSchema,
      params,
    }),
  });
  if (!res.ok) throw new Error(await res.text());
  return res.json();
}

const out = await cypher(
  `MATCH (o:orders {id: "01JTRX9KQ3YH8K2WMX0F5JZAB7"})
   RETURN o.status, o.amount_cents`,
  "shop.orders",
);
console.log(out.kind, out.rows);

# No SDK wraps /cypher yet - all four tabs call the route directly.
import os, requests

BASE = f"https://{os.environ['OC_HOST']}/v1/tenants/{os.environ['OC_TENANT']}"
H    = {"Authorization": f"Bearer {os.environ['OC_TOKEN']}"}

def cypher(query, default_schema=None, params=None):
    r = requests.post(
        f"{BASE}/cypher",
        headers=H,
        json={
            "cypher":         query,
            "default_schema": default_schema,
            "params":         params or {},
        },
    )
    r.raise_for_status()
    return r.json()

out = cypher(
    'MATCH (o:orders {id: "01JTRX9KQ3YH8K2WMX0F5JZAB7"}) '
    'RETURN o.status, o.amount_cents',
    default_schema="shop.orders",
)
print(out["kind"], out["rows"])

// No SDK wraps /cypher yet - all four tabs call the route directly.
type cypherReq struct {
    Cypher        string         `json:"cypher"`
    DefaultSchema string         `json:"default_schema,omitempty"`
    Params        map[string]any `json:"params,omitempty"`
}

func cypher(ctx context.Context, req cypherReq) (map[string]any, error) {
    body, _ := json.Marshal(req)
    hreq, _ := http.NewRequestWithContext(ctx, "POST",
        "https://"+os.Getenv("OC_HOST")+"/v1/tenants/"+os.Getenv("OC_TENANT")+"/cypher",
        bytes.NewReader(body))
    hreq.Header.Set("Authorization", "Bearer "+os.Getenv("OC_TOKEN"))
    hreq.Header.Set("Content-Type", "application/json")

    resp, err := http.DefaultClient.Do(hreq)
    if err != nil { return nil, err }
    defer resp.Body.Close()

    var out map[string]any
    err = json.NewDecoder(resp.Body).Decode(&out)
    return out, err
}

out, err := cypher(ctx, cypherReq{
    Cypher: `MATCH (o:orders {id: "01JTRX9KQ3YH8K2WMX0F5JZAB7"})
             RETURN o.status, o.amount_cents`,
    DefaultSchema: "shop.orders",
})
if err != nil { /* handle */ }
fmt.Println(out["kind"], out["rows"])

curl -X POST "https://$OC_HOST/v1/tenants/$OC_TENANT/cypher" \
  -H "Authorization: Bearer $OC_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "cypher": "MATCH (o:orders) WHERE o.status = \"paid\" AND o.amount_cents > 5000 RETURN o.id, o.amount_cents",
    "default_schema": "shop.orders"
  }'

const out = await cypher(
  `MATCH (o:orders)
   WHERE o.status = "paid" AND o.amount_cents > 5000
   RETURN o.id, o.amount_cents`,
  "shop.orders",
);

out = cypher(
    'MATCH (o:orders) '
    'WHERE o.status = "paid" AND o.amount_cents > 5000 '
    'RETURN o.id, o.amount_cents',
    default_schema="shop.orders",
)

out, err := cypher(ctx, cypherReq{
    Cypher: `MATCH (o:orders)
             WHERE o.status = "paid" AND o.amount_cents > 5000
             RETURN o.id, o.amount_cents`,
    DefaultSchema: "shop.orders",
})

curl -X POST "https://$OC_HOST/v1/tenants/$OC_TENANT/cypher" \
  -H "Authorization: Bearer $OC_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "cypher": "MATCH (o:orders {id: \"01JTRX9KQ3YH8K2WMX0F5JZAB7\"})-[:placed_by]->(c) RETURN c.name, c.country",
    "default_schema": "shop.orders"
  }'

const out = await cypher(
  `MATCH (o:orders {id: "01JTRX9KQ3YH8K2WMX0F5JZAB7"})-[:placed_by]->(c)
   RETURN c.name, c.country`,
  "shop.orders",
);

out = cypher(
    'MATCH (o:orders {id: "01JTRX9KQ3YH8K2WMX0F5JZAB7"})-[:placed_by]->(c) '
    'RETURN c.name, c.country',
    default_schema="shop.orders",
)

out, err := cypher(ctx, cypherReq{
    Cypher: `MATCH (o:orders {id: "01JTRX9KQ3YH8K2WMX0F5JZAB7"})-[:placed_by]->(c)
             RETURN c.name, c.country`,
    DefaultSchema: "shop.orders",
})

curl -X POST "https://$OC_HOST/v1/tenants/$OC_TENANT/cypher" \
  -H "Authorization: Bearer $OC_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "cypher": "MATCH (o:orders {id: \"01JTRX9KQ3YH8K2WMX0F5JZAB7\"})-[:placed_by]->(c)-[:referrer]->(r) RETURN r.name, r.country",
    "default_schema": "shop.orders"
  }'

// order -> customer -> the customer who referred them
const out = await cypher(
  `MATCH (o:orders {id: "01JTRX9KQ3YH8K2WMX0F5JZAB7"})-[:placed_by]->(c)-[:referrer]->(r)
   RETURN r.name, r.country`,
  "shop.orders",
);

# order -> customer -> the customer who referred them
out = cypher(
    'MATCH (o:orders {id: "01JTRX9KQ3YH8K2WMX0F5JZAB7"})'
    '-[:placed_by]->(c)-[:referrer]->(r) '
    'RETURN r.name, r.country',
    default_schema="shop.orders",
)

// order -> customer -> the customer who referred them
out, err := cypher(ctx, cypherReq{
    Cypher: `MATCH (o:orders {id: "01JTRX9KQ3YH8K2WMX0F5JZAB7"})
             -[:placed_by]->(c)-[:referrer]->(r)
             RETURN r.name, r.country`,
    DefaultSchema: "shop.orders",
})

curl -X POST "https://$OC_HOST/v1/tenants/$OC_TENANT/cypher" \
  -H "Authorization: Bearer $OC_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "cypher": "MATCH p = (c:customers {id: \"01JTRX1H4Q9P0N2WMX0F5JZ001\"})-[:referrer*1..3]->(up) RETURN up.name, length(p)",
    "default_schema": "shop.customers"
  }'

// Everyone up to 3 referral hops above this customer.
const out = await cypher(
  `MATCH p = (c:customers {id: "01JTRX1H4Q9P0N2WMX0F5JZ001"})-[:referrer*1..3]->(up)
   RETURN up.name, length(p)`,
  "shop.customers",
);

# Everyone up to 3 referral hops above this customer.
out = cypher(
    'MATCH p = (c:customers {id: "01JTRX1H4Q9P0N2WMX0F5JZ001"})'
    '-[:referrer*1..3]->(up) '
    'RETURN up.name, length(p)',
    default_schema="shop.customers",
)

// Everyone up to 3 referral hops above this customer.
out, err := cypher(ctx, cypherReq{
    Cypher: `MATCH p = (c:customers {id: "01JTRX1H4Q9P0N2WMX0F5JZ001"})
             -[:referrer*1..3]->(up)
             RETURN up.name, length(p)`,
    DefaultSchema: "shop.customers",
})

curl -X POST "https://$OC_HOST/v1/tenants/$OC_TENANT/cypher" \
  -H "Authorization: Bearer $OC_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "cypher": "MATCH (o:orders) WHERE o.status = \"paid\" RETURN o.id AS order_id, o.amount_cents AS cents ORDER BY o.amount_cents DESC SKIP 0 LIMIT 10",
    "default_schema": "shop.orders"
  }'

const out = await cypher(
  `MATCH (o:orders) WHERE o.status = "paid"
   RETURN o.id AS order_id, o.amount_cents AS cents
   ORDER BY o.amount_cents DESC
   SKIP 0 LIMIT 10`,
  "shop.orders",
);

out = cypher(
    'MATCH (o:orders) WHERE o.status = "paid" '
    'RETURN o.id AS order_id, o.amount_cents AS cents '
    'ORDER BY o.amount_cents DESC '
    'SKIP 0 LIMIT 10',
    default_schema="shop.orders",
)

out, err := cypher(ctx, cypherReq{
    Cypher: `MATCH (o:orders) WHERE o.status = "paid"
             RETURN o.id AS order_id, o.amount_cents AS cents
             ORDER BY o.amount_cents DESC
             SKIP 0 LIMIT 10`,
    DefaultSchema: "shop.orders",
})

curl -X POST "https://$OC_HOST/v1/tenants/$OC_TENANT/cypher" \
  -H "Authorization: Bearer $OC_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "cypher": "MATCH (o:orders) WHERE o.status = $want RETURN o.id",
    "default_schema": "shop.orders",
    "params": { "want": "paid" }
  }'

const out = await cypher(
  `MATCH (o:orders) WHERE o.status = $want RETURN o.id`,
  "shop.orders",
  { want: "paid" },
);

out = cypher(
    "MATCH (o:orders) WHERE o.status = $want RETURN o.id",
    default_schema="shop.orders",
    params={"want": "paid"},
)

out, err := cypher(ctx, cypherReq{
    Cypher:        `MATCH (o:orders) WHERE o.status = $want RETURN o.id`,
    DefaultSchema: "shop.orders",
    Params:        map[string]any{"want": "paid"},
})

# CREATE - insert one node. Returns {"kind":"insert","rows_inserted":1}
CREATE (o:orders {
  id: "01JTRXNEW00000000000000001",
  customer: "01JTRX1H4Q9P0N2WMX0F5JZ001",
  amount_cents: 4200,
  status: "pending",
  notes: "gift wrap",
  placed_ms: 1714480000000
})

# MERGE - insert only if absent. Returns {"kind":"merge","rows_inserted":0|1}
MERGE (c:customers {
  id: "01JTRX1H4Q9P0N2WMX0F5JZ009",
  name: "Nia Blake",
  country: "GB"
})

# SET - update properties on an anchored node.
# Returns {"kind":"update","rows_affected":1}
MATCH (o:orders {id: "01JTRXNEW00000000000000001"})
SET o.status = "paid"

# DELETE - retire an anchored node and its derived index/edge state.
# Returns {"kind":"delete","rows_deleted":1}
MATCH (o:orders {id: "01JTRXNEW00000000000000001"})
DELETE o

curl -X POST "https://$OC_HOST/v1/tenants/$OC_TENANT/cypher" \
  -H "Authorization: Bearer $OC_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "cypher": "MATCH (o:orders {id: \"01JTRXNEW00000000000000001\"}) SET o.status = \"paid\"",
    "default_schema": "shop.orders"
  }'

const out = await cypher(
  `MATCH (o:orders {id: "01JTRXNEW00000000000000001"}) SET o.status = "paid"`,
  "shop.orders",
);

out = cypher(
    'MATCH (o:orders {id: "01JTRXNEW00000000000000001"}) SET o.status = "paid"',
    default_schema="shop.orders",
)

out, err := cypher(ctx, cypherReq{
    Cypher:        `MATCH (o:orders {id: "01JTRXNEW00000000000000001"}) SET o.status = "paid"`,
    DefaultSchema: "shop.orders",
})