Merge pull request #283 from piolet/insert-update-geoindexer

override insert and delete functions
teamtnt · May 2, 2023 · 3727048 · 3727048
2 parents 201d679 + 6c43188
commit 3727048
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/src/Indexer/TNTGeoIndexer.php b/src/Indexer/TNTGeoIndexer.php
@@ -69,4 +69,16 @@ public function prepareInsertStatement()
         $this->insertStmt = $this->index->prepare("INSERT INTO locations (doc_id, longitude, latitude, cos_lat, sin_lat, cos_lng, sin_lng)
             VALUES (:doc_id, :longitude, :latitude, :cos_lat, :sin_lat, :cos_lng, :sin_lng)");
     }
+
+    public function insert($document)
+    {
+        $this->processDocument(new Collection($document));
+    }
+
+    public function delete($documentId)
+    {
+        $this->prepareAndExecuteStatement("DELETE FROM locations WHERE doc_id = :documentId;", [
+            ['key' => ':documentId', 'value' => $documentId]
+        ]);
+    }
 }