X-Git-Url: https://git.openstreetmap.org./nominatim.git/blobdiff_plain/fd3fcea539878b8f96cb9bcad51152459442ab48..0ab9c90708d574847852d33b75e9da34da9f9d3a:/utils/setup.php

diff --git a/utils/setup.php b/utils/setup.php
index db15aa44..81ed3512 100755
--- a/utils/setup.php
+++ b/utils/setup.php
@@ -23,6 +23,7 @@
 		array('create-minimal-tables', '', 0, 1, 0, 0, 'bool', 'Create minimal main tables'),
 		array('create-tables', '', 0, 1, 0, 0, 'bool', 'Create main tables'),
 		array('create-partitions', '', 0, 1, 0, 0, 'bool', 'Create required partition tables and triggers'),
+		array('import-wikipedia-articles', '', 0, 1, 0, 0, 'bool', 'Import wikipedia article dump'),
 		array('load-data', '', 0, 1, 0, 0, 'bool', 'Copy data to live tables from import table'),
 		array('import-tiger-data', '', 0, 1, 0, 0, 'bool', 'Import tiger data (not included in \'all\')'),
 		array('calculate-postcodes', '', 0, 1, 0, 0, 'bool', 'Calculate postcode centroids'),
@@ -210,6 +211,34 @@
 		pgsqlRunScript($sTemplate);
 	}
 
+	if ($aCMDResult['import-wikipedia-articles'] || $aCMDResult['all'])
+	{
+		$bDidSomething = true;
+		$sWikiArticlesFile = CONST_BasePath.'/data/wikipedia_article.sql.bin';
+		$sWikiRedirectsFile = CONST_BasePath.'/data/wikipedia_redirect.sql.bin';
+		if (file_exists($sWikiArticlesFile))
+		{
+			echo "Importing wikipedia articles...";
+			pgsqlRunDropAndRestore($sWikiArticlesFile);
+			echo "...done\n";
+		}
+		else
+		{
+			echo "WARNING: wikipedia article dump file not found - places will have default importance\n";
+		}
+		if (file_exists($sWikiRedirectsFile))
+		{
+			echo "Importing wikipedia redirects...";
+			pgsqlRunDropAndRestore($sWikiRedirectsFile);
+			echo "...done\n";
+		}
+		else
+		{
+			echo "WARNING: wikipedia redirect dump file not found - some place importance values may be missing\n";
+		}
+	}
+
+
 	if ($aCMDResult['load-data'] || $aCMDResult['all'])
 	{
 		echo "Load Data\n";
@@ -329,7 +358,7 @@
 			}
 
 			fclose($hFile);
-	
+
 			$bAnyBusy = true;
 			while($bAnyBusy)
 			{
@@ -454,7 +483,8 @@
 
 		// Convert database DSN to psql paramaters
 		$aDSNInfo = DB::parseDSN(CONST_Database_DSN);
-		$sCMD = 'psql -f '.$sFilename.' '.$aDSNInfo['database'];
+		if (!isset($aDSNInfo['port']) || !$aDSNInfo['port']) $aDSNInfo['port'] = 5432;
+		$sCMD = 'psql -p '.$aDSNInfo['port'].' -d '.$aDSNInfo['database'].' -f '.$sFilename;
 
 		$aDescriptors = array(
 			0 => array('pipe', 'r'),
@@ -482,7 +512,7 @@
 		// Convert database DSN to psql paramaters
 		$aDSNInfo = DB::parseDSN(CONST_Database_DSN);
 		if (!isset($aDSNInfo['port']) || !$aDSNInfo['port']) $aDSNInfo['port'] = 5432;
-		$sCMD = 'psql -p '.$aDSNInfo['port'].' '.$aDSNInfo['database'];
+		$sCMD = 'psql -p '.$aDSNInfo['port'].' -d '.$aDSNInfo['database'];
 		$aDescriptors = array(
 			0 => array('pipe', 'r'),
 			1 => STDOUT, 
@@ -500,3 +530,59 @@
 		fclose($ahPipes[0]);
 		proc_close($hProcess);
 	}
+
+	function pgsqlRunRestoreData($sDumpFile)
+	{
+		// Convert database DSN to psql paramaters
+		$aDSNInfo = DB::parseDSN(CONST_Database_DSN);
+		if (!isset($aDSNInfo['port']) || !$aDSNInfo['port']) $aDSNInfo['port'] = 5432;
+		$sCMD = 'pg_restore -p '.$aDSNInfo['port'].' -d '.$aDSNInfo['database'].' -Fc -a '.$sDumpFile;
+
+		$aDescriptors = array(
+			0 => array('pipe', 'r'),
+			1 => array('pipe', 'w'),
+			2 => array('file', '/dev/null', 'a')
+		);
+		$ahPipes = null;
+		$hProcess = proc_open($sCMD, $aDescriptors, $ahPipes);
+		if (!is_resource($hProcess)) fail('unable to start pg_restore');
+
+		fclose($ahPipes[0]);
+
+		// TODO: error checking
+		while(!feof($ahPipes[1]))
+		{
+			echo fread($ahPipes[1], 4096);
+		}
+		fclose($ahPipes[1]);
+
+		proc_close($hProcess);
+	}
+
+	function pgsqlRunDropAndRestore($sDumpFile)
+	{
+		// Convert database DSN to psql paramaters
+		$aDSNInfo = DB::parseDSN(CONST_Database_DSN);
+		if (!isset($aDSNInfo['port']) || !$aDSNInfo['port']) $aDSNInfo['port'] = 5432;
+		$sCMD = 'pg_restore -p '.$aDSNInfo['port'].' -d '.$aDSNInfo['database'].' -Fc --clean '.$sDumpFile;
+
+		$aDescriptors = array(
+			0 => array('pipe', 'r'),
+			1 => array('pipe', 'w'),
+			2 => array('file', '/dev/null', 'a')
+		);
+		$ahPipes = null;
+		$hProcess = proc_open($sCMD, $aDescriptors, $ahPipes);
+		if (!is_resource($hProcess)) fail('unable to start pg_restore');
+
+		fclose($ahPipes[0]);
+
+		// TODO: error checking
+		while(!feof($ahPipes[1]))
+		{
+			echo fread($ahPipes[1], 4096);
+		}
+		fclose($ahPipes[1]);
+
+		proc_close($hProcess);
+	}