Post 请求中空的正文，通过 PostgreSQL 和 json-api 返回

从现在开始，努力学习吧！本文《Post 请求中空的正文，通过 PostgreSQL 和 json-api 返回》主要讲解了等等相关知识点，我会在golang学习网中持续更新相关的系列文章，欢迎大家关注并积极留言建议。下面就先一起来看一下本篇正文内容吧，希望能帮到你！

在 post 请求之后，我期望将最后插入的记录编组到 json 中，但返回一个空正文。我哪方面做得不好？

package models


import (
    "encoding/json"
    "errors"
    "flag"
    "fmt"
    "log"
    "net/http"
    "strconv"

    "github.com/go-chi/chi"
    "github.com/google/jsonapi"
    "github.com/thedevsaddam/renderer"
    "github.com/xo/dburl"
)

var rnd = renderer.new()

var flagverbose = flag.bool("v", false, "verbose")

var flagurl = flag.string("url", "postgres://postgres:@127.0.0.1/sweb", "url")

// page represents a row from 'public.pages'.
type page struct {
    tag   string `jsonapi:"attr,tag"`      // tag
    body  string `jsonapi:"attr,body"`     // body
    slug  string `jsonapi:"attr,slug"`     // slug
    title string `jsonapi:"attr,title"`    // title
    id    int    `jsonapi:"primary,pages"` // id
    link  string `jsonapi:"attr,link"`     // link

    // xo fields
    _exists, _deleted bool
}

func (page page) jsonapilinks() *jsonapi.links {
    return &jsonapi.links{
        "self": fmt.sprintf("https://%d", page.id),
    }
}

我相信这就是罪魁祸首。插入一条记录后，它应该返回指定的最后插入的记录。

func (p *page) pinsert(db xodb) (*page, error) {
    var err error

    // if already exist, bail
    if p._exists {
        return p, errors.new("insert failed: already exists")
    }

    // sql insert query, primary key provided by sequence
    const sqlstr = `insert into public.pages (` +
        `tag, body, slug, title` +
        `) values (` +
        `$1, $2, $3, $4` +
        `) returning id, tag, body, title`

    // run query
    xolog(sqlstr, p.tag, p.body, p.slug, p.title)
    err = db.queryrow(sqlstr, p.tag, p.body, p.slug, p.title).scan(&p.id, &p.tag, &p.body, &p.title)
    if err != nil {
        return p, err
    }

    // set existence
    p._exists = true

    return p, nil
}

更新更新数据库中的页面并返回最后插入的记录。 这同样适用于更新功能

func (p *Page) Update(db XODB) (*Page, error) {
    var err error

    // if doesn't exist, bail
    if !p._exists {
        return p, errors.New("update failed: does not exist")
    }

    // if deleted, bail
    if p._deleted {
        return p, errors.New("update failed: marked for deletion")
    }

    // sql query
    const sqlstr = `UPDATE public.pages SET (` +
        `tag, body, slug, title` +
        `) = ( ` +
        `$1, $2, $3, $4` +
        `) WHERE id = $5`

    // run query
    XOLog(sqlstr, p.Tag, p.Body, p.Slug, p.Title, p.ID)
    _, err = db.Exec(sqlstr, p.Tag, p.Body, p.Slug, p.Title, p.ID)
    return p, err
}

func (p *Page) PSave(db XODB) (*Page, error) {
    if p.Exists() {
        return p.Update(db)
    }

    return p.PInsert(db)
}


func NewPage(w http.ResponseWriter, r *http.Request) {

    db, err := dburl.Open(*FlagURL)
    defer db.Close()
    if err != nil {
        log.Fatal(err)
    }

    var page Page

    //page := new(Page)

    if err := jsonapi.UnmarshalPayload(r.Body, &page); err != nil {
        http.Error(w, err.Error(), http.StatusInternalServerError)
        return
    }


    p, err := page.PSave(db)
    if err != nil {
        fmt.Println(err)
        if err := jsonapi.MarshalPayload(w, p); err != nil {
            http.Error(w, err.Error(), http.StatusInternalServerError)
            fmt.Println(err)
        }


    }


    w.Header().Set("Content-Type", jsonapi.MediaType)
    w.WriteHeader(http.StatusCreated)

}

这是我认为问题发生的最后一个函数。最后插入的记录应该被编组到 json 中。

解决方案

您的最后一段代码包含许多错误。相关部分（没有无用且令人困惑的 printlns）是：

p, err := page.psave(db)
if err != nil {
    if err := jsonapi.marshalpayload(w, p); err != nil {
        http.error(w, err.error(), http.statusinternalservererror)
    }
}

w.header().set("content-type", jsonapi.mediatype)
w.writeheader(http.statuscreated)

主要错误是 json.marshalpayload 仅在 err != nil 时调用。换句话说，您仅在保存页面失败时序列化该页面。

第二个错误是 jsonapi.marshalpayload 将在 http.responsewriter 上调用 write。这将对 header().set 和 writeheader 的所有后续调用变为无操作。

更正确的代码如下所示。

// 1. Save the page in the database, bail on error
p, err := page.PSave(db)
if err != nil {
    http.Error(w, err.Error(), http.StatusInternalServerError)
    return 
}

// 2. Marshal the page into an intermediate buffer, bail on error
var buf bytes.Buffer
if err := jsonapi.MarshalPayload(&buf, p); err != nil {
    http.Error(w, err.Error(), http.StatusInternalServerError)
    return 
}

// 3. Write the entire response; failures to write the intermediate buffer
// cannot be communicated over HTTP
w.Header().Set("Content-Type", jsonapi.MediaType)
w.WriteHeader(http.StatusCreated)
if _, err := buf.WriteTo(w); err != nil {
    log.Printf("failed to write response: %v", err)
    return 
}

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《Post 请求中空的正文，通过 PostgreSQL 和 json-api 返回》文章吧，也可关注golang学习网公众号了解相关技术文章。