modelfactory.php

<?php
require_once ('model-sqlite-opt.php');
require_once ('model-sqlite.php');
require_once ('model-mysql.php');
require_once ('model-changesets-sqlite.php');
require_once ("model-bbox.php");
require_once ("model-postgis.php");
require_once ("config.php");
require_once ("system.php");

$dbGlobal = Null;
$changesetGlobal = Null;

//The backend database is implemented using a strategy software pattern. This makes
//them nice and modular. The specific strategy to use is determined in this factory.

function OsmDatabase()
{
	if(BACKEND_DATABASE == "mysql")
		$db = new OsmDatabaseMysql();
	if(BACKEND_DATABASE == "sqlite")
		$db = new OsmDatabaseSqliteOpt();
	if(BACKEND_DATABASE == "sqlite-simple")
		$db = new OsmDatabaseSqlite();
	if(BACKEND_DATABASE == "postgis")
		$db = new OsmDatabasePostgis();

	$checkPermissions = $db->CheckPermissions();
	if($checkPermissions != 1)
	{
		header('HTTP/1.1 500 Internal Server Error');
		echo $checkPermissions.' is not writable';
		exit();
	}

	return $db;
}

function ChangesetDatabase()
{
	return new ChangesetDatabaseSqlite();
}

class OsmDatabaseMultiplexer extends OsmDatabaseCommon
{

	function __construct()
	{
		if(BACKEND_DATABASE == "mysql")
			$this->masterDb = new OsmDatabaseMysql();
		if(BACKEND_DATABASE == "sqlite")
			$this->masterDb = new OsmDatabaseSqliteOpt();
		
		//$this->events = fopen("events.txt","wt");
	}

	function __destruct()
	{
		unset($this->masterDb);
		//fclose($this->events);
	}

	function GetElementById($type,$id,$version=null)
	{
		return $this->masterDb->GetElementById($type, $id, $version);
	}

	public function CreateElement($type,$id,$el)
	{
		CallFuncByMessage(Message::ELEMENT_UPDATE_PRE_APPLY,array($type,$id,$el));

		//fwrite($this->events, "Create ".$type." ".$id."\n");
		$ret = $this->masterDb->CreateElement($type,$id,$el);
		
		CallFuncByMessage(Message::ELEMENT_UPDATE_DONE,array($type,$id,$el));
		return $ret;
	}

	public function ModifyElement($type,$id,$el)
	{
		CallFuncByMessage(Message::ELEMENT_UPDATE_PRE_APPLY,array($type,$id,$el));

		//fwrite($this->events, "Modify ".$type." ".$id."\n");
		$ret = $this->masterDb->ModifyElement($type,$id,$el);

		CallFuncByMessage(Message::ELEMENT_UPDATE_DONE,array($type,$id,$el));
		return $ret;
	}

	public function DeleteElement($type,$id,$el)
	{
		CallFuncByMessage(Message::ELEMENT_UPDATE_PRE_APPLY,array($type,$id,$el));

		//fwrite($this->events, "Delete ".$type." ".$id."\n");
		$ret = $this->masterDb->DeleteElement($type,$id,$el);

		CallFuncByMessage(Message::ELEMENT_UPDATE_DONE,array($type,$id,$el));
		return $ret;
	}

	public function Purge()
	{
		//fwrite($this->events, "Purge\n");
		return $this->masterDb->Purge();
	}

	function Dump($callback)
	{
		return $this->masterDb->Dump($callback);
	}

	function CheckPermissions()
	{
		return $this->masterDb->CheckPermissions();
	}

	function GetNodesInBbox($bbox)
	{
		return $this->masterDb->GetNodesInBbox($bbox);
	}

	function GetParentWaysOfNodes(&$nodes)
	{
		return $this->masterDb->GetParentWaysOfNodes($nodes);
	}

	function GetParentRelations(&$els)
	{
		return $this->masterDb->GetParentRelations($els);
	}

}



function MapDatabaseEventHandler($eventType, $content, $listenVars)
{
	global $dbGlobal;
	if($dbGlobal === Null)
		$dbGlobal = OsmDatabase();

	if($eventType === Message::MAP_QUERY)
		return $dbGlobal->MapQuery($content);

	if($eventType === Message::GET_OBJECT_BY_ID)
	{
		//if(count($content)<3) {var_dump(debug_backtrace()); die();}
		return $dbGlobal->GetElementById($content[0],$content[1],$content[2]);
	}

	if($eventType === Message::GET_FULL_HISTORY)
		return $dbGlobal->GetElementFullHistory($content[0], $content[1]);

	if($eventType === Message::GET_RELATIONS_FOR_ELEMENT)
		return $dbGlobal->GetCitingRelations($content[0], $content[1]);

	if($eventType === Message::GET_WAY_IDS_FOR_NODE)
		return $dbGlobal->GetCitingWaysOfNode($content);

	if($eventType === Message::CHECK_ELEMENT_EXISTS)
		return $dbGlobal->CheckElementExists($content[0], $content[1]);

	if($eventType === Message::GET_CURRENT_ELEMENT_VER)
		return $dbGlobal->GetCurentVerOfElement($content[0], $content[1]);

	if($eventType === Message::GET_ELEMENT_BBOX)
		return $dbGlobal->GetBboxOfElement($content[0], $content[1]);

	if($eventType === Message::CREATE_ELEMENT)
		return $dbGlobal->CreateElement($content[0], $content[1], $content[2]);

	if($eventType === Message::MODIFY_ELEMENT)
		return $dbGlobal->ModifyElement($content[0], $content[1], $content[2]);

	if($eventType === Message::DELETE_ELEMENT)
		return $dbGlobal->DeleteElement($content[0], $content[1], $content[2]);

	if($eventType === Message::DUMP)
		return $dbGlobal->Dump($content);

	if($eventType === Message::PURGE_MAP)
		return $dbGlobal->Purge();

	if($eventType === Message::GET_ELEMENT_FULL_DATA)
		return $dbGlobal->GetFullDetailsOfElement($content);

	if($eventType === Message::GET_ELEMENT_FULL_PARENT_DATA)
		return $dbGlobal->GetFullParentsOfElement($content);

	if($eventType === Message::SCRIPT_END)
	{
		unset($dbGlobal);
		$dbGlobal = Null;
	}
}

function ChangesetDatabaseEventHandler($eventType, $content, $listenVars)
{

	global $changesetGlobal;
	if($changesetGlobal === Null)
		$changesetGlobal = ChangesetDatabase();

	if($eventType === Message::CHANGESET_IS_OPEN)
		return $changesetGlobal->IsOpen($content);

	if($eventType === Message::OPEN_CHANGESET)
		return $changesetGlobal->Open($content[0], $content[1], $content[2], $content[3], $content[4]);

	if($eventType === Message::UPDATE_CHANGESET)
		return $changesetGlobal->Update($content[0], $content[1], $content[2], $content[3]);

	if($eventType === Message::CLOSE_CHANGESET)
		return $changesetGlobal->Close($content);

	if($eventType === Message::GET_CHANGESET_UID)
		return $changesetGlobal->GetUid($content);

	if($eventType === Message::GET_CHANGESET_METADATA)
		return $changesetGlobal->GetMetadata($content);

	if($eventType === Message::GET_CHANGESET_SIZE)
		return $changesetGlobal->GetSize($content);

	if($eventType === Message::EXPAND_BBOX)
		return $changesetGlobal->ExpandBbox($content[0], $content[1]);

	if($eventType === Message::CHANGESET_APPEND_ELEMENT)
		return $changesetGlobal->AppendElement($content[0], $content[1], $content[2]);

	if($eventType === Message::CHANGESET_QUERY)
		return $changesetGlobal->Query($content[0], $content[1], $content[2]);

	if($eventType === Message::GET_CHANGESET_CONTENT)
		return $changesetGlobal->GetContentObject($content);

	if($eventType === Message::GET_CHANGESET_CLOSE_TIME)
		return $changesetGlobal->GetClosedTime($content);

	if($eventType === Message::SCRIPT_END)
	{
		unset($changesetGlobal);
		$changesetGlobal = Null;
	}

}

?>