Function getCloudSQLConnectionConfig

backend/plugin/db/pg/pg.go:276–294

getCloudSQLConnectionConfig returns config for Cloud SQL connector. refs: https://cloud.google.com/sql/docs/postgres/connect-connectors https://github.com/GoogleCloudPlatform/golang-samples/blob/main/cloudsql/postgres/database-sql/cloudsql.go

(ctx context.Context, conf db.ConnectionConfig)

// https://cloud.google.com/sql/docs/postgres/connect-connectors
// https://github.com/GoogleCloudPlatform/golang-samples/blob/main/cloudsql/postgres/database-sql/cloudsql.go
func getCloudSQLConnectionConfig(ctx context.Context, conf db.ConnectionConfig) (*pgx.ConnConfig, error) {
	d, err := util.GetGCPConnectionConfig(ctx, conf)
	if err != nil {
		return nil, errors.Wrap(err, "load gcp config failed")
	}

	dsn := fmt.Sprintf("user=%s", conf.DataSource.Username)
	config, err := pgx.ParseConfig(dsn)
	if err != nil {
		return nil, err
	}
	config.DialFunc = func(ctx context.Context, _, _ string) (net.Conn, error) {
		return d.Dial(ctx, conf.DataSource.Host)
	}

	config.DefaultQueryExecMode = pgx.QueryExecModeExec
	config.StatementCacheCapacity = 0
	return config, nil
}

// Close closes the driver.
func (d *Driver) Close(context.Context) error {