shopware / SwagConnect

                foreach ($categories as $categoryKey => $category) {

                    $selectedCategory = $this->manager->getConnection()->executeQuery('SELECT `id` FROM s_plugin_connect_categories WHERE category_key = ? AND shop_id = ?',

                        [$categoryKey, $shopId]);

                    if (!($res = $selectedCategory->fetch())) {

                        $this->manager->getConnection()->executeQuery('INSERT INTO s_plugin_connect_categories (category_key, label, shop_id) VALUES (?, ?, ?)',

                            [$categoryKey, $category, $shopId]);

                        $categoryId = (int) $this->manager->getConnection()->lastInsertId();

                    } else {

                        $categoryId = (int) $res['id'];

                    }

                    $selectedProductToCategory = $this->manager->getConnection()->executeQuery('SELECT COUNT(*) FROM s_plugin_connect_product_to_categories WHERE connect_category_id = ? AND articleID = ?',

                        [$categoryId, (int) $row['article_id']]

                    )->fetchColumn();

    {

        $selectedCategory = $this->manager->getConnection()->executeQuery('SELECT `id` FROM s_plugin_connect_categories WHERE category_key = ? AND shop_id IS NULL',

            [$categoryKey]);

        if (!($res = $selectedCategory->fetch())) {

            $this->manager->getConnection()->executeQuery('INSERT INTO s_plugin_connect_categories (category_key, label, shop_id) VALUES (?, ?, ?)',

                [$categoryKey, $category, $shopId]);

            $createdCategoryId = (int) $this->manager->getConnection()->lastInsertId();

            $this->assignLocalCategories($createdCategoryId, $categoryKey);

            return $createdCategoryId;

        }

        $this->manager->getConnection()->executeQuery('UPDATE s_plugin_connect_categories SET shop_id = ? WHERE id = ?',

            [$shopId, $res['id']]);