Function drain_with_sql 

pub async fn drain_with_sql(
    pool: &PgPool,
    projection: &str,
    batch: i32,
    budget: Duration,
    projector: &str,
) -> Result<DrainReport, RepositoryError>