wangjia
f3471ae139
- config 增 DB_DRIVER(mysql 默认 | sqlite);DSN 对 sqlite 为文件路径
- db.OpenDriver 按驱动分派:sqlite 用 modernc(纯 Go 免 CGO)+ WAL/
busy_timeout/foreign_keys/_txlock=immediate;mysql 路径不变
- store.Open 分派;mysql 保留 UTC/collation 断言,sqlite 跳过
- 迁移拆 migrations/{mysql,sqlite}/ 双套,embed 双 FS,migrate 按驱动选源
与 golang-migrate 驱动;修复 m.Close() 误关调用方 *sql.DB 的坑
- cmd/migrate 串入 DB_DRIVER;集成测试 MigrateUp 签名更新
- 新增 SQLite 时间往返 smoke 测试与端到端迁移测试(免 docker)
Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
62 lines
1.7 KiB
Go
62 lines
1.7 KiB
Go
package db
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
// TestSQLiteTimeRoundTrip de-risks the migration translation: confirm modernc
|
|
// SQLite reads a DATETIME column back into a Go time.Time (UTC) correctly.
|
|
func TestSQLiteTimeRoundTrip(t *testing.T) {
|
|
d, err := OpenDriver("sqlite", ":memory:")
|
|
if err != nil {
|
|
t.Fatalf("open: %v", err)
|
|
}
|
|
defer d.Close()
|
|
|
|
if _, err := d.Exec(`CREATE TABLE t (
|
|
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
|
created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|
expires_at DATETIME NOT NULL,
|
|
flag INTEGER NOT NULL DEFAULT 0,
|
|
meta TEXT NULL
|
|
)`); err != nil {
|
|
t.Fatalf("create: %v", err)
|
|
}
|
|
|
|
want := time.Date(2026, 6, 17, 8, 30, 45, 123456000, time.UTC)
|
|
if _, err := d.Exec(`INSERT INTO t (expires_at, flag, meta) VALUES (?, ?, ?)`,
|
|
want, true, `{"k":"v"}`); err != nil {
|
|
t.Fatalf("insert: %v", err)
|
|
}
|
|
|
|
var created, expires time.Time
|
|
var flag bool
|
|
var meta string
|
|
if err := d.QueryRow(`SELECT created_at, expires_at, flag, meta FROM t WHERE id = 1`).
|
|
Scan(&created, &expires, &flag, &meta); err != nil {
|
|
t.Fatalf("scan: %v", err)
|
|
}
|
|
|
|
t.Logf("created=%v expires=%v flag=%v meta=%s", created, expires, flag, meta)
|
|
if !expires.Equal(want) {
|
|
t.Errorf("expires round-trip: got %v, want %v", expires.UTC(), want)
|
|
}
|
|
if created.IsZero() {
|
|
t.Errorf("created_at default not populated")
|
|
}
|
|
if !flag || meta != `{"k":"v"}` {
|
|
t.Errorf("flag/meta mismatch: flag=%v meta=%s", flag, meta)
|
|
}
|
|
|
|
// WHERE comparison against a time param (used by expires_at > ? queries).
|
|
var n int
|
|
if err := d.QueryRow(`SELECT COUNT(*) FROM t WHERE expires_at > ?`,
|
|
want.Add(-time.Hour)).Scan(&n); err != nil {
|
|
t.Fatalf("count: %v", err)
|
|
}
|
|
if n != 1 {
|
|
t.Errorf("time comparison: got %d rows, want 1", n)
|
|
}
|
|
}
|