WIP - Tools for migrate/import
This commit is contained in:
Matthew Ross
parent
6a2a0eb645
commit
ffde81c85b
70
tools/schema
Normal file
70
tools/schema
Normal file
@ -0,0 +1,70 @@
|
||||
CREATE TABLE `useroption` ( id INTEGER PRIMARY KEY AUTOINCREMENT , `new_tasks_at_bottom` INTEGER, `show_animations` INTEGER, `show_assignee` INTEGER, `multiple_tasks_per_row` INTEGER, `language` TEXT);
|
||||
CREATE TABLE `jwt` ( id INTEGER PRIMARY KEY AUTOINCREMENT , `secret` TEXT);
|
||||
CREATE TABLE `board` ( id INTEGER PRIMARY KEY AUTOINCREMENT , `name` TEXT, `is_active` INTEGER);
|
||||
CREATE TABLE `category` ( `id` INTEGER PRIMARY KEY AUTOINCREMENT ,`name` TEXT,`default_task_color` TEXT,`board_id` INTEGER , FOREIGN KEY(`board_id`)
|
||||
REFERENCES `board`(`id`)
|
||||
ON DELETE CASCADE ON UPDATE CASCADE );
|
||||
CREATE INDEX index_foreignkey_category_board ON `category` (board_id) ;
|
||||
CREATE TABLE `issuetracker` ( `id` INTEGER PRIMARY KEY AUTOINCREMENT ,`url` TEXT,`regex` TEXT,`board_id` INTEGER , FOREIGN KEY(`board_id`)
|
||||
REFERENCES `board`(`id`)
|
||||
ON DELETE CASCADE ON UPDATE CASCADE );
|
||||
CREATE INDEX index_foreignkey_issuetracker_board ON `issuetracker` (board_id) ;
|
||||
CREATE TABLE `column` ( `id` INTEGER PRIMARY KEY AUTOINCREMENT ,`name` TEXT,`position` INTEGER,`board_id` INTEGER , `task_limit` INTEGER, FOREIGN KEY(`board_id`)
|
||||
REFERENCES `board`(`id`)
|
||||
ON DELETE CASCADE ON UPDATE CASCADE );
|
||||
CREATE INDEX index_foreignkey_column_board ON `column` (board_id) ;
|
||||
CREATE TABLE `board_user` ( `id` INTEGER PRIMARY KEY AUTOINCREMENT ,`user_id` INTEGER,`board_id` INTEGER , FOREIGN KEY(`board_id`)
|
||||
REFERENCES `board`(`id`)
|
||||
ON DELETE CASCADE ON UPDATE CASCADE, FOREIGN KEY(`user_id`)
|
||||
REFERENCES `user`(`id`)
|
||||
ON DELETE CASCADE ON UPDATE CASCADE );
|
||||
CREATE INDEX index_foreignkey_board_user_user ON `board_user` (user_id) ;
|
||||
CREATE INDEX index_foreignkey_board_user_board ON `board_user` (board_id) ;
|
||||
CREATE UNIQUE INDEX UQ_board_useruser_id__board_id ON `board_user` (`user_id`,`board_id`);
|
||||
CREATE TABLE `activity` ( `id` INTEGER PRIMARY KEY AUTOINCREMENT ,`user_id` INTEGER,`log_text` TEXT,`before` TEXT,`after` TEXT,`item_type` TEXT,`item_id` INTEGER,`timestamp` INTEGER , FOREIGN KEY(`user_id`)
|
||||
REFERENCES `user`(`id`)
|
||||
ON DELETE SET NULL ON UPDATE SET NULL );
|
||||
CREATE INDEX index_foreignkey_activity_user ON `activity` (user_id) ;
|
||||
CREATE INDEX index_foreignkey_activity_item ON `activity` (item_id) ;
|
||||
CREATE TABLE `autoaction` ( `id` INTEGER PRIMARY KEY AUTOINCREMENT ,`trigger` INTEGER,`source_id` INTEGER,`type` INTEGER,`change_to` INTEGER,`board_id` INTEGER , FOREIGN KEY(`board_id`)
|
||||
REFERENCES `board`(`id`)
|
||||
ON DELETE SET NULL ON UPDATE SET NULL );
|
||||
CREATE INDEX index_foreignkey_autoaction_board ON `autoaction` (board_id) ;
|
||||
CREATE INDEX index_foreignkey_autoaction_source ON `autoaction` (source_id) ;
|
||||
CREATE TABLE `task` ( `id` INTEGER PRIMARY KEY AUTOINCREMENT ,`title` TEXT,`description` TEXT,`color` TEXT,`due_date` TEXT,`points` INTEGER,`position` INTEGER,`column_id` INTEGER , FOREIGN KEY(`column_id`)
|
||||
REFERENCES `column`(`id`)
|
||||
ON DELETE SET NULL ON UPDATE SET NULL );
|
||||
CREATE INDEX index_foreignkey_task_column ON `task` (column_id) ;
|
||||
CREATE TABLE `comment` ( `id` INTEGER PRIMARY KEY AUTOINCREMENT ,`text` TEXT,`user_id` INTEGER,`task_id` INTEGER , `timestamp` TEXT, `is_edited` INTEGER, FOREIGN KEY(`user_id`)
|
||||
REFERENCES `user`(`id`)
|
||||
ON DELETE SET NULL ON UPDATE SET NULL, FOREIGN KEY(`task_id`)
|
||||
REFERENCES `task`(`id`)
|
||||
ON DELETE SET NULL ON UPDATE SET NULL );
|
||||
CREATE INDEX index_foreignkey_comment_task ON `comment` (task_id) ;
|
||||
CREATE INDEX index_foreignkey_comment_user ON `comment` (user_id) ;
|
||||
CREATE TABLE `task_user` ( `id` INTEGER PRIMARY KEY AUTOINCREMENT ,`user_id` INTEGER,`task_id` INTEGER , FOREIGN KEY(`task_id`)
|
||||
REFERENCES `task`(`id`)
|
||||
ON DELETE CASCADE ON UPDATE CASCADE, FOREIGN KEY(`user_id`)
|
||||
REFERENCES `user`(`id`)
|
||||
ON DELETE CASCADE ON UPDATE CASCADE );
|
||||
CREATE INDEX index_foreignkey_task_user_user ON `task_user` (user_id) ;
|
||||
CREATE INDEX index_foreignkey_task_user_task ON `task_user` (task_id) ;
|
||||
CREATE UNIQUE INDEX UQ_task_useruser_id__task_id ON `task_user` (`user_id`,`task_id`);
|
||||
CREATE TABLE `category_task` ( `id` INTEGER PRIMARY KEY AUTOINCREMENT ,`category_id` INTEGER,`task_id` INTEGER , FOREIGN KEY(`task_id`)
|
||||
REFERENCES `task`(`id`)
|
||||
ON DELETE CASCADE ON UPDATE CASCADE, FOREIGN KEY(`category_id`)
|
||||
REFERENCES `category`(`id`)
|
||||
ON DELETE CASCADE ON UPDATE CASCADE );
|
||||
CREATE INDEX index_foreignkey_category_task_category ON `category_task` (category_id) ;
|
||||
CREATE INDEX index_foreignkey_category_task_task ON `category_task` (task_id) ;
|
||||
CREATE UNIQUE INDEX UQ_category_taskcategory_id__task_id ON `category_task` (`category_id`,`task_id`);
|
||||
CREATE TABLE `collapsed` ( `id` INTEGER PRIMARY KEY AUTOINCREMENT ,`user_id` INTEGER,`column_id` INTEGER , FOREIGN KEY(`user_id`)
|
||||
REFERENCES `user`(`id`)
|
||||
ON DELETE SET NULL ON UPDATE SET NULL, FOREIGN KEY(`column_id`)
|
||||
REFERENCES `column`(`id`)
|
||||
ON DELETE SET NULL ON UPDATE SET NULL );
|
||||
CREATE INDEX index_foreignkey_collapsed_column ON `collapsed` (column_id) ;
|
||||
CREATE INDEX index_foreignkey_collapsed_user ON `collapsed` (user_id) ;
|
||||
CREATE TABLE `user` ( `id` INTEGER PRIMARY KEY AUTOINCREMENT ,`security_level` INTEGER,`username` TEXT,`password_hash` TEXT,`email` TEXT,`default_board_id` INTEGER,`user_option_id` INTEGER,`last_login` TEXT,`active_token` TEXT );
|
||||
CREATE INDEX index_foreignkey_user_user_option ON `user` (user_option_id) ;
|
||||
CREATE INDEX index_foreignkey_user_default_board ON `user` (default_board_id) ;
|
||||
251
tools/tb-github-project.php
Normal file
251
tools/tb-github-project.php
Normal file
@ -0,0 +1,251 @@
|
||||
<?php
|
||||
error_reporting(E_ERROR);
|
||||
|
||||
class TbGitHubImport {
|
||||
var $db;
|
||||
var $isNew;
|
||||
var $user;
|
||||
var $pass;
|
||||
var $repo;
|
||||
var $ch;
|
||||
var $api;
|
||||
var $projects;
|
||||
|
||||
function __construct() {
|
||||
$this->ch = curl_init();
|
||||
$this->api = "https://api.github.com/";
|
||||
}
|
||||
|
||||
function __destruct() {
|
||||
print "Closing 'taskboard.sqlite'...";
|
||||
$this->db->exec('PRAGMA foreign_keys = ON');
|
||||
$this->db->close();
|
||||
print " Done.\n";
|
||||
}
|
||||
|
||||
function import() {
|
||||
$this->openDb();
|
||||
$this->getInfo();
|
||||
$this->loadData();
|
||||
$this->importData();
|
||||
}
|
||||
|
||||
private function openDb() {
|
||||
print "Opening 'taskboard.sqlite'...";
|
||||
$this->isNew = !file_exists('taskboard.sqlite');
|
||||
|
||||
if ($this->isNew) {
|
||||
print "\n File not found, creating...";
|
||||
}
|
||||
|
||||
$this->db = new SQLite3('taskboard.sqlite');
|
||||
print " Done.\n";
|
||||
|
||||
if ($this->isNew) {
|
||||
print "Creating tables...";
|
||||
$schema = file_get_contents('schema');
|
||||
$this->db->exec($schema);
|
||||
print " Done.\n";
|
||||
}
|
||||
|
||||
$this->db->exec('PRAGMA foreign_keys = OFF');
|
||||
}
|
||||
|
||||
private function getInfo() {
|
||||
$this->user = readline("Enter your GitHub user name: ");
|
||||
$this->pass = readline("Enter your GitHub password: ");
|
||||
$this->repo = readline("What repo do you want to export projects from? ");
|
||||
}
|
||||
|
||||
private function loadData() {
|
||||
$options = array(
|
||||
CURLOPT_URL => $this->api . "repos/" . $this->user . "/" . $this->repo . "/projects",
|
||||
CURLOPT_USERAGENT => "Googlebot/2.1 (+http://www.google.com/bot.html)",
|
||||
CURLOPT_HTTPAUTH => CURLAUTH_BASIC,
|
||||
CURLOPT_RETURNTRANSFER => 1,
|
||||
CURLOPT_USERPWD => $this->user . ":" . $this->pass,
|
||||
CURLOPT_HTTPHEADER => array(
|
||||
'Accept: application/vnd.github.inertia-preview+json'
|
||||
)
|
||||
);
|
||||
curl_setopt_array($this->ch, $options);
|
||||
|
||||
$data = json_decode(curl_exec($this->ch));
|
||||
$this->projects = [];
|
||||
|
||||
foreach ($data as $project) {
|
||||
$this->projects[$project->id] =
|
||||
(object)array("id" => $project->id, "name" => $project->name);
|
||||
}
|
||||
|
||||
print("Found " . count($this->projects) . " project" .
|
||||
(count($this->projects) === 1 ? "" : "s") . ".\n");
|
||||
|
||||
foreach ($this->projects as $project) {
|
||||
print " Loading Project " . $project->name . "...\n";
|
||||
|
||||
curl_setopt(
|
||||
$this->ch,
|
||||
CURLOPT_URL,
|
||||
$this->api . "projects/" . $project->id . "/columns"
|
||||
);
|
||||
$data = json_decode(curl_exec($this->ch));
|
||||
|
||||
$columns = [];
|
||||
$colPos = 1;
|
||||
|
||||
foreach ($data as $column) {
|
||||
print " Loading Column " . $column->name . "...";
|
||||
|
||||
$currentColumn = (object)array(
|
||||
"id" => $column->id, "name" => $column->name, "position" => $colPos
|
||||
);
|
||||
$colPos++;
|
||||
|
||||
curl_setopt(
|
||||
$this->ch,
|
||||
CURLOPT_URL,
|
||||
$this->api . "projects/columns/" . $column->id . "/cards"
|
||||
);
|
||||
$cardData = json_decode(curl_exec($this->ch));
|
||||
|
||||
$cards = [];
|
||||
$cardPos = 1;
|
||||
|
||||
foreach ($cardData as $card) {
|
||||
$cards[] = (object)array(
|
||||
"id" => $card->id,
|
||||
"title" => "Imported",
|
||||
"color" => "#ffffe0",
|
||||
"description" => $card->note,
|
||||
"position" => $cardPos,
|
||||
"column_id" => $column->id
|
||||
);
|
||||
$cardPos++;
|
||||
}
|
||||
|
||||
$this->projects[$project->id]->columns[$column->id] = $currentColumn;
|
||||
$this->projects[$project->id]->columns[$column->id]->cards = $cards;
|
||||
|
||||
print " Loaded " . ($cardPos - 1) . " cards (tasks).\n";
|
||||
}
|
||||
|
||||
print " Loaded Project " . $project->name . ".\n";
|
||||
}
|
||||
}
|
||||
|
||||
private function importData() {
|
||||
foreach($this->projects as $project) {
|
||||
print " Importing Project " . $project->name . "...\n";
|
||||
|
||||
$exists = $this->db->querySingle('SELECT id FROM board WHERE name = "' .
|
||||
$project->name . '"');
|
||||
|
||||
if (count($exists) === 0) {
|
||||
$stmt = $this->db->prepare('INSERT INTO board (name, is_active) ' .
|
||||
'VALUES (:name, :is_active)');
|
||||
|
||||
$stmt->bindValue(":name", $project->name);
|
||||
$stmt->bindValue(":is_active", true);
|
||||
|
||||
if ($stmt->execute()) {
|
||||
print " Created board.\n";
|
||||
}
|
||||
}
|
||||
|
||||
if ($this->isNew) {
|
||||
$stmt = $this->db->prepare('INSERT INTO user (username, security_level, ' .
|
||||
'password_hash) VALUES (:uname, :secLev, :hash)');
|
||||
$stmt->bindValue(':uname', 'admin');
|
||||
$stmt->bindValue(':secLev', 1);
|
||||
$stmt->bindValue(':hash', password_hash('admin', PASSWORD_BCRYPT));
|
||||
|
||||
if ($stmt->execute()) {
|
||||
print " Created default admin user.\n";
|
||||
}
|
||||
|
||||
$adminId = $this->db->lastInsertRowID();
|
||||
$stmt = $this->db->prepare('INSERT INTO useroption (id, ' .
|
||||
'new_tasks_at_bottom, show_animations, show_assignee, ' .
|
||||
'multiple_tasks_per_row, language) VALUES (:id, :new, :anim, ' .
|
||||
':assign, :mult, :lang)');
|
||||
$stmt->bindValue(':id', $adminId);
|
||||
$stmt->bindValue(':new', true);
|
||||
$stmt->bindValue(':anim', true);
|
||||
$stmt->bindValue(':assign', true);
|
||||
$stmt->bindValue(':mult', false);
|
||||
$stmt->bindValue(':lang', 'en');
|
||||
|
||||
$stmt->execute();
|
||||
}
|
||||
|
||||
$boardId = $this->cleanupExistingTables($project->name);
|
||||
|
||||
$users = $this->db->query('SELECT id FROM user WHERE security_level = 1');
|
||||
$stmt = $this->db->prepare('INSERT INTO board_user (user_id, board_id) '.
|
||||
'VALUES (:user_id, :board_id)');
|
||||
|
||||
while ($user = $users->fetchArray()) {
|
||||
$stmt->bindValue(':user_id', $user['id']);
|
||||
$stmt->bindValue(':board_id', $boardId);
|
||||
|
||||
$stmt->execute();
|
||||
}
|
||||
print " Added admin user(s) to board.\n";
|
||||
|
||||
$colCount = 0;
|
||||
$taskCount = 0;
|
||||
|
||||
foreach ($project->columns as $column) {
|
||||
$stmt = $this->db->prepare('INSERT INTO column (name, position, board_id) ' .
|
||||
'VALUES (:name, :pos, :board_id)');
|
||||
|
||||
$stmt->bindValue(':name', $column->name);
|
||||
$stmt->bindValue(':pos', $column->position);
|
||||
$stmt->bindValue(':board_id', $boardId);
|
||||
|
||||
$stmt->execute();
|
||||
$colCount++;
|
||||
$colId = $this->db->lastInsertRowID();
|
||||
|
||||
$stmt = $this->db->prepare('INSERT INTO task (title, description, ' .
|
||||
'color, position, column_id) VALUES (:title, :description, :color,' .
|
||||
':pos, :col_id)');
|
||||
foreach($column->cards as $card) {
|
||||
$stmt->bindValue(':title', $card->title);
|
||||
$stmt->bindValue(':description', $card->description);
|
||||
$stmt->bindValue(':color', $card->color);
|
||||
$stmt->bindValue(':pos', $card->position);
|
||||
$stmt->bindValue(':col_id', $colId);
|
||||
|
||||
$stmt->execute();
|
||||
$taskCount++;
|
||||
}
|
||||
}
|
||||
|
||||
print " Inserted " . $colCount . " columns, and " . $taskCount . " tasks.\n";
|
||||
}
|
||||
|
||||
print " Done Importing.\n";
|
||||
}
|
||||
|
||||
private function cleanupExistingTables($boardName) {
|
||||
$boardId = $this->db->querySingle('SELECT id FROM board ' .
|
||||
'WHERE name = "' . $boardName . '"');
|
||||
$this->db->exec('DELETE FROM board_user WHERE board_id = ' . $boardId);
|
||||
$columns = $this->db->query('SELECT id FROM column WHERE board_id = ' . $boardId);
|
||||
|
||||
while ($col = $columns->fetchArray()) {
|
||||
$this->db->exec('DELETE FROM task WHERE column_id = ' . $col['id']);
|
||||
}
|
||||
|
||||
$this->db->exec('DELETE FROM column WHERE board_id = ' . $boardId);
|
||||
|
||||
return $boardId;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
$tb = new TbGitHubImport();
|
||||
$tb->import();
|
||||
|
||||
382
tools/tb-migrate.php
Normal file
382
tools/tb-migrate.php
Normal file
@ -0,0 +1,382 @@
|
||||
<?php
|
||||
|
||||
class TbMigrate {
|
||||
var $oldDb;
|
||||
var $newDb;
|
||||
|
||||
function __construct() {
|
||||
print "Opening 'taskboard.db'...";
|
||||
try {
|
||||
$this->oldDb = new SQLite3('taskboard.db', SQLITE3_OPEN_READONLY);
|
||||
print "\t\tDone.\n";
|
||||
} catch (Exception $e) {
|
||||
print "\t\tError opening 'taskboard.db'\n";
|
||||
print " " . $e->getMessage() . "\n";
|
||||
die();
|
||||
}
|
||||
|
||||
print "Opening 'taskboard.sqlite'...";
|
||||
try {
|
||||
unlink('taskboard.sqlite'); // Always start fresh.
|
||||
|
||||
$this->newDb = new SQLite3('taskboard.sqlite');
|
||||
print "\t\tDone.\n\n";
|
||||
} catch (Exception $e) {
|
||||
print "\t\tError creating 'taskboard.sqlite'\n";
|
||||
print " " . $e->getMessage() . "\n";
|
||||
die();
|
||||
}
|
||||
}
|
||||
|
||||
function __destruct() {
|
||||
print "\n";
|
||||
print "Closing 'taskboard.sqlite'...";
|
||||
$this->newDb->exec('PRAGMA foreign_keys = ON');
|
||||
$this->newDb->close();
|
||||
print "\t\tDone.\n";
|
||||
|
||||
print "Closing 'taskboard.db'...";
|
||||
$this->oldDb->close();
|
||||
print "\t\tDone.\n";
|
||||
}
|
||||
|
||||
function migrate() {
|
||||
$this->createTables();
|
||||
|
||||
$this->migrateActivity();
|
||||
// TODO: attachments table
|
||||
$this->migrateAutoAction();
|
||||
$this->migrateBoard();
|
||||
$this->migrateBoardUser();
|
||||
$this->migrateCategory();
|
||||
$this->migrateCollapsed();
|
||||
$this->migrateComment();
|
||||
$this->migrateItem();
|
||||
$this->migrateLane();
|
||||
$this->migrateUser();
|
||||
}
|
||||
|
||||
private function createTables() {
|
||||
print " Creating new tables...";
|
||||
$schema = file_get_contents('schema');
|
||||
|
||||
$this->newDb->exec($schema);
|
||||
$this->newDb->exec('PRAGMA foreign_keys = OFF');
|
||||
print "\t\t\tDone.\n\n";
|
||||
}
|
||||
|
||||
private function getItemType($str) {
|
||||
if (strpos($str, 'item') !== false) {
|
||||
return 'task';
|
||||
}
|
||||
|
||||
if (strpos($str, 'column') !== false) {
|
||||
return 'column';
|
||||
}
|
||||
|
||||
if (strpos($str, 'board') !== false) {
|
||||
return 'board';
|
||||
}
|
||||
|
||||
if (strpos($str, 'changed') !== false || strpos($str, 'logged') !== false ||
|
||||
strpos($str, 'added') !== false || strpos($str, 'removed') !== false) {
|
||||
return 'user';
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
|
||||
private function getItemId($itemId, $newValue) {
|
||||
if (isset($itemId)) {
|
||||
return $itemId;
|
||||
}
|
||||
|
||||
$obj = json_decode($newValue);
|
||||
|
||||
if ($obj !== null) {
|
||||
return $obj->id;
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
|
||||
private function getActionType($row) {
|
||||
switch ($row['action_id']) {
|
||||
case 0:
|
||||
return 1;
|
||||
break;
|
||||
case 2:
|
||||
return 4;
|
||||
break;
|
||||
case 3:
|
||||
return 6;
|
||||
break;
|
||||
default:
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
private function getActionChange($row) {
|
||||
if (isset($row['color'])) {
|
||||
return $row['color'];
|
||||
}
|
||||
|
||||
if (isset($row['category_id'])) {
|
||||
return $row['category_id'];
|
||||
}
|
||||
|
||||
if (isset($row['assignee_id'])) {
|
||||
return $row['assignee_id'];
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
|
||||
private function migrateTable($stmtStr, $fn, $oldTable = null) {
|
||||
$table = isset($oldTable) ? $oldTable : explode(' ', $stmtStr)[2];
|
||||
|
||||
print " Migrating table `$table`...";
|
||||
|
||||
$results = $this->oldDb->query("SELECT * from $table ORDER BY id");
|
||||
|
||||
if ($results->numColumns() === 0) {
|
||||
print " no rows.\n";
|
||||
return;
|
||||
}
|
||||
|
||||
$stmt = $this->newDb->prepare($stmtStr);
|
||||
$rowCount = 0;
|
||||
$errCount = 0;
|
||||
|
||||
while ($row = $results->fetchArray()) {
|
||||
$fn($stmt, $row);
|
||||
|
||||
if ($stmt->execute() === false) {
|
||||
$errCount++;
|
||||
continue;
|
||||
}
|
||||
|
||||
$rowCount++;
|
||||
}
|
||||
|
||||
$stmt->close();
|
||||
print strlen($table) < 10 ? "\t" : "";
|
||||
print "\t$rowCount rows migrated.\n";
|
||||
|
||||
if ($errCount > 0) {
|
||||
print " $errCount rows failed.\n";
|
||||
}
|
||||
}
|
||||
|
||||
private function migrateActivity() {
|
||||
$stmtStr = 'INSERT INTO activity (id, user_id, log_text, before, after, ' .
|
||||
'item_type, item_id, timestamp) VALUES (:id, :user_id, :log_text, ' .
|
||||
':before, :after, :item_type, :item_id, :timestamp)';
|
||||
$knownNames = [];
|
||||
|
||||
$this->migrateTable($stmtStr, function(&$stmt, $row) use ($knownNames) {
|
||||
$name = explode(' ', $row['comment'])[0];
|
||||
|
||||
if (!array_key_exists($name, $knownNames)) {
|
||||
$usr = $this->oldDb->query('SELECT id FROM user ' .
|
||||
'WHERE username = "' . $name . '"');
|
||||
|
||||
$knownNames[$name] = $usr->fetchArray()['id'];
|
||||
}
|
||||
|
||||
$type = $this->getItemType($row['comment']);
|
||||
|
||||
$stmt->bindValue(':id', $row['id']);
|
||||
$stmt->bindValue(':user_id', $knownNames[$name]);
|
||||
$stmt->bindValue(':log_text', $row['comment']);
|
||||
$stmt->bindValue(':before', $row['old_value']);
|
||||
$stmt->bindValue(':after', $row['new_value']);
|
||||
$stmt->bindValue(':item_type', $type);
|
||||
$stmt->bindValue(':item_id', $type === 'user'
|
||||
? $knownNames[$name]
|
||||
: $this->getItemId($row['item_id'], $row['new_value']));
|
||||
$stmt->bindValue(':timestamp', $row['timestamp']);
|
||||
});
|
||||
}
|
||||
|
||||
private function migrateAutoAction() {
|
||||
$stmtStr = 'INSERT INTO autoaction (id, trigger, source_id, type, ' .
|
||||
'change_to, board_id) VALUES (:id, :trigger, :source_id, :type, ' .
|
||||
':change_to, :board_id)';
|
||||
|
||||
$this->migrateTable($stmtStr, function (&$stmt, $row) {
|
||||
$stmt->bindValue(':id', $row['id']);
|
||||
$stmt->bindValue(':trigger', ((int)$row['trigger_id']) + 1);
|
||||
$stmt->bindValue(':source_id', $row['secondary_id']);
|
||||
$stmt->bindValue(':type', $this->getActionType($row));
|
||||
$stmt->bindValue(':change_to', $this->getActionChange($row));
|
||||
$stmt->bindValue(':board_id', $row['board_id']);
|
||||
});
|
||||
}
|
||||
|
||||
private function migrateBoard() {
|
||||
$stmtStr = 'INSERT INTO board (id, name, is_active) ' .
|
||||
'VALUES (:id, :name, :is_active)';
|
||||
|
||||
$this->migrateTable($stmtStr, function (&$stmt, $row) {
|
||||
$stmt->bindValue(':id', $row['id']);
|
||||
$stmt->bindValue(':name', $row['name']);
|
||||
$stmt->bindValue(':is_active', $row['active']);
|
||||
});
|
||||
}
|
||||
|
||||
private function migrateBoardUser() {
|
||||
$stmtStr = 'INSERT INTO board_user (id, user_id, board_id) ' .
|
||||
'VALUES (:id, :user_id, :board_id)';
|
||||
|
||||
$this->migrateTable($stmtStr, function (&$stmt, $row) {
|
||||
$stmt->bindValue(':id', $row['id']);
|
||||
$stmt->bindValue(':user_id', $row['user_id']);
|
||||
$stmt->bindValue(':board_id', $row['board_id']);
|
||||
});
|
||||
}
|
||||
|
||||
private function migrateCategory() {
|
||||
$stmtStr = 'INSERT INTO category (id, name, default_task_color, board_id) ' .
|
||||
'VALUES (:id, :name, "#ffffe0", :board_id)';
|
||||
|
||||
$this->migrateTable($stmtStr, function (&$stmt, $row) {
|
||||
$stmt->bindValue(':id', $row['id']);
|
||||
$stmt->bindValue(':name', $row['name']);
|
||||
$stmt->bindValue(':board_id', $row['board_id']);
|
||||
});
|
||||
}
|
||||
|
||||
private function migrateCollapsed() {
|
||||
$stmtStr = 'INSERT INTO collapsed (id, user_id, column_id) ' .
|
||||
'VALUES (:id, :user_id, :column_id)';
|
||||
|
||||
$this->migrateTable($stmtStr, function (&$stmt, $row) {
|
||||
$stmt->bindValue(':id', $row['id']);
|
||||
$stmt->bindValue(':user_id', $row['user_id']);
|
||||
$stmt->bindValue(':column_id', $row['lane_id']);
|
||||
});
|
||||
}
|
||||
|
||||
private function migrateComment() {
|
||||
$stmtStr = 'INSERT INTO comment (id, text, user_id, task_id, timestamp, ' .
|
||||
'is_edited) VALUES (:id, :text, :user_id, :task_id, :timestamp, 0)';
|
||||
|
||||
$this->migrateTable($stmtStr, function (&$stmt, $row) {
|
||||
$stmt->bindValue(':id', $row['id']);
|
||||
$stmt->bindValue(':text', $row['text']);
|
||||
$stmt->bindValue(':user_id', $row['user_id']);
|
||||
$stmt->bindValue(':task_id', $row['item_id']);
|
||||
$stmt->bindValue(':timestamp', $row['timestamp']);
|
||||
});
|
||||
}
|
||||
|
||||
private function migrateItem() {
|
||||
$stmtStr = 'INSERT INTO task (id, title, description, color, due_date, ' .
|
||||
'points, position, column_id) VALUES (:id, :title, :description, :color, ' .
|
||||
':due_date, :points, :position, :column_id)';
|
||||
|
||||
$this->migrateTable($stmtStr, function (&$stmt, $row) {
|
||||
$stmt->bindValue(':id', $row['id']);
|
||||
$stmt->bindValue(':title', $row['title']);
|
||||
$stmt->bindValue(':description', $row['description']);
|
||||
$stmt->bindValue(':color', $row['color']);
|
||||
$stmt->bindValue(':due_date', $row['due_date']);
|
||||
$stmt->bindValue(':points', $row['points']);
|
||||
$stmt->bindValue(':position', $row['position']);
|
||||
$stmt->bindValue(':column_id', $row['lane_id']);
|
||||
|
||||
$this->newDb->exec('INSERT INTO task_user (user_id, task_id) ' .
|
||||
'VALUES (' . $row['assignee'] . ', ' . $row['id'] . ')');
|
||||
$this->newDb->exec('INSERT INTO category_task (category_id, task_id) ' .
|
||||
'VALUES (' . $row['category'] . ', ' . $row['id'] . ')');
|
||||
}, 'item', function ($lastId, $row) {
|
||||
});
|
||||
}
|
||||
|
||||
private function migrateLane() {
|
||||
$stmtStr = 'INSERT INTO column (id, name, position, board_id) ' .
|
||||
'VALUES (:id, :name, :position, :board_id)';
|
||||
|
||||
$this->migrateTable($stmtStr, function (&$stmt, $row) {
|
||||
$stmt->bindValue(':id', $row['id']);
|
||||
$stmt->bindValue(':name', $row['name']);
|
||||
$stmt->bindValue(':position', $row['position']);
|
||||
$stmt->bindValue(':board_id', $row['board_id']);
|
||||
}, 'lane');
|
||||
}
|
||||
|
||||
private function migrateOption() {
|
||||
$stmtStr = 'INSERT INTO useroption (id, new_tasks_at_bottom, ' .
|
||||
'show_animations, show_assignee, multiple_tasks_per_row, language) ' .
|
||||
'VALUES (:id, :atBottom, :anims, :assignee, 0, "en")';
|
||||
|
||||
$this->migrateTable($stmtStr, function (&$stmt, $row) {
|
||||
$stmt->bindValue(':id', $row['id']);
|
||||
$stmt->bindValue(':atBottom', isset($row['tasks_order'])
|
||||
? $row['tasks_order']
|
||||
: $row['new_task_position']);
|
||||
$stmt->bindValue(':anims', isset($row['animate'])
|
||||
? $row['animate']
|
||||
: $row['show_animations']);
|
||||
$stmt->bindValue(':assignee', isset($row['show_assignee'])
|
||||
? $row['show_assignee']
|
||||
: 1);
|
||||
}, 'option');
|
||||
}
|
||||
|
||||
private function migrateUser() {
|
||||
$stmtStr = 'INSERT INTO user (id, username, security_level, password_hash, ' .
|
||||
'email, default_board_id, user_option_id, last_login) VALUES (:id, ' .
|
||||
':uname, :secLev, :hash, :email, :board, :option, :last)';
|
||||
|
||||
$this->migrateTable($stmtStr, function (&$stmt, $row) {
|
||||
$stmt->bindValue(':id', $row['id']);
|
||||
$stmt->bindValue(':uname', $row['username']);
|
||||
$stmt->bindValue(':secLev', $row['is_admin'] === 1 ? 1 : 3);
|
||||
$stmt->bindValue(':hash', $row['password']);
|
||||
$stmt->bindValue(':email', $row['email']);
|
||||
$stmt->bindValue(':board', $row['default_board']);
|
||||
$stmt->bindValue(':option', $row['id']);
|
||||
$stmt->bindValue(':last', $row['last_login']);
|
||||
});
|
||||
|
||||
$users = $this->newDb->query('SELECT id FROM user ORDER BY id');
|
||||
|
||||
while ($row = $users->fetchArray()) {
|
||||
$stmt = $this->newDb->prepare('INSERT INTO useroption (id, ' .
|
||||
'new_tasks_at_bottom, show_animations, show_assignee, ' .
|
||||
'multiple_tasks_per_row, language) VALUES (:id, :atBottom, :anims, ' .
|
||||
':assignee, 0, "en")');
|
||||
|
||||
$opts = $this->oldDb->query(
|
||||
'SELECT * FROM option WHERE id = ' . (int)$row['id']
|
||||
);
|
||||
$opts = $opts->fetchArray();
|
||||
|
||||
if ($opts === false) {
|
||||
continue;
|
||||
}
|
||||
|
||||
$stmt->bindValue(':id', $opts['id']);
|
||||
$stmt->bindValue(':atBottom', isset($opts['tasks_order'])
|
||||
? $opts['tasks_order']
|
||||
: $opts['new_task_position']);
|
||||
$stmt->bindValue(':anims', isset($opts['animate'])
|
||||
? $opts['animate']
|
||||
: $opts['show_animations']);
|
||||
$stmt->bindValue(':assignee', isset($opts['show_assignee'])
|
||||
? $opts['show_assignee']
|
||||
: 1);
|
||||
|
||||
$stmt->execute();
|
||||
}
|
||||
|
||||
$stmt->close();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
$tbm = new TbMigrate();
|
||||
$tbm->migrate();
|
||||
|
||||
Reference in New Issue
Block a user