Abstract Class yii\mongodb\ActiveRecord

                public function attributes()
{
    throw new InvalidConfigException('The attributes() method of mongodb ActiveRecord has to be implemented by child classes.');
}

            

                public static function collectionName()
{
    return Inflector::camel2id(StringHelper::basename(get_called_class()), '_');
}

            

                public function delete()
{
    $result = false;
    if ($this->beforeDelete()) {
        $result = $this->deleteInternal();
        $this->afterDelete();
    }
    return $result;
}

            

                public static function deleteAll($condition = [], $options = [])
{
    return static::getCollection()->remove($condition, $options);
}

            

                protected function deleteInternal()
{
    // we do not check the return value of deleteAll() because it's possible
    // the record is already deleted in the database and thus the method will return 0
    $condition = $this->getOldPrimaryKey(true);
    $lock = $this->optimisticLock();
    if ($lock !== null) {
        $condition[$lock] = $this->$lock;
    }
    $result = static::getCollection()->remove($condition);
    if ($lock !== null && !$result) {
        throw new StaleObjectException('The object being deleted is outdated.');
    }
    $this->setOldAttributes(null);
    return $result;
}

            

                public function equals($record)
{
    if ($this->isNewRecord || $record->isNewRecord) {
        return false;
    }
    return $this->collectionName() === $record->collectionName() && (string) $this->getPrimaryKey() === (string) $record->getPrimaryKey();
}

            

                public static function find()
{
    return Yii::createObject(ActiveQuery::className(), [get_called_class()]);
}

            

                public static function getCollection()
{
    return static::getDb()->getCollection(static::collectionName());
}

            

                public static function getDb()
{
    return \Yii::$app->get('mongodb');
}

            

                public function insert($runValidation = true, $attributes = null)
{
    if ($runValidation && !$this->validate($attributes)) {
        return false;
    }
    $result = $this->insertInternal($attributes);
    return $result;
}

            

                protected function insertInternal($attributes = null)
{
    if (!$this->beforeSave(true)) {
        return false;
    }
    $values = $this->getDirtyAttributes($attributes);
    if (empty($values)) {
        $currentAttributes = $this->getAttributes();
        foreach ($this->primaryKey() as $key) {
            if (isset($currentAttributes[$key])) {
                $values[$key] = $currentAttributes[$key];
            }
        }
    }
    $newId = static::getCollection()->insert($values);
    $this->setAttribute('_id', $newId);
    $values['_id'] = $newId;
    $changedAttributes = array_fill_keys(array_keys($values), null);
    $this->setOldAttributes($values);
    $this->afterSave(true, $changedAttributes);
    return true;
}

            

                public static function primaryKey()
{
    return ['_id'];
}

            

                public static function updateAll($attributes, $condition = [], $options = [])
{
    return static::getCollection()->update($condition, $attributes, $options);
}

            

                public static function updateAllCounters($counters, $condition = [], $options = [])
{
    return static::getCollection()->update($condition, ['$inc' => $counters], $options);
}

            

                protected function updateInternal($attributes = null)
{
    if (!$this->beforeSave(false)) {
        return false;
    }
    $values = $this->getDirtyAttributes($attributes);
    if (empty($values)) {
        $this->afterSave(false, $values);
        return 0;
    }
    $condition = $this->getOldPrimaryKey(true);
    $lock = $this->optimisticLock();
    if ($lock !== null) {
        if (!isset($values[$lock])) {
            $values[$lock] = $this->$lock + 1;
        }
        $condition[$lock] = $this->$lock;
    }
    // We do not check the return value of update() because it's possible
    // that it doesn't change anything and thus returns 0.
    $rows = static::getCollection()->update($condition, $values);
    if ($lock !== null && !$rows) {
        throw new StaleObjectException('The object being updated is outdated.');
    }
    if (isset($values[$lock])) {
        $this->$lock = $values[$lock];
    }
    $changedAttributes = [];
    foreach ($values as $name => $value) {
        $changedAttributes[$name] = $this->getOldAttribute($name);
        $this->setOldAttribute($name, $value);
    }
    $this->afterSave(false, $changedAttributes);
    return $rows;
}