通过Gorm向PostgreSQL插入时间数组时的类型转换问题

问题分析 #

你遇到的报错是因为Gorm默认无法直接将[]time.Time类型编码为PostgreSQL的timestamptz[]类型，缺少对应的编码规则。pq.Array完全支持时间数组，这是无需改用Unix时间戳的最优解决方案。

解决方案 #

方法1：使用pq.Array包装time.Time数组（推荐） #

修改结构体字段类型为pq.Array[time.Time]，保留原Gorm类型标签：

import "github.com/lib/pq"

type Instance struct {
    UpdatedAt     time.Time          `gorm:"index"`
    InstanceId    string             `gorm:"primaryKey"`
    InstanceName  string
    InstanceType  string
    InstanceState string
    LaunchTime    time.Time
    ExitTime      time.Time
    PausedTimes   pq.Array[time.Time] `gorm:"type:timestamptz[]"`
    ResumedTimes  pq.Array[time.Time] `gorm:"type:timestamptz[]"`
}

插入数据时直接用pq.Array[time.Time]类型赋值：

dbConnection.Clauses(clause.OnConflict{
    UpdateAll: true,
}).Create(&model.InstanceDB{
    InstanceId:   "1",
    PausedTimes:  pq.Array[time.Time]{time.Now().UTC(), time.Now().UTC().Add(50000)},
    ResumedTimes: pq.Array[time.Time]{time.Now().UTC()},
})

注意：建议统一使用time.UTC而非time.Local，避免时区不匹配引发的潜在问题，确保数据库存储时间与应用逻辑一致。

方法2：自定义Gorm类型转换器 #

若不想修改结构体字段类型，可注册自定义转换器让Gorm支持[]time.Time与timestamptz[]的转换：

import (
    "fmt"
    "database/sql/driver"
    "gorm.io/gorm"
    "gorm.io/gorm/schema"
    "github.com/lib/pq"
)

func init() {
    gorm.RegisterDataType("timestamptz[]", schema.DataType{
        SQLType: "timestamptz[]",
        Converter: &TimeArrayConverter{},
    })
}

type TimeArrayConverter struct{}

func (c *TimeArrayConverter) Scan(value interface{}) (interface{}, error) {
    arr, ok := value.(pq.Array[time.Time])
    if !ok {
        return nil, fmt.Errorf("failed to scan timestamptz[] into []time.Time")
    }
    return []time.Time(arr), nil
}

func (c *TimeArrayConverter) Value(value interface{}) (driver.Value, error) {
    times, ok := value.([]time.Time)
    if !ok {
        return nil, fmt.Errorf("failed to convert []time.Time to timestamptz[]")
    }
    return pq.Array[time.Time](times), nil
}

注册完成后，原结构体的[]time.Time字段可直接正常使用，无需修改类型。

验证 #

插入后可通过查询确认数据存储正确性：

var instance model.InstanceDB
dbConnection.Where("instance_id = ?", "1").First(&instance)
// 输出instance.PausedTimes和instance.ResumedTimes，验证时间数组是否正确解析

内容的提问来源于stack exchange，提问作者Priyansh Choudhary