Use mysql2 streaming properly