elastic.php

<?php
/**
 * Name of database configuration resource to use for storing data in Elastic Search
 *
 * @var string
 **/
  public $useIndexConfig = 'index';

/**
 * Check if DataSource currently is ElasticSource
 *
 * @return boolean
 */
	public function isElastic() {
		return $this->getDataSource() instanceof ElasticSource;
	}

/**
 * Check if DataSource currently is Mysql
 *
 * @return boolean
 */
	public function isMysql() {
		return $this->getDataSource() instanceof Mysql;
	}

/**
 * Dynamically set the schema to the properties the corresponding data source is expecting
 * when using the elastic search data source it will return the elastic mapping
 *
 * @return array
 **/
	public function schema($field = false) {
		if ($this->isElastic()) {
			if (!empty($this->_schema) && !isset($this->_oldSchema)) {
				$this->_oldSchema = $this->_schema;
			}

			$schema = $this->_schema = $this->elasticMapping();
			if ($field && is_string($field)) {
				return Hash::get($schema, $field);
			}
			return $schema;
		}

		if (!empty($this->_oldSchema)) {
			$this->_schema = $this->_oldSchema;
			unset($this->_oldSchema);
		}

		// Failsafe to prevent schema mix-ups
		if (method_exists($this, 'elasticMapping') && $this->_schema === $this->elasticMapping()) {
			$this->_schema = null;
		}

		return parent::schema($field);
	}

/**
 * Counter cache should not happen when you are in ElasticSearch mode
 *
 * Updates the counter cache of belongsTo associations after a save or delete operation
 *
 * @param array $keys Optional foreign key data, defaults to the information $this->data
 * @param boolean $created True if a new record was created, otherwise only associations with
 *	 'counterScope' defined get updated
 * @return void
 */
	public function updateCounterCache($keys = array(), $created = false) {
		if ($this->isElastic()) {
			return;
		}

		return parent::updateCounterCache($keys, $created);
	}

/**
 * Cascades model deletes through associated hasMany and hasOne child records.
 *
 * @param string $id ID of record that was deleted
 * @param boolean $cascade Set to true to delete records that depend on this record
 * @return void
 */
	protected function _deleteDependent($id, $cascade) {
		if ($this->isElastic()) {
			return;
		}

		return parent::_deleteDependent($id, $cascade);
	}

/**
 * Cascades model deletes through HABTM join keys.
 *
 * @param int $id ID of record that was deleted
 * @return void
 */
	protected function _deleteLinks($id) {
		if ($this->isElastic()) {
			return false;
		}

		parent::_deleteLinks($id);
	}

/**
 * Switches internal datasource config to elastic search
 *
 * @return void
 */
	public function switchToElastic() {
		if ($this->isMysql()) {
			$this->_oldConfig = $this->useDbConfig;
		}
		$this->setDataSource($this->useIndexConfig);
	}

/**
 * Switches the model back from elastic search datasource to database
 *
 * @return void
 **/
	public function switchToDatabase() {
		if ($this->isElastic()) {
			$config = (empty($this->_oldConfig)) ? 'default' : $this->_oldConfig;
			$this->_oldConfig = null;
			$this->setDataSource($config);
		}
	}