Port to sette library
[disclosr.git] / import.php
blob:a/import.php -> blob:b/import.php
--- a/import.php
+++ b/import.php
@@ -1,22 +1,34 @@
 <?php
+
 require_once 'common.inc.php';
+try {
+    $server->create_db('disclosr-agencies');
+} catch (SetteeRestClientException $e) {
+    setteErrorHandler($e);
+}
 $db = $server->get_db('disclosr-agencies');
-//createAgencyDesignDoc();
- $conn = new PDO("pgsql:dbname=contractDashboard;user=postgres;password=snmc;host=localhost");
- $namesQ = 'select agency.abn, string_agg("agencyName",\',\') as names from agency inner join agency_nametoabn on agency.abn::text = agency_nametoabn.abn group by agency.abn;';
- $abntonames = Array(); 
- foreach ($conn->query($namesQ) as $row) {
-      $abntonames[$row['abn']] = explode(",",$row['names']);
-  }
-  $result = $conn->query("select * from agency");
-  while ($agency = $result->fetch(PDO::FETCH_ASSOC)) {
-		
-		$agency['otherNames'] = $abntonames[$agency['abn']];
-                if (sizeof($abntonames[$agency['abn']]) == 1) $agency['name'] = $abntonames[$agency['abn']][0];
-		$agency["lastScraped"] = "1/1/1970";
-		$agency["scrapeDepth"] = 1;
-                $doc = $db->save($agency);
-print_r($doc);
-  }
+createAgencyDesignDoc();
+$conn = new PDO("pgsql:dbname=contractDashboard;user=postgres;password=snmc;host=localhost");
+$namesQ = 'select agency.abn, string_agg("agencyName",\',\') as names from agency inner join agency_nametoabn on agency.abn::text = agency_nametoabn.abn group by agency.abn;';
+$abntonames = Array();
+foreach ($conn->query($namesQ) as $row) {
+    $abntonames[$row['abn']] = explode(",", $row['names']);
+}
+$result = $conn->query("select * from agency");
+while ($agency = $result->fetch(PDO::FETCH_ASSOC)) {
+    $agency['_id'] = md5($agency['abn']);
+    $agency['otherNames'] = $abntonames[$agency['abn']];
+    if (sizeof($abntonames[$agency['abn']]) == 1)
+        $agency['name'] = $abntonames[$agency['abn']][0];
+    $agency["lastScraped"] = "1/1/1970";
+    $agency["scrapeDepth"] = 1;
+    try {
+        $doc = $db->save($agency);
+        //print_r($doc);
+        echo $agency['abn'] . " imported \n<br>";
+    } catch (SetteeRestClientException $e) {
+        setteErrorHandler($e);
+    }
+}
 ?>