能直接用标准 PostgreSQL 驱动连,不需要额外适配层——因CockroachDB官方兼容PostgreSQL wire protocol(v9.5+),lib/pq作为事实标准完全可用;但必须注意连接串需显式配置sslmode、事务须BEGIN/COMMIT显式控制、写冲突需业务层捕获40001错误并重试。

能直接用标准 PostgreSQL 驱动连,不需要额外适配层 —— 但必须注意连接串、事务语义和分布式特性带来的行为差异。
为什么用 github.com/lib/pq 而不是专用驱动
CockroachDB 官方明确声明兼容 PostgreSQL wire protocol(v9.5+),所以 Go 生态中成熟的 lib/pq 就够用,无需引入非标准驱动。官方也推荐这种方式,而非维护独立 SDK。
-
lib/pq是事实标准,社区维护活跃,bug 修复及时 - 所有 SQL 语法、参数绑定(
$1,$2)、sql.Null*类型都原生支持 - 不兼容的点极少:比如
pg_get_keywords()这类 PostgreSQL 内部函数在 CRDB 上不可用,但业务代码几乎不会调用 - 避免引入
cockroachdb/cockroach-go这类过时或半废弃的 wrapper 包(它已多年未更新)
sql.Open 的连接串必须显式禁用 SSL 或配置证书
本地开发常用 sslmode=disable,但生产环境必须用 sslmode=require 并挂载 CA 证书 —— 否则连接会被拒绝,且错误信息常为模糊的 failed to connect,而非明确提示 SSL 问题。
- 开发环境示例:
postgresql://root@localhost:26257/defaultdb?sslmode=disable - 生产环境必须:
postgresql://root@cluster.example.com:26257/defaultdb?sslmode=require&sslrootcert=/etc/cockroach/certs/ca.crt - 若用
cockroachdb/serverless,连接串里会带options=--cluster%3Dyour-cluster-name,这个options参数不能丢,否则报invalid cluster name -
database/sql默认不校验连接有效性,务必在db.Ping()后再使用,否则首次查询才暴露连接失败
事务必须显式控制,CRDB 不支持隐式事务
PostgreSQL 允许单条语句自动开启事务,但 CockroachDB 要求所有写操作必须包裹在 BEGIN ... COMMIT 或使用 sql.Tx —— 否则会直接返回 ERROR: SAVEPOINTs are not supported outside of a transaction 或更误导性的 current transaction is aborted。
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器,提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象,支持命名依赖等
立即学习“go语言免费学习笔记(深入)”;
- 正确做法:
tx, err := db.Begin()→tx.QueryRow(...)→tx.Commit()或tx.Rollback() - 不要依赖
db.Exec("INSERT ...")自动提交:在 CRDB 上可能成功,也可能因上下文无事务而静默失败(尤其在重试场景下) - CRDB 的自动重试只作用于显式事务内;单条语句不参与重试机制,写冲突时直接报错
- 若用 GORM,确保启用
PrepareStmt: true,否则预编译语句在分布式节点间可能因 schema 不一致失败
读写分离和负载均衡要靠应用层或代理,不是驱动层
lib/pq 本身不提供连接池路由能力,CRDB Serverless 或多节点集群的读请求分发需外部介入:
- 简单轮询:用
sql.Open("postgres", connstr1)和sql.Open("postgres", connstr2)手动维护多个*sql.DB实例,按需选择 - 代理方案:在 Kubernetes 中部署
pgbouncer或haproxy,前端统一连代理,后端指向多个 CRDB gateway 节点 - Serverless 场景下,PlanetScale 有内置读副本,CRDB Serverless 则默认所有节点可读,但写仍必须打到 leader —— 应用无需感知 leader 位置,驱动自动重定向
- 注意:CRDB 的
SET LOCAL不生效,所有 session 变量(如search_path)必须在事务开头设置,且不能跨语句持久化
最易被忽略的是事务重试逻辑 —— CRDB 在遇到写冲突时会返回 40001 错误码(serialization_failure),但 database/sql 不自动重试,必须由业务代码捕获并循环执行整个事务块。这点和传统单机 DB 完全不同,跳过就会导致数据丢失或报错中断。

















