From 19f217c51c021421b4855abee2aedfabf16bfb59 Mon Sep 17 00:00:00 2001 From: kremsy Date: Sun, 2 Feb 2014 18:55:29 +0100 Subject: [PATCH] database converter --- DatabaseConverter.php | 578 ++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 578 insertions(+) create mode 100644 DatabaseConverter.php diff --git a/DatabaseConverter.php b/DatabaseConverter.php new file mode 100644 index 00000000..903020d3 --- /dev/null +++ b/DatabaseConverter.php @@ -0,0 +1,578 @@ +connectToSourceDB($host, $port, $user, $pass, "smesc12"); +$test = $converter->convertPlayersAndStatistics(); +$test = $converter->convertMapsAndKarma(); +unset($converter); +var_dump($test); + +class DatabaseConverter { + /** + * Constants + */ + const MC_TABLE_STATISTICS = 'mc_statistics'; + const MC_TABLE_STATSMETADATA = 'mc_statmetadata'; + const MC_TABLE_PLAYERS = 'mc_players'; + const MC_TABLE_MAPS = 'mc_maps'; + const MC_TABLE_KARMA = 'mc_karma'; + const AS_TABLE_MAPS = 'maps'; + const AS_TABLE_PLAYERS = 'players'; + const AS_TABLE_PLAYERS_EXTRA = 'players_extra'; + const AS_TABLE_KARMA = 'rs_karma'; + + /** + * Public properties + */ + private $mysqli = null; + /** @var \mysqli $sourceMysqli */ + private $sourceMysqli = null; + + private $targetDatabase = ""; + + + public function __construct($host, $port, $user, $pass, $dbname) { + $host = (string)$host; + $port = (int)$port; + $user = (string)$user; + $pass = (string)$pass; + + $this->targetDatabase = $dbname; + + // Open database connection + $this->mysqli = new \mysqli($host, $user, $pass, null, $port); + if ($this->mysqli->connect_error) { + trigger_error($this->mysqli->connect_error, E_USER_ERROR); + } + $this->mysqli->set_charset("utf8"); + + $this->initDatabase(); + } + + public function connectToSourceDB($host, $port, $user, $pass, $dbname) { + $host = (string)$host; + $port = (int)$port; + $user = (string)$user; + $pass = (string)$pass; + $dbname = (string)$dbname; + + // Open database connection + $this->sourceMysqli = new \mysqli($host, $user, $pass, null, $port); + if ($this->sourceMysqli->connect_error) { + trigger_error($this->sourceMysqli->connect_error, E_USER_ERROR); + } + $this->sourceMysqli->set_charset("utf8"); + + // Connect to new database + $this->sourceMysqli->select_db($dbname); + if ($this->sourceMysqli->error) { + trigger_error("Couldn't select database '{$dbname}'. " . $this->sourceMysqli->error, E_USER_ERROR); + return false; + } + return true; + } + + /** + * Destruct database connection + */ + public function __destruct() { + $this->mysqli->close(); + if ($this->sourceMysqli != null) { + $this->sourceMysqli->close(); + } + } + + public function convertMapsAndKarma() { + $success = $this->initMapsTable(); + if (!$success) { + return false; + } + + $mapQuery = "SELECT * FROM `" . self::AS_TABLE_MAPS . "`;"; + $result = $this->sourceMysqli->query($mapQuery); + + if (!$result) { + return false; + } + + $mapConvertQuery = "INSERT IGNORE INTO `" . self::MC_TABLE_MAPS . "` + ( `uid`, `name`, `authorLogin`, `environment`) + VALUES + ( ?,?,?, ? );"; + $statement = $this->mysqli->prepare($mapConvertQuery); + if ($this->mysqli->error) { + trigger_error($this->mysqli->error); + return false; + } + + + //Loop through all the players + while($row = $result->fetch_object()) { + $statement->bind_param('ssss', $row->Uid, $row->Name, $row->Author, $row->Environment); + $statement->execute(); + if ($statement->error) { + trigger_error($statement->error); + return false; + } + } + $result->free_result(); + $statement->close(); + + return $this->convertKarma(); + } + + private function convertKarma() { + $success = $this->initKarmaTable(); + if (!$success) { + return false; + } + + //Build Map Vector + $mapQuery = "SELECT uid, " . self::MC_TABLE_MAPS . ".index FROM `" . self::MC_TABLE_MAPS . "`;"; + $result = $this->mysqli->query($mapQuery); + if (!$result) { + var_dump($this->mysqli->error); + trigger_error("Building Map Vector failed"); + return false; + } + + + $mapvector = array(); + while($row = $result->fetch_object()) { + $mapvector[$row->uid] = $row->index; + } + $result->free_result(); + + //Build Player Vector + $playerQuery = "SELECT " . self::MC_TABLE_PLAYERS . ".index, login FROM `" . self::MC_TABLE_PLAYERS . "`;"; + $result = $this->mysqli->query($playerQuery); + + if (!$result) { + trigger_error("Building Player Vector failed"); + return false; + } + + $playerVector = array(); + while($row = $result->fetch_object()) { + $playerVector[$row->login] = $row->index; + } + $result->free_result(); + + + //SELECT Login, Uid, Score FROM `rs_karma` INNER JOIN `maps` ON (maps.id = rs_karma.id) INNER JOIN `players` ON (players.Id = rs_karma.PlayerId); + //Get Karma Table + $karmaQuery = "SELECT Login, Uid, Score FROM `" . self::AS_TABLE_KARMA . "` + INNER JOIN `" . self::AS_TABLE_MAPS . "` ON (" . self::AS_TABLE_MAPS . ".id = " . self::AS_TABLE_KARMA . ".id) + INNER JOIN `" . self::AS_TABLE_PLAYERS . "` ON (" . self::AS_TABLE_PLAYERS . ".Id = " . self::AS_TABLE_KARMA . ".PlayerId);"; + $result = $this->sourceMysqli->query($karmaQuery); + + if (!$result) { + return false; + } + + $karmaConvertQuery = "INSERT IGNORE INTO `" . self::MC_TABLE_KARMA . "` + ( `mapIndex`, `playerIndex`, `vote`) + VALUES + ( ?,?,?);"; + $statement = $this->mysqli->prepare($karmaConvertQuery); + if ($this->mysqli->error) { + trigger_error($this->mysqli->error); + return false; + } + + //Loop through all the players + while($row = $result->fetch_object()) { + $mapId = intval($mapvector[$row->Uid]); + $playerId = intval($playerVector[$row->Login]); + $vote = 1; + if ($row->Score == -1) { + $vote = 0; + } + $statement->bind_param('iii', $mapId, $playerId, $vote); + $statement->execute(); + if ($statement->error) { + trigger_error($statement->error); + return false; + } + } + $result->free_result(); + $statement->close(); + + return true; + } + + public function convertPlayersAndStatistics($serverIndex = -1) { + $success = $this->initPlayerTable(); + if (!$success) { + return false; + } + + $success = $this->initStatsTable(); + if (!$success) { + return false; + } + + if (!isset($this->sourceMysqli)) { + return false; + } + + $databaseQuery = "SELECT * FROM `" . self::AS_TABLE_PLAYERS . "`;"; + + $result = $this->sourceMysqli->query($databaseQuery); + + if (!$result) { + return false; + } + + + $playerConvertQuery = "INSERT INTO `" . self::MC_TABLE_PLAYERS . "` + ( `index`, `login`, `nickname`) + VALUES + ( ?,?,? ) + ON DUPLICATE KEY UPDATE + `index` = LAST_INSERT_ID(`index`);"; + $statement = $this->mysqli->prepare($playerConvertQuery); + if ($this->mysqli->error) { + trigger_error($this->mysqli->error); + return false; + } + + $statisticQuery = "INSERT IGNORE INTO `" . self::MC_TABLE_STATISTICS . "` + (`playerId`, `statId`, `value`, `serverIndex`) + VALUES + (?,?,?,?);"; + $statStatement = $this->mysqli->prepare($statisticQuery); + if ($this->mysqli->error) { + trigger_error($this->mysqli->error); + return false; + } + + //Loop through all the players + while($row = $result->fetch_object()) { + $statement->bind_param('iss', $row->Id, $row->Login, $row->NickName); + $statement->execute(); + if ($statement->error) { + trigger_error($statement->error); + return false; + } + + + if ($row->Joins > 0) { + $statId = 0; + $statStatement->bind_param('iiii', $row->Id, $statId, $row->Joins, $serverIndex); + $statStatement->execute(); + } + + if ($row->TimePlayed > 0) { + $statId = 2; + $statStatement->bind_param('iiii', $row->Id, $statId, $row->TimePlayed, $serverIndex); + $statStatement->execute(); + } + + if ($row->Survivals > 0) { + $statId = 4; + $statStatement->bind_param('iiii', $row->Id, $statId, $row->Survivals, $serverIndex); + $statStatement->execute(); + } + + if ($row->Wins > 0) { + $statId = 5; + $statStatement->bind_param('iiii', $row->Id, $statId, $row->Wins, $serverIndex); + $statStatement->execute(); + } + + if ($row->NearMisses > 0) { + $statId = 6; + $statStatement->bind_param('iiii', $row->Id, $statId, $row->NearMisses, $serverIndex); + $statStatement->execute(); + } + + if ($row->Captures > 0) { + $statId = 7; + $statStatement->bind_param('iiii', $row->Id, $statId, $row->Captures, $serverIndex); + $statStatement->execute(); + } + + if ($row->Hits > 0) { + $statId = 8; + $statStatement->bind_param('iiii', $row->Id, $statId, $row->Hits, $serverIndex); + $statStatement->execute(); + } + + if ($row->GotHits > 0) { + $statId = 9; + $statStatement->bind_param('iiii', $row->Id, $statId, $row->GotHits, $serverIndex); + $statStatement->execute(); + } + + if ($row->Deaths > 0) { + $statId = 10; + $statStatement->bind_param('iiii', $row->Id, $statId, $row->Deaths, $serverIndex); + $statStatement->execute(); + } + + if ($row->Respawns > 0) { + $statId = 11; + $statStatement->bind_param('iiii', $row->Id, $statId, $row->Respawns, $serverIndex); + $statStatement->execute(); + } + + if ($row->Shots > 0) { + $statId = 13; + $statStatement->bind_param('iiii', $row->Id, $statId, $row->Shots, $serverIndex); + $statStatement->execute(); + } + /* + (12, 'Kills', 0, ''), + */ + } + + $statement->close(); + $statStatement->close(); + + return $this->convertPlayersExtra($serverIndex); + } + + private function convertPlayersExtra($serverIndex) { //TODO dont rely on playerId from Aseco table + $databaseQuery = "SELECT * FROM `" . self::AS_TABLE_PLAYERS_EXTRA . "`;"; + + $result = $this->sourceMysqli->query($databaseQuery); + + if (!$result) { + return false; + } + + $statisticQuery = "INSERT IGNORE INTO `" . self::MC_TABLE_STATISTICS . "` + (`playerId`, `statId`, `value`, `serverIndex`) + VALUES + (?,?,?,?);"; + $statement = $this->mysqli->prepare($statisticQuery); + if ($this->mysqli->error) { + trigger_error($this->mysqli->error); + return false; + } + + //Loop through all the players and Insert the Donations Stat + while($row = $result->fetch_object()) { + if ($row->Donations == 0) { + continue; + } + + $statId = 3; + $statement->bind_param('iiii', $row->PlayerId, $statId, $row->Donations, $serverIndex); + $statement->execute(); + if ($statement->error) { + trigger_error($statement->error); + return false; + } + + } + $statement->close(); + return true; + } + + /** + * Connect to the defined database (create it if needed) + * + * @return bool + */ + private function initDatabase() { + $dbName = (string)$this->targetDatabase; + if (!$dbName) { + trigger_error("Invalid database configuration (database).", E_USER_ERROR); + return false; + } + + // Try to connect + $result = $this->mysqli->select_db($dbName); + if ($result) { + return true; + } + + // Create database + $databaseQuery = "CREATE DATABASE {$dbName};"; + $this->mysqli->query($databaseQuery); + if ($this->mysqli->error) { + trigger_error($this->mysqli->error, E_USER_ERROR); + return false; + } + + // Connect to new database + $this->mysqli->select_db($dbName); + if ($this->mysqli->error) { + trigger_error("Couldn't select database '{$dbName}'. " . $this->mysqli->error, E_USER_ERROR); + return false; + } + return true; + } + + /** + * Initialize necessary database tables + * + * @return bool + */ + private function initPlayerTable() { + $mysqli = $this->mysqli; + $playerTableQuery = "CREATE TABLE IF NOT EXISTS `" . self::MC_TABLE_PLAYERS . "` ( + `index` int(11) NOT NULL AUTO_INCREMENT, + `login` varchar(100) COLLATE utf8_unicode_ci NOT NULL, + `nickname` varchar(150) COLLATE utf8_unicode_ci NOT NULL, + `path` varchar(100) COLLATE utf8_unicode_ci NOT NULL, + `authLevel` int(11) NOT NULL DEFAULT '0', + `changed` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + PRIMARY KEY (`index`), + UNIQUE KEY `login` (`login`) + ) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='Player Data' AUTO_INCREMENT=1;"; + $playerTableStatement = $mysqli->prepare($playerTableQuery); + if ($mysqli->error) { + trigger_error($mysqli->error, E_USER_ERROR); + return false; + } + $playerTableStatement->execute(); + if ($playerTableStatement->error) { + trigger_error($playerTableStatement->error, E_USER_ERROR); + return false; + } + $playerTableStatement->close(); + return true; + } + + /** + * Initialize necessary database tables + * + * @return bool + */ + private function initMapsTable() { + $mysqli = $this->mysqli; + $query = "CREATE TABLE IF NOT EXISTS `" . self::MC_TABLE_MAPS . "` ( + `index` int(11) NOT NULL AUTO_INCREMENT, + `mxid` int(11), + `uid` varchar(50) COLLATE utf8_unicode_ci NOT NULL, + `name` varchar(150) COLLATE utf8_unicode_ci NOT NULL, + `authorLogin` varchar(100) COLLATE utf8_unicode_ci NOT NULL, + `fileName` varchar(100) COLLATE utf8_unicode_ci NOT NULL, + `environment` varchar(50) COLLATE utf8_unicode_ci NOT NULL, + `mapType` varchar(50) COLLATE utf8_unicode_ci NOT NULL, + `changed` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + PRIMARY KEY (`index`), + UNIQUE KEY `uid` (`uid`) + ) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='Map data' AUTO_INCREMENT=1;"; + $result = $mysqli->query($query); + if ($mysqli->error) { + trigger_error($mysqli->error, E_USER_ERROR); + return false; + } + return $result; + } + + /** + * Initialize statistic Tables + * + * @return bool + */ + private function initStatsTable() { + $mysqli = $this->mysqli; + $query = "CREATE TABLE IF NOT EXISTS `" . self::MC_TABLE_STATSMETADATA . "` ( + `index` int(11) NOT NULL AUTO_INCREMENT, + `name` varchar(100) COLLATE utf8_unicode_ci NOT NULL, + `type` int(5) NOT NULL, + `description` varchar(150) COLLATE utf8_unicode_ci, + PRIMARY KEY (`index`), + UNIQUE KEY `name` (`name`) + ) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='Statistics Meta Data' AUTO_INCREMENT=1;"; + $statement = $mysqli->prepare($query); + if ($mysqli->error) { + trigger_error($mysqli->error, E_USER_ERROR); + return false; + } + $statement->execute(); + if ($statement->error) { + trigger_error($statement->error, E_USER_ERROR); + return false; + } + $statement->close(); + + $query = "CREATE TABLE IF NOT EXISTS `" . self::MC_TABLE_STATISTICS . "` ( + `index` int(11) NOT NULL AUTO_INCREMENT, + `serverIndex` int(11) NOT NULL, + `playerId` int(11) NOT NULL, + `statId` int(11) NOT NULL, + `value` int(20) COLLATE utf8_unicode_ci NOT NULL DEFAULT '0', + PRIMARY KEY (`index`), + UNIQUE KEY `unique` (`statId`,`playerId`,`serverIndex`) + ) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='Statistics' AUTO_INCREMENT=1;"; + $statement = $mysqli->prepare($query); + if ($mysqli->error) { + trigger_error($mysqli->error, E_USER_ERROR); + return false; + } + $statement->execute(); + if ($statement->error) { + trigger_error($statement->error, E_USER_ERROR); + return false; + } + $statement->close(); + + $query = "INSERT IGNORE INTO `" . self::MC_TABLE_STATSMETADATA . "` (`index`, `name`, `type`, `description`) VALUES + (1, 'Joins', 0, ''), + (2, 'Servertime', 1, ''), + (3, 'Donated Planets', 0, ''), + (4, 'Survivals', 0, ''), + (5, 'Wins', 0, ''), + (6, 'Near Misses', 0, ''), + (7, 'Captures', 0, ''), + (8, 'Hits', 0, ''), + (9, 'Got Hits', 0, ''), + (10, 'Deaths', 0, ''), + (11, 'Respawns', 0, ''), + (12, 'Kills', 0, ''), + (13, 'Shots', 0, '');"; + + $statement = $mysqli->prepare($query); + if ($mysqli->error) { + trigger_error($mysqli->error, E_USER_ERROR); + return false; + } + $statement->execute(); + if ($statement->error) { + trigger_error($statement->error, E_USER_ERROR); + return false; + } + $statement->close(); + return true; + } + + + /** + * Create necessary database tables + */ + private function initKarmaTable() { + $mysqli = $this->mysqli; + $query = "CREATE TABLE IF NOT EXISTS `" . self::MC_TABLE_KARMA . "` ( + `index` int(11) NOT NULL AUTO_INCREMENT, + `mapIndex` int(11) NOT NULL, + `playerIndex` int(11) NOT NULL, + `vote` float NOT NULL DEFAULT '-1', + `changed` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + PRIMARY KEY (`index`), + UNIQUE KEY `player_map_vote` (`mapIndex`, `playerIndex`) + ) ENGINE=MyISAM DEFAULT CHARSET=utf8 COMMENT='Save players map votes' AUTO_INCREMENT=1;"; + $result = $mysqli->query($query); + if ($mysqli->error) { + trigger_error($mysqli->error, E_USER_ERROR); + return false; + } + return $result; + } +} \ No newline at end of file