def _get_db(dburl, create=True, reset_db=False):
"""
Get a db handle. Optionally reset / create.
"""
sres = urlparse.urlsplit(dburl)
dbname = sres.path.lstrip('/')
srv = couchdb.Server(urlparse.urlunsplit(sres._replace(path='', query='')))
srv.version() # throws if can't connect to server
if reset_db:
if dbname in srv:
del srv[dbname]
return srv.create(dbname)
if dbname in srv:
return srv[dbname]
else:
if create:
return srv.create(dbname)
else:
return None
评论列表
文章目录