Телеграмм чат группы tarantoolru страница 7503

Size: a a a

Tarantool

1105 membersпожаловаться на группу

2020 November 30

Pavel in Tarantool

либо втыкать unpack в луашку

источник

17:40пожаловаться #1

Pavel in Tarantool

// CallAsync sends a call to registered tarantool function and returns Future.
// It uses request code for tarantool 1.6, so future's result is always array of arrays

источник

17:40пожаловаться #2

Pavel in Tarantool

MAPC

function select_few_rec_by_primary(array)
    out = {}
    for i = 1, #array do
        t = box.space.first_space:select{array[i]}
        if #t > 0 then
            t = t[1]:totable()
            p = box.space.second_space:select{t[2]}
            if #p > 0 then
                t[#t+1] = p[1][3]
            else
                t[#t+1] = nil
            end
            out[#out+1] = t
        end
        fiber.yield()
    end

    return out
end

А это гошный кусок 
func (t tar) Get(keys []int64) ([]model.ActualInfo, error) {
  actualInfo := make([]model.ActualInfo, 0, len(keys))
  fut := datasource.Tarantool.CallAsync("select_few_rec_by_primary", []interface{}{keys})
  err := fut.GetTyped(&actualInfo)

  if err != nil {
    log.Println(err)
    tarantoolError, ok := err.(tarantool.ClientError)
    if !ok {
      return nil, err
    }

    if tarantoolError.Code == tarantool.ErrConnectionClosed {
      return nil, datasource.ReconnectTarantool(datasource.Tarantool, 1)
    }
  }

  return actualInfo, nil
}

тут, кстати, можно сразу callTyped использовать

источник

17:44пожаловаться #3

MAPC in Tarantool

Pavel

actualInfo := make([]model.ActualInfo, 0, len(keys))

По-моему из call результат возвращается в массиве, т.е вам нужно его распаковывать в [][]model.ActualInfo

не, так не канает
msgpack: invalid code ce decoding map length

источник

17:45пожаловаться #4

Alexey Kuzin in Tarantool

MAPC

function select_few_rec_by_primary(array)
    out = {}
    for i = 1, #array do
        t = box.space.first_space:select{array[i]}
        if #t > 0 then
            t = t[1]:totable()
            p = box.space.second_space:select{t[2]}
            if #p > 0 then
                t[#t+1] = p[1][3]
            else
                t[#t+1] = nil
            end
            out[#out+1] = t
        end
        fiber.yield()
    end

    return out
end

А это гошный кусок 
func (t tar) Get(keys []int64) ([]model.ActualInfo, error) {
  actualInfo := make([]model.ActualInfo, 0, len(keys))
  fut := datasource.Tarantool.CallAsync("select_few_rec_by_primary", []interface{}{keys})
  err := fut.GetTyped(&actualInfo)

  if err != nil {
    log.Println(err)
    tarantoolError, ok := err.(tarantool.ClientError)
    if !ok {
      return nil, err
    }

    if tarantoolError.Code == tarantool.ErrConnectionClosed {
      return nil, datasource.ReconnectTarantool(datasource.Tarantool, 1)
    }
  }

  return actualInfo, nil
}