weave_sqlx_old.go

// an abbreviated, fictional example of a database method you might find at Weave
func (p personService) CreateOrUpdate(ctx context.Context, person app.Person) (app.Person, error) {
  var result app.Person

  query := `
    INSERT INTO persons
    (
      id,
      first_name,
      last_name,
      created_at,
      updated_at
    )
    VALUES 
    (
      $1,
      $2,
      $3,
      now(),
      now()
    )
    ON CONFLICT(id) DO UPDATE SET
    (
      first_name = $2,
      last_name = $3,
      updated_at = now()
    )
    RETURNING
      id,
      first_name,
      last_name,
      created_at,
      updated_at;
      `

  row := hos.DB.QueryRowContext(
    ctx,
    query,
    uuid.NewV4(),
    person.FirstName,
    person.LastName,
  )

  err := row.Scan(
    &result.ID,
    &result.FirstName,
    &result.LastName,
    &result.CreatedAt,
    &result.UpdatedAt,
  )

  if err != nil {
    return app.Person{}, werror.Wrap(err, "failed to insert or update person")
  }

  return result, nil
}