tweet_live: comparison web/lib/Zend/Cloud/DocumentService/Adapter/SimpleDb.php

equal deleted inserted replaced

-:5e7a0fedabdf
+:877f952ae2bd
 * to license@zend.com so we can send you a copy immediately.
 *
 * @category   Zend
 * @package    Zend_Cloud
 * @subpackage DocumentService
-* @copyright  Copyright (c) 2005-2010 Zend Technologies USA Inc. (http://www.zend.com)
+* @copyright  Copyright (c) 2005-2012 Zend Technologies USA Inc. (http://www.zend.com)
 * @license    http://framework.zend.com/license/new-bsd     New BSD License
 */
 require_once 'Zend/Cloud/DocumentService/Adapter/AbstractAdapter.php';
 require_once 'Zend/Cloud/DocumentService/Adapter/SimpleDb/Query.php';
 * SimpleDB adapter for document service.
 *
 * @category   Zend
 * @package    Zend_Cloud
 * @subpackage DocumentService
-* @copyright  Copyright (c) 2005-2010 Zend Technologies USA Inc. (http://www.zend.com)
+* @copyright  Copyright (c) 2005-2012 Zend Technologies USA Inc. (http://www.zend.com)
 * @license    http://framework.zend.com/license/new-bsd     New BSD License
 */
 class Zend_Cloud_DocumentService_Adapter_SimpleDb
 extends Zend_Cloud_DocumentService_Adapter_AbstractAdapter
 {
 /*
 * Options array keys for the SimpleDB adapter.
 */
 const AWS_ACCESS_KEY   = 'aws_accesskey';
 const AWS_SECRET_KEY   = 'aws_secretkey';
 const ITEM_NAME        = 'ItemName';
 const MERGE_OPTION     = "merge";
 const RETURN_DOCUMENTS = "return_documents";
 const DEFAULT_QUERY_CLASS = 'Zend_Cloud_DocumentService_Adapter_SimpleDb_Query';
 /**
 * SQS service instance.
 * @var Zend_Service_Amazon_SimpleDb
 */
 protected $_simpleDb;
 /**
 * Class to utilize for new query objects
 * @var string
 */
 protected $_queryClass = 'Zend_Cloud_DocumentService_Adapter_SimpleDb_Query';
 /**
 * Constructor
 *
 * @param  array|Zend_Config $options
 * @return void
 */
 public function __construct($options = array())
 {
 if ($options instanceof Zend_Config) {
 $options = $options->toArray();
 }
 $this->_simpleDb = new Zend_Service_Amazon_SimpleDb(
 $options[self::AWS_ACCESS_KEY], $options[self::AWS_SECRET_KEY]
 );
 if (isset($options[self::HTTP_ADAPTER])) {
-$this->_sqs->getHttpClient()->setAdapter($options[self::HTTP_ADAPTER]);
+$this->_simpleDb->getHttpClient()->setAdapter($options[self::HTTP_ADAPTER]);
 }
 if (isset($options[self::DOCUMENT_CLASS])) {
 $this->setDocumentClass($options[self::DOCUMENT_CLASS]);
 }
 *
 * @param  string $name
 * @param  array  $options
 * @return void
 */
 public function createCollection($name, $options = null)
 {
 try {
 $this->_simpleDb->createDomain($name);
 } catch(Zend_Service_Amazon_Exception $e) {
 throw new Zend_Cloud_DocumentService_Exception('Error on domain creation: '.$e->getMessage(), $e->getCode(), $e);
 *
 * @param  string $name
 * @param  array  $options
 * @return void
 */
 public function deleteCollection($name, $options = null)
 {
 try {
 $this->_simpleDb->deleteDomain($name);
 } catch(Zend_Service_Amazon_Exception $e) {
 throw new Zend_Cloud_DocumentService_Exception('Error on collection deletion: '.$e->getMessage(), $e->getCode(), $e);
 * List collections.
 *
 * @param  array  $options
 * @return array
 */
 public function listCollections($options = null)
 {
 try {
 // TODO package this in Pages
 $domains = $this->_simpleDb->listDomains()->getData();
 } catch(Zend_Service_Amazon_Exception $e) {
 *
 * @param  string $collectionName Name of collection for which to list documents
 * @param  array|null $options
 * @return Zend_Cloud_DocumentService_DocumentSet
 */
 public function listDocuments($collectionName, array $options = null)
 {
 $query = $this->select('*')->from($collectionName);
 $items = $this->query($collectionName, $query, $options);
 return $items;
 }
 */
 public function insertDocument($collectionName, $document, $options = null)
 {
 if (is_array($document)) {
 $document =  $this->_getDocumentFromArray($document);
 }
 if (!$document instanceof Zend_Cloud_DocumentService_Document) {
 throw new Zend_Cloud_DocumentService_Exception('Invalid document supplied');
 }
 try {
 $this->_simpleDb->putAttributes(
 $collectionName,
 $document->getID(),
 $this->_makeAttributes($document->getID(), $document->getFields())
 }
 }
 /**
 * Replace an existing document with a new version
 *
 * @param  string $collectionName
 * @param  array|Zend_Cloud_DocumentService_Document $document
 * @param  array $options
 * @return void
 */
 public function replaceDocument($collectionName, $document, $options = null)
 {
 if (is_array($document)) {
 $document =  $this->_getDocumentFromArray($document);
 }
 if (!$document instanceof Zend_Cloud_DocumentService_Document) {
 throw new Zend_Cloud_DocumentService_Exception('Invalid document supplied');
 }
 // Delete document first, then insert. PutAttributes always keeps any
 // fields not referenced in the payload, but present in the document
 $documentId = $document->getId();
 $fields     = $document->getFields();
 $docClass   = get_class($document);
 $this->deleteDocument($collectionName, $document, $options);
 $document   = new $docClass($fields, $documentId);
 $this->insertDocument($collectionName, $document);
 }
 /**
 * Update document. The new document replaces the existing document.
 *
 * Option 'merge' specifies to add all attributes (if true) or
 * specific attributes ("attr" => true) instead of replacing them.
 * By default, attributes are replaced.
 *
 * @param  string $collectionName
 * @param  mixed|Zend_Cloud_DocumentService_Document $documentId Document ID, adapter-dependent
 * @param  array|Zend_Cloud_DocumentService_Document $fieldset Set of fields to update
 * @param  array                   $options
 * @return boolean
 if (empty($documentId)) {
 $documentId = $fieldset->getId();
 }
 $fieldset = $fieldset->getFields();
 }
 $replace = array();
 if (empty($options[self::MERGE_OPTION])) {
 // no merge option - we replace all
 foreach ($fieldset as $key => $value) {
 $replace[$key] = true;
 // if there's merge key, we add it, otherwise we replace it
 $replace[$key] = true;
 }
 }
 } // otherwise $replace is empty - all is merged
 try {
 $this->_simpleDb->putAttributes(
 $collectionName,
 $documentId,
 $this->_makeAttributes($documentId, $fieldset),
 return true;
 }
 /**
 * Fetch single document by ID
 *
 * @param  string $collectionName Collection name
 * @param  mixed $documentId Document ID, adapter-dependent
 * @param  array $options
 * @return Zend_Cloud_DocumentService_Document
 */
 return $this->_resolveAttributes($attributes, true);
 } catch(Zend_Service_Amazon_Exception $e) {
 throw new Zend_Cloud_DocumentService_Exception('Error on fetching document: '.$e->getMessage(), $e->getCode(), $e);
 }
 }
 /**
 * Query for documents stored in the document service. If a string is passed in
 * $query, the query string will be passed directly to the service.
 *
 * @param  string $collectionName Collection name
 return $this->_getDocumentSetFromResultSet($result, $returnDocs);
 }
 /**
 * Create query statement
 *
 * @param  string $fields
 * @return Zend_Cloud_DocumentService_Adapter_SimpleDb_Query
 */
 public function select($fields = null)
 {
 if (!$query instanceof $defaultClass) {
 throw new Zend_Cloud_DocumentService_Exception('Query class must extend ' . self::DEFAULT_QUERY_CLASS);
 }
 $query->select($fields);
 return $query;
 }
 /**
 * Get the concrete service client
 *
 * @return Zend_Service_Amazon_SimpleDb
 */
 public function getClient()
 {
 return $this->_simpleDb;
 }
 /**
 * Convert array of key-value pairs to array of Amazon attributes
 *
 * @param string $name
 * @param array $attributes
 * @return array
 */
 protected function _makeAttributes($name, $attributes)
 foreach ($attributes as $key => $attr) {
 $result[] = new Zend_Service_Amazon_SimpleDb_Attribute($name, $key, $attr);
 }
 return $result;
 }
 /**
 * Convert array of Amazon attributes to array of key-value pairs
 *
 * @param array $attributes
 * @return array
 */
 protected function _resolveAttributes($attributes, $returnDocument = false)
 {
 return new $documentClass($result, $attr->getItemName());
 }
 return $result;
 }
 /**
 * Create suitable document from array of fields
 *
 * @param array $document
 * @return Zend_Cloud_DocumentService_Document
 */
 protected function _getDocumentFromArray($document)
 {
 return new $documentClass($document, $key);
 }
 /**
 * Create a DocumentSet from a SimpleDb resultset
 *
 * @param  Zend_Service_Amazon_SimpleDb_Page $resultSet
 * @param  bool $returnDocs
 * @return Zend_Cloud_DocumentService_DocumentSet
 */
 protected function _getDocumentSetFromResultSet(Zend_Service_Amazon_SimpleDb_Page $resultSet, $returnDocs = true)
 {
 $docs = array();

changeset 807	877f952ae2bd
parent 207	621fa6caec0c
child 1230	68c69c656a2c