Method GetRowsOnly

flow/e2e/pg.go:211–221

to avoid fetching rows from "child" tables ala Postgres table inheritance

(ctx context.Context, suffix string, table string, cols string)

// to avoid fetching rows from "child" tables ala Postgres table inheritance
func (s *PostgresSource) GetRowsOnly(ctx context.Context, suffix string, table string, cols string) (*model.QRecordBatch, error) {
	pgQueryExecutor, err := s.PostgresConnector.NewQRepQueryExecutor(ctx, nil, shared.InternalVersion_Latest, "testflow", "testpart")
	if err != nil {
		return nil, err
	}

	return pgQueryExecutor.ExecuteAndProcessQuery(
		ctx,
		fmt.Sprintf(`SELECT %s FROM ONLY e2e_test_%s.%s ORDER BY id`, cols, suffix, common.QuoteIdentifier(table)),
	)
}

func RevokePermissionForTableColumns(ctx context.Context, conn *pgx.Conn, tableIdentifier string, selectedColumns []string) error {
	schemaTable, err := common.ParseTableIdentifier(tableIdentifier)