Right now it has its own (old) code for handling the database connection and results throughput. Building it on top of ASyncQuery would be much nicer and clean.