Think about how to handle joins/aggregates/projections: can either have our alohomora mysql connector parse the query and perform a mirroring transformation on the policies (how hard is this? sounds very slow), or use k9db and add support for this in dataflow engine.