Sirius\Orm\Action\Insert::execute()

Complexity

Conditions	1
Paths	1

Size

Total Lines	19
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    protected function execute()
    {
        $this->entityId    = $this->mapper->getEntityPk($this->entity);
        $this->entityState = $this->entity->getPersistenceState();

        $connection = $this->mapper->getWriteConnection();

        $columns = array_merge(
            $this->mapper->extractFromEntity($this->entity),
            $this->extraColumns,
            $this->mapper->getGuards()
        );
        $columns = Arr::except($columns, $this->mapper->getPrimaryKey());

        $insertSql = new \Sirius\Sql\Insert($connection);
        $insertSql->into($this->mapper->getTable())
                  ->columns($columns);
        $insertSql->perform();
        $this->mapper->setEntityPk($this->entity, $connection->lastInsertId());
    }