summaryrefslogtreecommitdiff
path: root/reddwarfclient/databases.py
diff options
context:
space:
mode:
authorMichael Basnight <mbasnight@gmail.com>2013-06-17 23:34:27 -0700
committerMichael Basnight <mbasnight@gmail.com>2013-06-21 20:15:23 +0000
commit9916c8f2733b683d859770d05dacd2c9c82912d7 (patch)
tree084a0d53580cbbd34ed8f28de9302d6c78f7050d /reddwarfclient/databases.py
parentbc90b3e088d3d4b83b5b3de0f9f83d9b6956947d (diff)
downloadpython-troveclient-0.1.3.tar.gz
Rename from reddwarf to trove.0.1.3
Implements Blueprint reddwarf-trove-rename Change-Id: Ib2d694c7466887ca297bea4250eca17cdc06b7bf
Diffstat (limited to 'reddwarfclient/databases.py')
-rw-r--r--reddwarfclient/databases.py79
1 files changed, 0 insertions, 79 deletions
diff --git a/reddwarfclient/databases.py b/reddwarfclient/databases.py
deleted file mode 100644
index d7f31e1..0000000
--- a/reddwarfclient/databases.py
+++ /dev/null
@@ -1,79 +0,0 @@
-from reddwarfclient import base
-from reddwarfclient.common import check_for_exceptions
-from reddwarfclient.common import limit_url
-from reddwarfclient.common import Paginated
-import exceptions
-import urlparse
-
-
-class Database(base.Resource):
- """
- According to Wikipedia, "A database is a system intended to organize,
- store, and retrieve
- large amounts of data easily."
- """
- def __repr__(self):
- return "<Database: %s>" % self.name
-
-
-class Databases(base.ManagerWithFind):
- """
- Manage :class:`Databases` resources.
- """
- resource_class = Database
-
- def create(self, instance_id, databases):
- """
- Create new databases within the specified instance
- """
- body = {"databases": databases}
- url = "/instances/%s/databases" % instance_id
- resp, body = self.api.client.post(url, body=body)
- check_for_exceptions(resp, body)
-
- def delete(self, instance_id, dbname):
- """Delete an existing database in the specified instance"""
- url = "/instances/%s/databases/%s" % (instance_id, dbname)
- resp, body = self.api.client.delete(url)
- check_for_exceptions(resp, body)
-
- def _list(self, url, response_key, limit=None, marker=None):
- resp, body = self.api.client.get(limit_url(url, limit, marker))
- check_for_exceptions(resp, body)
- if not body:
- raise Exception("Call to " + url +
- " did not return a body.")
- links = body.get('links', [])
- next_links = [link['href'] for link in links if link['rel'] == 'next']
- next_marker = None
- for link in next_links:
- # Extract the marker from the url.
- parsed_url = urlparse.urlparse(link)
- query_dict = dict(urlparse.parse_qsl(parsed_url.query))
- next_marker = query_dict.get('marker', None)
- databases = body[response_key]
- databases = [self.resource_class(self, res) for res in databases]
- return Paginated(databases, next_marker=next_marker, links=links)
-
- def list(self, instance, limit=None, marker=None):
- """
- Get a list of all Databases from the instance.
-
- :rtype: list of :class:`Database`.
- """
- return self._list("/instances/%s/databases" % base.getid(instance),
- "databases", limit, marker)
-
-# def get(self, instance, database):
-# """
-# Get a specific instances.
-#
-# :param flavor: The ID of the :class:`Database` to get.
-# :rtype: :class:`Database`
-# """
-# assert isinstance(instance, Instance)
-# assert isinstance(database, (Database, int))
-# instance_id = base.getid(instance)
-# db_id = base.getid(database)
-# url = "/instances/%s/databases/%s" % (instance_id, db_id)
-# return self._get(url, "database")