0

我正在尝试使用 go 客户端创建用于更改 Dgraph 节点和谓词的 api，所以我的问题是我可以轻松地为创建操作创建 api，但是如果我想使用新字段更新节点或删除现有字段如何我实现了这一点，而且如果我想更改谓词名称以区分类型数据，那么我该如何实现呢？

你能解释一下如何在 Dgraph 中实现这一点，如果可能的话，请指导我找到正确的参考。这是我尝试使用 upsert 但没有给出我想要的东西

func (dg *Dgraph) UpdateOrderState(ctx context.Context, jwt string, id string, state string, chargeId string) ([]byte, error) {
    isPurchased := state == "purchased"
    o := &models.Order{State: state, StripeChargeId: chargeId, Purchased: isPurchased}
    md := metadata.New(map[string]string{"Content-Type": "application/grpc", "Authorization": jwt, "auth-token": jwt})
    ctx = metadata.NewOutgoingContext(ctx, md)

    ojson, err := json.Marshal(o)
    if err != nil {
        log.Printf("Could not marshal order - %s", err)
        return []byte{}, err // invalid order
    }

    mu := &api.Mutation{
        SetJson:   ojson,
        CommitNow: true,
    }

    query := `
        {
            node(func: type(Order)) @filter(uid("` + id + `")) {
                uid
            }
        }
    `
    txn := dg.client.NewTxn()

    req := &api.Request{
        Query:     query,
        Vars:      map[string]string{"$id": id},
        Mutations: []*api.Mutation{mu},
        CommitNow: true,
    }
    res, err := txn.Do(ctx, req)
    if err != nil {
        log.Printf("error updating order - %s", err)
        return []byte{}, err // skip if broken at this stage
    }

    // defer txn.Discard(ctx)
    log.Printf("ORDER UPDATED: %s", res)
    return res.GetJson(), nil
}

一切正常，但我的 dgraph 没有更新

4

0 回答 0