1 回答

TA貢獻2037條經(jīng)驗 獲得超6個贊
我們總是conn.*Typed()在我們的項目中使用查詢來做到這一點。
首先,您需要在 Tarantool 中定義表示元組的結(jié)構(gòu)。然后你需要為它實現(xiàn)兩個接口,msgpack.CustomDecoder和msgpack.CustomEncoder。
你應(yīng)該能夠做這樣的事情:
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
}
注意解碼器。它包含計數(shù)字段。這對于非中斷遷移是必要的。
例如,如果 msgpack 數(shù)組的字段數(shù)少于我們嘗試解碼的字段數(shù),則不會出現(xiàn)任何問題。
選擇查詢的響應(yīng)是 msgpack 元組的順序數(shù)組,因此如果我們不跳過未知字段,則結(jié)構(gòu)的下一個實例的解碼將不會從下一個元組的開頭開始。
然后你可以嘗試做查詢:
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
}
在我看來,這是最好的方法,因為反射、類型轉(zhuǎn)換和類型斷言最少,如果使用不慎,可能會導(dǎo)致生產(chǎn)中的恐慌。這也是一種性能更高的方式。
- 1 回答
- 0 關(guān)注
- 114 瀏覽
添加回答
舉報