如何使用 Go 连接器将 Tarantool 选择结果序列化为就绪结构

Question

请描述一种如何将go-tarantool连接器中的选择结果序列化为 struct 以能够访问字段的方法tuple.key1.key2

Answer 1

我们总是conn.*Typed()在我们的项目中使用查询来做到这一点。

首先，您需要在 Tarantool 中定义表示元组的结构。然后你需要为它实现两个接口，msgpack.CustomDecoder和msgpack.CustomEncoder。

你应该能够做这样的事情：

type Session struct {

    ID         string

    UserID     int64 

}

func (s *Session) EncodeMsgpack(e *msgpack.Encoder) error {

    if err := e.EncodeArrayLen(2); err != nil {

        return err

    }

  

    if err := e.EncodeString(s.ID); err != nil {

        return err

    }

  

    if err := e.EncodeInt64(s.UserID); err != nil {

        return err

    }

    return nil

}

func (s *Session) DecodeMsgpack(d *msgpack.Decoder) error {

    l, err := d.DecodeArrayLen()

    if err != nil {

        return err

    }

  

    decodedFields := 1

    if s.ID, err = d.DecodeString(); err != nil || decodedFields == l {

        return err

    }

    decodedFields++

    if s.UserID, err = d.DecodeInt64(); err != nil || decodedFields == l {

        return err

    }

 

    for i := 0; i < l-decodedFields; i++ {

        _ = d.Skip()

    }

  

    return nil

}

注意解码器。它包含计数字段。这对于非中断迁移是必要的。

例如，如果 msgpack 数组的字段数少于我们尝试解码的字段数，则不会出现任何问题。

选择查询的响应是 msgpack 元组的顺序数组，因此如果我们不跳过未知字段，则结构的下一个实例的解码将不会从下一个元组的开头开始。

然后你可以尝试做查询：

func() ([]Session, error) {

    const userID = 822

    

    var sessions []Session

    err := conn.SelectTyped("session", "user", 0, 10, tarantool.IterEq, []interface{}{userID}, &resp)

    if err != nil {

        return nil, err

    }

    if len(resp) == 0 {

        return nil, nil

    }

  

    return sessions, nil

}

在我看来，这是最好的方法，因为反射、类型转换和类型断言最少，如果使用不慎，可能会导致生产中的恐慌。这也是一种性能更高的方式。