stream straight into db