equal
deleted
inserted
replaced
95 $progressBar = $this->output->createProgressBar($recs->getTotalRecordsInCollection()); |
95 $progressBar = $this->output->createProgressBar($recs->getTotalRecordsInCollection()); |
96 $progressBar->setFormat(' %current%/%max% [%bar%] %percent:3s%% - %message%'); |
96 $progressBar->setFormat(' %current%/%max% [%bar%] %percent:3s%% - %message%'); |
97 |
97 |
98 $insertTimeouts = 0; |
98 $insertTimeouts = 0; |
99 |
99 |
100 $documentCounts = ['all' => 0, 'unknown' => 0, 'error' => 0]; |
100 $documentCounts = ['all' => 0, 'unknown' => 0, 'error' => 0, 'raw_duplicates' => 0]; |
101 |
101 |
102 foreach ($recs as $item) { |
102 foreach ($recs as $item) { |
103 $item->registerXPathNamespace('oai', "http://www.openarchives.org/OAI/2.0/"); |
103 $item->registerXPathNamespace('oai', "http://www.openarchives.org/OAI/2.0/"); |
104 $identifier = (string) $item->xpath('oai:header/oai:identifier')[0]; |
104 $identifier = (string) $item->xpath('oai:header/oai:identifier')[0]; |
105 |
105 |
152 //insert raw |
152 //insert raw |
153 if($raw) { |
153 if($raw) { |
154 $resDocsRaw = $gs_raw->query("ASK WHERE { GRAPH <$docUri> { ?s ?p ?o }}"); |
154 $resDocsRaw = $gs_raw->query("ASK WHERE { GRAPH <$docUri> { ?s ?p ?o }}"); |
155 if($resDocsRaw->getBoolean()) { |
155 if($resDocsRaw->getBoolean()) { |
156 $gs_raw->clear($docUri); |
156 $gs_raw->clear($docUri); |
|
157 |
157 } |
158 } |
158 $gs_raw->insert($doc, $docUri); |
159 $gs_raw->insert($doc, $docUri); |
159 } |
160 } |
160 |
161 |
161 //map doc |
162 //map doc |