Function isPostgresDB

plugins/destination/postgresql/client/client_test.go:62–74

(ctx context.Context)

}

func isPostgresDB(ctx context.Context) (bool, error) {
	conn, err := getConnection(ctx)
	if err != nil {
		return false, err
	}
	defer conn.Close()
	var version string
	err = conn.QueryRow(ctx, "select version()").Scan(&version)
	if err != nil {
		return false, fmt.Errorf("failed to get version %w", err)
	}
	return strings.HasPrefix(strings.ToLower(version), "postgresql"), nil
}

var safeMigrations = plugin.SafeMigrations{
	AddColumn:              true,