Aerospike Query Return 가장 높은 값

Question

Aerospike 데이터베이스에 대한 쿼리를 만들려고합니다. 특정 데이터베이스에서 가장 높은 값을 반환합니다. MAX() 함수가 MySQL에서 작동하는 방식과 비슷합니다. 예를 들어,이 같은 집합을했다 :

+--------------+---------+ 
| filename  | version | 
+--------------+---------+ 
| alphabet.doc | 4  | 
| people.doc | 2  | 
| alphabet.doc | 6  | 
| people.doc | 3  | 
+--------------+---------+ 

난 단지 가장 높은 버전의 파일 이름을 반환하는 것입니다 필요한 것은. 현재로서는 다음과 같은 필터를 추가 할 수 있습니다.

stmt := db.NewStatement(DBns, DBset, "filename", "version") 
    stmt.Addfilter(db.NewEqualFilter("filename", "alphabet.doc")) 

    // run database query 
    records := runQuery(stmt) 

누구나 알고 계십니까?

Answer 1

쿼리에 Lua UDF (사용자 정의 함수)를 적용하여 결과를 효율적으로 필터링 할 수 있습니다.

예. 여기에 max를 사용하여 레코드를 리턴하는 스트림 UDF가 있습니다. 버전 번호 : https://gist.github.com/jhecking/b98783bea7564d610ea291b5ac47808c

하는 당신은 찾을 수 있습니다 여기 요지로 완전히 동작하는 예제를 업로드 한

stmt := NewStatement(ns, set) 
    recordset, _ := client.QueryAggregate(nil, stmt, "udfFilter", "maxVersion") 

    for rec := range recordset.Results() { 
    res := rec.Record.Bins["SUCCESS"].(map[interface{}]interface{}) 
    fmt.Printf("filename with max. version: %s (ver. %d)\n", res["filename"], res["version"]) 
} 

:

function maxVersion(stream, bin) 
    -- The stream function cannot return record objects directly, 
    -- so we have to map to a Map data type first. 
    local function toArray(rec) 
    local result = map() 
    result['filename'] = rec['filename'] 
    result['version'] = rec['version'] 
    return result 
    end 
    local function findMax(a, b) 
    if a.version > b.version then 
     return a 
    else 
     return b 
    end 
    end 
    return stream : map(toArray) : reduce(findMax) 
end 

는이 같은 기능을 수행 할 이동 클라이언트를 사용하여 쿼리 집계를 위해 스트림 UDF를 사용하는 방법에 대한 자세한 정보는 여기를 참조하십시오. http://www.aerospike.com/docs/guide/aggregation.html