Function getConnection

plugins/destination/postgresql/client/client_test.go:31–38

(ctx context.Context)

}

func getConnection(ctx context.Context) (*pgxpool.Pool, error) {
	pgxConfig, err := pgxpool.ParseConfig(getTestConnection())
	if err != nil {
		return nil, fmt.Errorf("failed to parse connection string %w", err)
	}
	pgxConfig.ConnConfig.RuntimeParams["timezone"] = "UTC"
	return pgxpool.NewWithConfig(ctx, pgxConfig)
}

func getIndexesForTable(ctx context.Context, tableName string) (map[string]string, error) {
	conn, err := getConnection(ctx)