initial pass at DBStream and MySQLStreamer