Method get

service/netquery/runtime_query_runner.go:47–77

(keyOrPrefix string)

}

func (runner *RuntimeQueryRunner) get(keyOrPrefix string) ([]record.Record, error) {
	query := strings.TrimPrefix(
		keyOrPrefix,
		runner.keyPrefix,
	)

	log.Infof("netquery: executing custom SQL query: %q", query)

	var result []map[string]interface{}
	if err := runner.db.Execute(context.Background(), query, orm.WithResult(&result)); err != nil {
		return nil, fmt.Errorf("failed to perform query %q: %w", query, err)
	}

	// we need to wrap the result slice into a map as portbase/database attempts
	// to inject a _meta field.
	blob, err := json.Marshal(map[string]interface{}{
		"result": result,
	})
	if err != nil {
		return nil, fmt.Errorf("failed to marshal result: %w", err)
	}

	// construct a new record wrapper that uses the already prepared JSON blob.
	key := fmt.Sprintf("%s:%s", runner.reg.DatabaseName(), keyOrPrefix)
	wrapper, err := record.NewWrapper(key, new(record.Meta), dsd.JSON, blob)
	if err != nil {
		return nil, fmt.Errorf("failed to create record wrapper: %w", err)
	}

	return []record.Record{wrapper}, nil
}