Commitee746ec

committed

Allow specifying non-local mongodb

1 parentb25c9ca commitee746ecCopy full SHA for ee746ec

File tree

+13

-10

lines changed

+13

-10

lines changed

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -66,6 +66,7 @@ To use non-default databases, perform the following steps:`
`66`	`66`
`67`	`67`	`# only the chosen db's config will be read`
`68`	`68`	`mongodb:`
	`69`	`+ 'uri': 'mongodb://127.0.0.1:27017/'`
`69`	`70`	`'db': 'repo'`
`70`	`71`	`'collection': 'data'`
`71`	`72`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -17,6 +17,7 @@ db_config:`
`17`	`17`	`leveldb:`
`18`	`18`	`'dir': '~/.ndn/ndn-python-repo/leveldb/' # directory to leveldb database files`
`19`	`19`	`mongodb:`
	`20`	`+ 'uri': 'mongodb://127.0.0.1:27017/'`
`20`	`21`	`'db': 'repo'`
`21`	`22`	`'collection': 'data'`
`22`	`23`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -7,7 +7,7 @@`
`7`	`7`
`8`	`8`	`classMongoDBStorage(Storage):`
`9`	`9`
`10`		`-def__init__(self,db:str,collection:str):`
	`10`	`+def__init__(self,db:str,collection:str,uri:str='mongodb://127.0.0.1:27017/'):`
`11`	`11`	`"""`
`12`	`12`	`Init a MongoDB storage with unique index on key.`
`13`	`13`
`@@ -17,7 +17,7 @@ def __init__(self, db: str, collection: str):`
`17`	`17`	`super().__init__()`
`18`	`18`	`self._db=db`
`19`	`19`	`self._collection=collection`
`20`		`-self._uri='mongodb://127.0.0.1:27017/'`
	`20`	`+self._uri=uri`
`21`	`21`	`self.client=MongoClient(self._uri)`
`22`	`22`	`self.c_db=self.client[self._db]`
`23`	`23`	`self.c_collection=self.c_db[self._collection]`

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,8 @@ def create_storage(config):`
`37`	`37`	`elifdb_type=='mongodb':`
`38`	`38`	`db_name=config[db_type]['db']`
`39`	`39`	`db_collection=config[db_type]['collection']`
`40`		`-ret=MongoDBStorage(db_name,db_collection)`
	`40`	`+db_uri=config[db_type]['uri']`
	`41`	`+ret=MongoDBStorage(db_name,db_collection,db_uri)`
`41`	`42`	`else:`
`42`	`43`	`raiseNameError()`
`43`	`44`

Lines changed: 7 additions & 7 deletions

Some generated files are not rendered by default. Learn more aboutcustomizing how changed files appear on GitHub.

Comments

(0)