transaction-function.go

func executeQuery(tx neo4j.Transaction) (interface{}, error) {
  var (
    counter int
    result  neo4j.Result
    err     error
  )

  if result, err = tx.Run(query, nil); err != nil {
    return nil, err
  }

  processHeader(result)
  for result.Next() {
    processRecord(result.Record())
    counter++
  }
  if err = result.Err(); err != nil {
    return nil, err
  }

  return counter, nil
}