def connect(self, clear=False):
    'Connect to Mongo DB\n\n        :return: pymongo Database\n        '
    c = pymongo.MongoClient()
    db = c[self.DB]
    if clear:
        for coll in (self.SRC, self.DST):
            db[coll].remove()
            tcoll = ((coll + '.') + CollectionTracker.TRACKING_NAME)
            db[tcoll].remove()
    return db
Connect to Mongo DB

:return: pymongo Database
def connect(self, clear=False):
    'Connect to Mongo DB\n\n        :return: pymongo Database\n        '
    c = pymongo.MongoClient()
    db = c[self.DB]
    if clear:
        for coll in (self.SRC, self.DST):
            db[coll].remove()
            tcoll = ((coll + '.') + CollectionTracker.TRACKING_NAME)
            db[tcoll].remove()
    return db