294 lines
9.1 KiB
PHP
294 lines
9.1 KiB
PHP
<?php
|
|
/**
|
|
* This software is governed by the CeCILL-B license. If a copy of this license
|
|
* is not distributed with this file, you can obtain one at
|
|
* http://www.cecill.info/licences/Licence_CeCILL-B_V1-en.txt
|
|
*
|
|
* Authors of STUdS (initial project): Guilhem BORGHESI (borghesi@unistra.fr) and Raphaël DROZ
|
|
* Authors of Framadate/OpenSondage: Framasoft (https://github.com/framasoft)
|
|
*
|
|
* =============================
|
|
*
|
|
* Ce logiciel est régi par la licence CeCILL-B. Si une copie de cette licence
|
|
* ne se trouve pas avec ce fichier vous pouvez l'obtenir sur
|
|
* http://www.cecill.info/licences/Licence_CeCILL-B_V1-fr.txt
|
|
*
|
|
* Auteurs de STUdS (projet initial) : Guilhem BORGHESI (borghesi@unistra.fr) et Raphaël DROZ
|
|
* Auteurs de Framadate/OpenSondage : Framasoft (https://github.com/framasoft)
|
|
*/
|
|
namespace Framadate\Migration;
|
|
|
|
use Framadate\Utils;
|
|
|
|
/**
|
|
* This class executes the aciton in database to migrate data from version 0.8 to 0.9.
|
|
*
|
|
* @package Framadate\Migration
|
|
* @version 0.9
|
|
*/
|
|
class From_0_8_to_0_9_Migration implements Migration {
|
|
|
|
function __construct() {
|
|
}
|
|
|
|
/**
|
|
* This method should describe in english what is the purpose of the migration class.
|
|
*
|
|
* @return string The description of the migration class
|
|
*/
|
|
function description() {
|
|
return 'From 0.8 to 0.9';
|
|
}
|
|
|
|
/**
|
|
* This method could check if the execute method should be called.
|
|
* It is called before the execute method.
|
|
*
|
|
* @param \PDO $pdo The connection to database
|
|
* @return bool true is the Migration should be executed.
|
|
*/
|
|
function preCondition(\PDO $pdo) {
|
|
$stmt = $pdo->query('SHOW TABLES');
|
|
$tables = $stmt->fetchAll(\PDO::FETCH_COLUMN);
|
|
|
|
// Check if tables of v0.8 are presents
|
|
$diff = array_diff(['sondage', 'sujet_studs', 'comments', 'user_studs'], $tables);
|
|
return count($diff) === 0;
|
|
}
|
|
|
|
/**
|
|
* This method is called only one time in the migration page.
|
|
*
|
|
* @param \PDO $pdo The connection to database
|
|
* @return bool true is the execution succeeded
|
|
*/
|
|
function execute(\PDO $pdo) {
|
|
$this->createPollTable($pdo);
|
|
$this->createCommentTable($pdo);
|
|
$this->createSlotTable($pdo);
|
|
$this->createVoteTable($pdo);
|
|
|
|
$pdo->beginTransaction();
|
|
$this->migrateFromSondageToPoll($pdo);
|
|
$this->migrateFromCommentsToComment($pdo);
|
|
$this->migrateFromSujetStudsToSlot($pdo);
|
|
$this->migrateFromUserStudsToVote($pdo);
|
|
$pdo->commit();
|
|
|
|
$this->dropOldTables($pdo);
|
|
|
|
return true;
|
|
}
|
|
|
|
private function createPollTable(\PDO $pdo) {
|
|
$pdo->exec('
|
|
CREATE TABLE IF NOT EXISTS `' . Utils::table('poll') . '` (
|
|
`id` CHAR(16) NOT NULL,
|
|
`admin_id` CHAR(24) NOT NULL,
|
|
`title` TEXT NOT NULL,
|
|
`description` TEXT,
|
|
`admin_name` VARCHAR(64) DEFAULT NULL,
|
|
`admin_mail` VARCHAR(128) DEFAULT NULL,
|
|
`creation_date` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|
`end_date` TIMESTAMP NOT NULL DEFAULT \'0000-00-00 00:00:00\',
|
|
`format` VARCHAR(1) DEFAULT NULL,
|
|
`editable` TINYINT(1) DEFAULT \'0\',
|
|
`receiveNewVotes` TINYINT(1) DEFAULT \'0\',
|
|
`active` TINYINT(1) DEFAULT \'1\',
|
|
PRIMARY KEY (`id`)
|
|
)
|
|
ENGINE = InnoDB
|
|
DEFAULT CHARSET = utf8');
|
|
}
|
|
|
|
private function migrateFromSondageToPoll(\PDO $pdo) {
|
|
$select = $pdo->query('
|
|
SELECT
|
|
`id_sondage`,
|
|
`id_sondage_admin`,
|
|
`titre`,
|
|
`commentaires`,
|
|
`nom_admin`,
|
|
`mail_admin`,
|
|
`date_creation`,
|
|
`date_fin`,
|
|
SUBSTR(`format`, 1, 1) AS `format`,
|
|
CASE SUBSTR(`format`, 2, 1)
|
|
WHEN \'+\' THEN 1
|
|
ELSE 0 END AS `editable`,
|
|
`mailsonde`,
|
|
CASE SUBSTR(`format`, 2, 1)
|
|
WHEN \'-\' THEN 0
|
|
ELSE 1 END AS `active`
|
|
FROM sondage');
|
|
|
|
$insert = $pdo->prepare('
|
|
INSERT INTO `' . Utils::table('poll') . '`
|
|
(`id`, `admin_id`, `title`, `description`, `admin_name`, `admin_mail`, `creation_date`, `end_date`, `format`, `editable`, `receiveNewVotes`, `active`)
|
|
VALUE (?,?,?,?,?,?,?,?,?,?,?,?)');
|
|
|
|
while ($row = $select->fetch(\PDO::FETCH_OBJ)) {
|
|
$insert->execute([
|
|
$row->id_sondage,
|
|
$row->id_sondage_admin,
|
|
$this->unescape($row->titre),
|
|
$this->unescape($row->commentaires),
|
|
$this->unescape($row->nom_admin),
|
|
$this->unescape($row->mail_admin),
|
|
$row->date_creation,
|
|
$row->date_fin,
|
|
$row->format,
|
|
$row->editable,
|
|
$row->mailsonde,
|
|
$row->active
|
|
]);
|
|
}
|
|
}
|
|
|
|
private function createSlotTable(\PDO $pdo) {
|
|
$pdo->exec('
|
|
CREATE TABLE IF NOT EXISTS `' . Utils::table('slot') . '` (
|
|
`id` INT(11) UNSIGNED NOT NULL AUTO_INCREMENT,
|
|
`poll_id` CHAR(16) NOT NULL,
|
|
`title` TEXT,
|
|
`moments` TEXT,
|
|
PRIMARY KEY (`id`),
|
|
KEY `poll_id` (`poll_id`)
|
|
)
|
|
ENGINE = InnoDB
|
|
DEFAULT CHARSET = utf8');
|
|
}
|
|
|
|
private function migrateFromSujetStudsToSlot(\PDO $pdo) {
|
|
$stmt = $pdo->query('SELECT * FROM sujet_studs');
|
|
$sujets = $stmt->fetchAll();
|
|
$slots = [];
|
|
|
|
foreach ($sujets as $sujet) {
|
|
$newSlots = $this->transformSujetToSlot($sujet);
|
|
foreach ($newSlots as $newSlot) {
|
|
$slots[] = $newSlot;
|
|
}
|
|
}
|
|
|
|
$prepared = $pdo->prepare('INSERT INTO ' . Utils::table('slot') . ' (`poll_id`, `title`, `moments`) VALUE (?,?,?)');
|
|
foreach ($slots as $slot) {
|
|
$prepared->execute([
|
|
$slot->poll_id,
|
|
$this->unescape($slot->title),
|
|
!empty($slot->moments) ? $this->unescape($slot->moments) : null
|
|
]);
|
|
}
|
|
}
|
|
|
|
private function createCommentTable(\PDO $pdo) {
|
|
$pdo->exec('
|
|
CREATE TABLE IF NOT EXISTS `' . Utils::table('comment') . '` (
|
|
`id` INT(11) UNSIGNED NOT NULL AUTO_INCREMENT,
|
|
`poll_id` CHAR(16) NOT NULL,
|
|
`name` TEXT,
|
|
`comment` TEXT NOT NULL,
|
|
PRIMARY KEY (`id`),
|
|
KEY `poll_id` (`poll_id`)
|
|
)
|
|
ENGINE = InnoDB
|
|
DEFAULT CHARSET = utf8');
|
|
}
|
|
|
|
private function migrateFromCommentsToComment(\PDO $pdo) {
|
|
$select = $pdo->query('
|
|
SELECT
|
|
`id_sondage`,
|
|
`usercomment`,
|
|
`comment`
|
|
FROM `comments`');
|
|
|
|
$insert = $pdo->prepare('
|
|
INSERT INTO `' . Utils::table('comment') . '` (`poll_id`, `name`, `comment`)
|
|
VALUE (?,?,?)');
|
|
|
|
while ($row = $select->fetch(\PDO::FETCH_OBJ)) {
|
|
$insert->execute([
|
|
$row->id_sondage,
|
|
$this->unescape($row->usercomment),
|
|
$this->unescape($row->comment)
|
|
]);
|
|
}
|
|
}
|
|
|
|
private function createVoteTable(\PDO $pdo) {
|
|
$pdo->exec('
|
|
CREATE TABLE IF NOT EXISTS `' . Utils::table('vote') . '` (
|
|
`id` INT(11) UNSIGNED NOT NULL AUTO_INCREMENT,
|
|
`poll_id` CHAR(16) NOT NULL,
|
|
`name` VARCHAR(64) NOT NULL,
|
|
`choices` TEXT NOT NULL,
|
|
PRIMARY KEY (`id`),
|
|
KEY `poll_id` (`poll_id`)
|
|
)
|
|
ENGINE = InnoDB
|
|
DEFAULT CHARSET = utf8');
|
|
}
|
|
|
|
private function migrateFromUserStudsToVote(\PDO $pdo) {
|
|
$select = $pdo->query('
|
|
SELECT
|
|
`id_sondage`,
|
|
`nom`,
|
|
REPLACE(REPLACE(REPLACE(`reponses`, 1, \'X\'), 2, 1), \'X\', 2) reponses
|
|
FROM `user_studs`');
|
|
|
|
$insert = $pdo->prepare('
|
|
INSERT INTO `' . Utils::table('vote') . '` (`poll_id`, `name`, `choices`)
|
|
VALUE (?,?,?)');
|
|
|
|
while ($row = $select->fetch(\PDO::FETCH_OBJ)) {
|
|
$insert->execute([
|
|
$row->id_sondage,
|
|
$this->unescape($row->nom),
|
|
$row->reponses
|
|
]);
|
|
}
|
|
}
|
|
|
|
private function transformSujetToSlot($sujet) {
|
|
$slots = [];
|
|
$ex = explode(',', $sujet->sujet);
|
|
$isDatePoll = strpos($sujet->sujet, '@');
|
|
$lastSlot = null;
|
|
|
|
foreach ($ex as $atomicSlot) {
|
|
if ($isDatePoll === false) { // Classic poll
|
|
$slot = new \stdClass();
|
|
$slot->poll_id = $sujet->id_sondage;
|
|
$slot->title = $atomicSlot;
|
|
$slots[] = $slot;
|
|
} else { // Date poll
|
|
$values = explode('@', $atomicSlot);
|
|
if ($lastSlot == null || $lastSlot->title !== $values[0]) {
|
|
$lastSlot = new \stdClass();
|
|
$lastSlot->poll_id = $sujet->id_sondage;
|
|
$lastSlot->title = $values[0];
|
|
$lastSlot->moments = count($values) == 2 ? $values[1] : '-';
|
|
$slots[] = $lastSlot;
|
|
} else {
|
|
$lastSlot->moments .= ',' . (count($values) == 2 ? $values[1] : '-');
|
|
}
|
|
}
|
|
}
|
|
|
|
return $slots;
|
|
}
|
|
|
|
private function dropOldTables(\PDO $pdo) {
|
|
$pdo->exec('DROP TABLE `comments`');
|
|
$pdo->exec('DROP TABLE `sujet_studs`');
|
|
$pdo->exec('DROP TABLE `user_studs`');
|
|
$pdo->exec('DROP TABLE `sondage`');
|
|
}
|
|
|
|
private function unescape($value) {
|
|
return stripslashes(html_entity_decode($value, ENT_QUOTES));
|
|
}
|
|
}
|