shopware / SwagConnect

    /**

     * Create most used indexes in s_plugin_connect_items table.

     */

    private function addConnectItemsIndex()

    {

        if (version_compare($this->version, '1.1.1', '<=')) {

            try {

                $this->db->query('ALTER TABLE s_plugin_connect_items ADD INDEX stream(shop_id, stream)');

                $this->db->query('ALTER TABLE s_plugin_connect_items MODIFY group_id VARCHAR(64)');

                $this->db->query('ALTER TABLE s_plugin_connect_items ADD INDEX source_id (source_id, shop_id)');

                $this->db->query('ALTER TABLE s_plugin_connect_items ADD INDEX group_id (group_id, shop_id)');

            } catch (\Exception $e) {

                // ignore it if exists

                $this->logger->write(

                    true,

                    sprintf('An error occurred during update to version %s stacktrace: %s', $this->version, $e->getTraceAsString()),

                    $e->getMessage()

                );

            }

        }

    }

    /**

     * Create the mapping table between connect remote categories and local categories.

        }

    }

    private function addShopIdToConnectCategories()

    {

        if (version_compare($this->version, '1.1.7', '<=')) {

            try {

                if (!$this->existsConfig('addShopIdToConnectCategories')) {

                    $this->db->query('INSERT INTO `s_plugin_connect_config` (`name`, `value`) VALUES ("addShopIdToConnectCategories", "0")');

                }

                $this->db->query('ALTER TABLE s_plugin_connect_categories ADD COLUMN `shop_id` int(11) NULL');

                $this->db->query('ALTER TABLE s_plugin_connect_categories DROP INDEX scuk_category_key');

                $this->db->query('ALTER TABLE s_plugin_connect_categories ADD UNIQUE KEY `scuk_connect_category_for_shop_id` (`category_key`,`shop_id`)');

            } catch (\Exception $e) {

                // ignore it if exists

                $this->logger->write(

                    true,

                    sprintf('An error occurred during update to version %s stacktrace: %s', $this->version, $e->getTraceAsString()),

                    $e->getMessage()

                );

            }

        }

    }

    private function addStreamColumnToConnectToLocalCategories()

    {