xNightR00T File Manager

<?php

require_once dirname(__FILE__) . "/zs_component_upgrader.php";

class StatsdDBHandler extends ZSComponentUpgrader {

	protected function getSqliteDbName($version = "2018.0.0") {
		return "datacache_statistics.db";
	}

	protected function getMysqlSqlFilenames() {
		return array("statsd_mysql_create_database.sql");
	}

	protected function getSqliteSqlFilenames() {
		return array("statsd_sqlite_create_database.sql");
	}

	public function getComponent() { return "statsd"; }

	public function getSchemaVersion() { return "2018.0.0"; }

	public function getMysqlSchemaVersion() {
		$dbh = $this->getMySqlDbh();
		$res = $dbh->query("SELECT property_value FROM schema_properties WHERE property = 'STATSD_SCHEMA_VERSION'")->fetchAll();
		foreach ($res as $row) {
			return $row['property_value'];
		}

		return false;
	}

	public function getSqliteSchemaVersion() {
		$dbh = $this->getSqliteDbh();
		foreach ($dbh->query("SELECT value FROM statsd_properties where name='version'") as $row) {
			$dbCurrentVersion = $row['value'];
		}
		message("Found sqlite current version $dbCurrentVersion");
		return $this->getParsedVersionString($dbCurrentVersion);
	}

	public function setSqliteSchemaVersion($dbh, $version) {
		$stmt = $dbh->prepare("REPLACE INTO statsd_properties (name, value) VALUES ('version', :version)");
		$stmt->bindValue(":version", $version);
		$stmt->execute();
		message("Setting sqlite current version $version");
	}

	public function setMysqlSchemaVersion($dbh, $version) {
		$dbh->exec("REPLACE INTO schema_properties (property, property_value) VALUES('STATSD_SCHEMA_VERSION', '{$version}')");
	}

	protected function upgradeSqlite() {
		$this->createCleanSqliteDatabase();
	}

	protected function upgradeMysql() {
	   $this->createCleanMysqlDatabase();
	}

	public function upgrade() {
		// We need to copy the data from previous version
		if($this->copySqliteFromPreviousVersions()) {
			$this->upgradeSqlite();
		} else {
			$this->createCleanSqliteDatabase();
		}
		// Set the schema version
		$this->setSqliteSchemaVersion($this->getSqliteDbh(), $this->getSchemaVersion());
		if ($this->isClusterUpgrade()) {
			$this->upgradeMysql();
		}
	}
}

?>