• 您的应用程序已部署
• 您的应用程序读取操作频繁
• 您的数据库复制到多个副本以加快查询速度
• 您分离连接以优化查询
• 

• 您的应用程序部署在多个区域
• 您的数据库已全局配置
• 

• 您使用多主数据库拓扑，例如Aurora多主
• 

package main

import (
	"context"
	"database/sql"
	"fmt"
	"log"

	"github.com/bxcodec/dbresolver/v2"
	_ "github.com/lib/pq"
)

func main() {
	var (
		host1     = "localhost"
		port1     = 5432
		user1     = "postgresrw"
		password1 = "<password>"
		host2     = "localhost"
		port2     = 5433
		user2     = "postgresro"
		password2 = "<password>"
		dbname    = "<dbname>"
	)
	// 连接字符串
	rwPrimary := fmt.Sprintf("host=%s port=%d user=%s password=%s dbname=%s sslmode=disable", host1, port1, user1, password1, dbname)
	readOnlyReplica := fmt.Sprintf("host=%s port=%d user=%s password=%s dbname=%s sslmode=disable", host2, port2, user2, password2, dbname)

	// 打开主数据库连接
	dbPrimary, err := sql.Open("postgres", rwPrimary)
	if err != nil {
		log.Print("连接数据库时出错")
	}
	// 配置数据库的其他设置，例如追踪等
	// 例如，tracing.Postgres(dbPrimary)

	// 打开副本数据库连接
	dbReadOnlyReplica, err := sql.Open("postgres", readOnlyReplica)
	if err != nil {
		log.Print("连接数据库时出错")
	}
	// 配置数据库的其他设置，例如追踪等
	// 例如，tracing.Postgres(dbReadOnlyReplica)

	connectionDB := dbresolver.New(
		dbresolver.WithPrimaryDBs(dbPrimary),
		dbresolver.WithReplicaDBs(dbReadOnlyReplica),
		dbresolver.WithLoadBalancer(dbresolver.RoundRobinLB))

	defer connectionDB.Close()
	// 现在您可以使用此连接进行所有数据库操作
	_, err = connectionDB.ExecContext(context.Background(), "DELETE FROM book WHERE id=$1") // 将使用主数据库
	if err != nil {
		log.Print("执行数据库查询时出错", err)
	}
	connectionDB.QueryRowContext(context.Background(), "SELECT * FROM book WHERE id=$1") // 将使用只读副本数据库
}