florianajir / rabbitmq-sql-worker

     *

     * @throws Exception

     */

    protected function persistOneToOneRelations(EntityInterface $entity)

    {

        $joinData = array();

        $relations = $entity->getOneToOneRelations();

        foreach ($relations as $relation) {

            $oneToOne = $this->relationFactory->create(DataMapper::RELATION_ONE_TO_ONE, $relation);

            $entity = $this->entityFactory->create($oneToOne->getEntity());

            $id = $this->persistRecursive($entity);

            $joinVal = $entity->getProperty($oneToOne->getJoinColumnReferencedColumnName());

            $joinData[$oneToOne->getJoinColumnName()] = !is_null($joinVal)

                ? $joinVal

                : $this->provider->getColumnValueWhere(

                    $oneToOne->getTable(),

                    $oneToOne->getJoinColumnReferencedColumnName(),

                    key($id),

                    current($id)

                );

        }

        return $joinData;

    }

    /**

     * Persist manyToOne relations

     *

     * @throws Exception

     */

    protected function persistManyToOneRelations(EntityInterface $entity)

    {

        $joinData = array();

        $relations = $entity->getManyToOneRelations();

        foreach ($relations as $relation) {

            $manyToOne = $this->relationFactory->create(DataMapper::RELATION_MANY_TO_ONE, $relation);

            $entity = $this->entityFactory->create($manyToOne->getEntity());

            $id = $this->persistRecursive($entity);

            $joinVal = $entity->getProperty($manyToOne->getJoinColumnReferencedColumnName());

            $joinData[$manyToOne->getJoinColumnName()] = !is_null($joinVal)

                ? $joinVal

                : $this->provider->getColumnValueWhere(

                    $manyToOne->getTable(),

                    $manyToOne->getJoinColumnReferencedColumnName(),

                    key($id),

                    current($id)

                );

        }

        return $joinData;

    }

    /**

     * @param EntityInterface $entity