You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

求助:如何将PostgreSQL的JSONB数组扫描到Golang结构体数组

解决PostgreSQL JSONB数组到Go结构体数组的扫描问题

你遇到的问题是sqlx默认无法直接将PostgreSQL的JSONB数组类型映射到Go的结构体切片——单个JSONB字段能正常扫描,是因为sqlx(底层驱动)支持将单个JSONB解析为结构体,但数组类型需要自定义扫描逻辑。

解决步骤

  1. 定义自定义类型并实现sql.Scanner接口
    针对advanceAndRoomPayment切片,创建自定义类型并实现Scan方法,处理数据库返回的JSONB数组字节流:
import (
    "database/sql"
    "encoding/json"
    "fmt"
)

type otherPayments struct {
    DebitTo     int    `json:"debit_To" binding:"required"`
    CreditFrom  int    `json:"credit_from" binding:"required"`
    OverallType string `json:"overall_type" binding:"required"`
}

type advanceAndRoomPayment struct {
    PmID        int    `json:"pm_id" binding:"required"`
    PmName      string `json:"pm_name" binding:"required"`
    DebitTo     int    `json:"debit_To" binding:"required"`
    CreditFrom  int    `json:"credit_from" binding:"required"`
    OverallType string `json:"overall_type" binding:"required"`
}

// 自定义类型,用于接收JSONB数组
type AdvanceAndRoomPayments []advanceAndRoomPayment

// 实现sql.Scanner接口,解析数据库返回的JSONB数组
func (a *AdvanceAndRoomPayments) Scan(value interface{}) error {
    rawBytes, ok := value.([]byte)
    if !ok {
        return fmt.Errorf("invalid type for JSONB array: expected []byte, got %T", value)
    }
    return json.Unmarshal(rawBytes, a)
}
  1. 定义接收查询结果的结构体
    将advance_payment和room_payment字段类型改为自定义的AdvanceAndRoomPayments,并确保db标签与数据库字段名一致:
type BookingSettings struct {
    Initial         otherPayments         `db:"initial"`
    Cancellation    otherPayments         `db:"cancellation"`
    Updation        otherPayments         `db:"updation"`
    AdvancePayment  AdvanceAndRoomPayments `db:"advance_payment"`
    RoomPayment     AdvanceAndRoomPayments `db:"room_payment"`
}
  1. 执行查询并扫描结果
    使用sqlx的Get或Select方法执行查询,结果会自动通过自定义Scan方法解析JSONB数组:
// 假设db是已初始化的sqlx.DB实例
var settings BookingSettings
query := `SELECT initial, cancellation, updation, advance_payment, room_payment FROM booking_settings WHERE hotel_id = $1`
err := sqlx.Get(db, &settings, query, 123) // 替换为实际的hotel_id值
if err != nil {
    // 处理查询或扫描错误
    panic(err)
}

// 现在可正常访问settings.AdvancePayment和settings.RoomPayment

注意事项

  • 确保数据库中JSONB数组是合法的JSON格式,且每个元素的字段名与结构体的json标签完全匹配(包括大小写)。
  • 若使用pgx作为底层驱动,也可使用pgx/types.Jsonb类型,但上述方法基于标准库encoding/json,兼容性更强。

内容的提问来源于stack exchange,提问作者Zulfiqar Ali

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.08.20 11:18:38