shopware / SwagConnect

    /**

      * Create index by articleID in s_plugin_connect_product_to_categories table.

      */

    private function addProductToCategoryIndex()

    {

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

            try {

                $this->db->query('ALTER TABLE s_plugin_connect_product_to_categories ADD INDEX article_id(articleID)');

            } 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 addShopIdToConnectCategories()

    {

        }

    }

    private function changeExportStatusToVarchar()

    {

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

            try {

                $this->db->query('ALTER TABLE s_plugin_connect_items MODIFY export_status varchar(255)');

                $this->db->query('ALTER TABLE s_plugin_connect_items ADD INDEX IDX_revision (revision)');

                $this->db->query('ALTER TABLE s_plugin_connect_items ADD INDEX IDX_status (export_status)');

            } 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 addArticleRelationsTable()

    {

        }

    }

    private function addArticleRelationsTable()

    {

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

            try {

                $this->db->query(

                    'CREATE TABLE IF NOT EXISTS `s_plugin_connect_article_relations` (

                  `id` int(11) NOT NULL AUTO_INCREMENT,

                  `article_id` int(11) unsigned NOT NULL,

                  `shop_id` int(11) NOT NULL,

                  `related_article_local_id` int(11) NOT NULL,

                  `relationship_type` varchar(32) COLLATE utf8_unicode_ci NOT NULL,

                  PRIMARY KEY (`id`),

                  UNIQUE KEY `relations` (`article_id`, `shop_id`, `related_article_local_id`, `relationship_type`),

                  CONSTRAINT s_plugin_connect_article_relations_fk_article_id FOREIGN KEY (article_id) REFERENCES s_articles (id) ON DELETE CASCADE

                  ) ENGINE = InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;'

                );

            } catch (\Exception $e) {

                // ignore it if exists

        }

    }

    private function addOverwriteMainImage()

    {

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

            try {

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

                    $this->db->query('INSERT INTO `s_plugin_connect_config` (`name`, `value`, `groupName`) VALUES ("overwriteProductMainImage", "1", "import")');

                }

                $this->db->query('ALTER TABLE `s_plugin_connect_items` ADD COLUMN `update_main_image` varchar(255) COLLATE utf8_unicode_ci DEFAULT NULL');

            } 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 changeGroupNameImportSettings()

    {

        }

    }

    private function changeGroupNameImportSettings()

    {

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

            try {

                $this->db->query('UPDATE `s_plugin_connect_config` SET `groupName` = "import" WHERE `groupName` = "general" AND `name` IN ("createCategoriesAutomatically", "activateProductsAutomatically", "createUnitsAutomatically",

                                            "detailShopInfo", "checkoutShopInfo", "showShippingCostsSeparately")');

            } catch (\Exception $e) {

                $this->logger->write(

                    true,

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

                    $e->getMessage()

                );

            }

        }

    }

    private function addArticleDetailsForeignKey()

    {

        }

    }

    private function addArticleDetailsForeignKey()

    {

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

            try {

                $this->db->query('

                ALTER TABLE s_plugin_connect_items

                ADD FOREIGN KEY (`article_detail_id`) REFERENCES s_articles_details (id) ON DELETE SET NULL

                ');

            } catch (\Exception $e) {

                $this->logger->write(

                    true,

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

                    $e->getMessage()

                );

            }

        }

    }

    /**

     * @param string $configName

     * @return bool

     */

    private function existsConfig($configName) {

        $stmt = $this->db->prepare('SELECT * FROM s_plugin_connect_config WHERE `name` = ?');

        $stmt->execute([$configName]);

        return $stmt->fetch() !== false;

    }