Method parseRecords

query_result.go:127–154

(raw_result_set []interface{})

}

func (qr *QueryResult) parseRecords(raw_result_set []interface{}) {
	records, _ := redis.Values(raw_result_set[1], nil)
	qr.results = make([]*Record, len(records))

	for i, r := range records {
		cells, _ := redis.Values(r, nil)
		values := make([]interface{}, len(cells))

		for idx, c := range cells {
			t := qr.header.column_types[idx]
			switch t {
			case COLUMN_SCALAR:
				s, _ := redis.Values(c, nil)
				values[idx] = qr.parseScalar(s)
				break
			case COLUMN_NODE:
				values[idx] = qr.parseNode(c)
				break
			case COLUMN_RELATION:
				values[idx] = qr.parseEdge(c)
				break
			default:
				panic("Unknown column type.")
			}
		}
		qr.results[i] = recordNew(values, qr.header.column_names)
	}
}

func (qr *QueryResult) parseProperties(props []interface{}) map[string]interface{} {
	// [[name, value type, value] X N]