echo "Import\n";
$bDidSomething = true;
- if (!file_exists(CONST_BasePath.'/osm2pgsql/osm2pgsql')) fail("please download and build osm2pgsql");
- passthru(CONST_BasePath.'/osm2pgsql/osm2pgsql -lsc -O gazetteer -C 10000 --hstore -d nominatim '.$aCMDResult['osm-file']);
+ $osm2pgsql = CONST_BasePath.'/osm2pgsql/osm2pgsql';
+ if (!file_exists($osm2pgsql)) $osm2pgsql = trim(`which osm2pgsql`);
+ if (!file_exists($osm2pgsql)) fail("please download and build osm2pgsql");
+ passthru($osm2pgsql.' -lsc -O gazetteer -C 10000 --hstore -d nominatim '.$aCMDResult['osm-file']);
$oDB =& getDB();
$x = $oDB->getRow('select * from place limit 1');
if ($aCMDResult['calculate-postcodes'] || $aCMDResult['all'])
{
+ $bDidSomething = true;
$oDB =& getDB();
if (!pg_query($oDB->connection, 'DELETE from placex where osm_type=\'P\'')) fail(pg_last_error($oDB->connection));
$sSQL = "insert into placex (osm_type,osm_id,class,type,postcode,country_code,geometry) ";
$sCMD = 'psql -p '.$aDSNInfo['port'].' '.$aDSNInfo['database'];
$aDescriptors = array(
0 => array('pipe', 'r'),
- 1 => array('pipe', 'w'),
- 2 => array('file', '/dev/null', 'a')
+ 1 => STDOUT,
+ 2 => STDERR
);
$ahPipes = null;
$hProcess = proc_open($sCMD, $aDescriptors, $ahPipes);
if (!is_resource($hProcess)) fail('unable to start pgsql');
- fwrite($ahPipes[0], $sScript);
- fclose($ahPipes[0]);
-
- // TODO: error checking
- while(!feof($ahPipes[1]))
+ while(strlen($sScript))
{
- echo fread($ahPipes[1], 4096);
+ $written = fwrite($ahPipes[0], $sScript);
+ $sScript = substr($sScript, $written);
}
- fclose($ahPipes[1]);
-
+ fclose($ahPipes[0]);
proc_close($hProcess);
}