Feat mongo inversion

src/Database/Adapter.php

@@ -1271,12 +1271,45 @@ abstract public function getInternalIndexesKeys(): array;
      */
     abstract public function getSchemaAttributes(string $collection): array;
 
+    /**
+     * Get the query to check for tenant when in shared tables mode
+     *
+     * @param string $collection   The collection being queried
+     * @param string $alias  The alias of the parent collection if in a subquery
+     * @return string
+     */
+    abstract public function getTenantQuery(string $collection, string $alias = ''): string;
+
     /**
      * @param mixed $stmt
      * @return bool
      */
     abstract protected function execute(mixed $stmt): bool;
 
+    /**
+     * Decode a WKB or textual POINT into [x, y]
+     *
+     * @param string $wkb
+     * @return float[] Array with two elements: [x, y]
+     */
+    abstract public function decodePoint(string $wkb): array;
+
+    /**
+     * Decode a WKB or textual LINESTRING into [[x1, y1], [x2, y2], ...]
+     *
+     * @param string $wkb
+     * @return float[][] Array of points, each as [x, y]
+     */
+    abstract public function decodeLinestring(string $wkb): array;
+
+    /**
+     * Decode a WKB or textual POLYGON into [[[x1, y1], [x2, y2], ...], ...]
+     *
+     * @param string $wkb
+     * @return float[][][] Array of rings, each ring is an array of points [x, y]
+     */
+    abstract public function decodePolygon(string $wkb): array;
+
     /**
         * Returns the document after casting
         * @param Document $collection

src/Database/Adapter/MariaDB.php

@@ -155,7 +155,7 @@ public function createCollection(string $name, array $attributes = [], array $in
 
         $collection = "
 			CREATE TABLE {$this->getSQLTable($id)} (
-				_id INT(11) UNSIGNED NOT NULL AUTO_INCREMENT,
+				_id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
 				_uid VARCHAR(255) NOT NULL,
 				_createdAt DATETIME(3) DEFAULT NULL,
 				_updatedAt DATETIME(3) DEFAULT NULL,
@@ -186,7 +186,7 @@ public function createCollection(string $name, array $attributes = [], array $in
 
         $permissions = "
             CREATE TABLE {$this->getSQLTable($id . '_perms')} (
-                _id int(11) UNSIGNED NOT NULL AUTO_INCREMENT,
+                _id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
                 _type VARCHAR(12) NOT NULL,
                 _permission VARCHAR(255) NOT NULL,
                 _document VARCHAR(255) NOT NULL,

src/Database/Adapter/Mongo.php

@@ -31,16 +31,24 @@ class Mongo extends Adapter
         '$gt',
         '$gte',
         '$in',
+        '$nin',
         '$text',
         '$search',
         '$or',
         '$and',
         '$match',
         '$regex',
+        '$not',
+        '$nor',
     ];
 
     protected Client $client;
 
+    /**
+     * Default batch size for cursor operations
+     */
+    private const DEFAULT_BATCH_SIZE = 1000;
+
     //protected ?int $timeout = null;
 
     /**
@@ -1277,15 +1285,43 @@ public function getSequences(string $collection, array $documents): array
             $filters['_tenant'] = $this->getTenantFilters($collection, $documentTenants);
         }
         try {
-            $results = $this->client->find($name, $filters, ['projection' => ['_uid' => 1, '_id' => 1]]);
+            // Use cursor paging for large result sets
+            $options = [
+                'projection' => ['_uid' => 1, '_id' => 1],
+                'batchSize' => self::DEFAULT_BATCH_SIZE
+            ];
+
+            $response = $this->client->find($name, $filters, $options);
+            $results = $response->cursor->firstBatch ?? [];
+
+            // Process first batch
+            foreach ($results as $result) {
+                $sequences[$result->_uid] = (string)$result->_id;
+            }
+
+            // Get cursor ID for subsequent batches
+            $cursorId = $response->cursor->id ?? null;
+
+            // Continue fetching with getMore
+            while ($cursorId && $cursorId !== 0) {
+                $moreResponse = $this->client->getMore((int)$cursorId, $name, self::DEFAULT_BATCH_SIZE);
+                $moreResults = $moreResponse->cursor->nextBatch ?? [];
+
+                if (empty($moreResults)) {
+                    break;
+                }
+
+                foreach ($moreResults as $result) {
+                    $sequences[$result->_uid] = (string)$result->_id;
+                }
+
+                // Update cursor ID for next iteration
+                $cursorId = (int)($moreResponse->cursor->id ?? 0);
+            }
         } catch (MongoException $e) {
             throw $this->processException($e);
         }
 
-        foreach ($results->cursor->firstBatch as $result) {
-            $sequences[$result->_uid] = (string)$result->_id;
-        }
-
         foreach ($documents as $document) {
             if (isset($sequences[$document->getId()])) {
                 $document['$sequence'] = $sequences[$document->getId()];
@@ -1575,12 +1611,10 @@ public function find(Document $collection, array $queries = [], ?int $limit = 25
 
         try {
             // Use proper cursor iteration with reasonable batch size
-            $batchSize = 1000;
-            $options['batchSize'] = $batchSize;
+            $options['batchSize'] = self::DEFAULT_BATCH_SIZE;
 
             $response = $this->client->find($name, $filters, $options);
             $results = $response->cursor->firstBatch ?? [];
-
             // Process first batch
             foreach ($results as $result) {
                 $record = $this->replaceChars('_', '$', (array)$result);
@@ -1597,7 +1631,7 @@ public function find(Document $collection, array $queries = [], ?int $limit = 25
                     break;
                 }
 
-                $moreResponse = $this->client->getMore($cursorId, $name, $batchSize);
+                $moreResponse = $this->client->getMore((int)$cursorId, $name, self::DEFAULT_BATCH_SIZE);
                 $moreResults = $moreResponse->cursor->nextBatch ?? [];
 
                 if (empty($moreResults)) {
@@ -1614,7 +1648,7 @@ public function find(Document $collection, array $queries = [], ?int $limit = 25
                     }
                 }
 
-                $cursorId = $moreResponse->cursor->id ?? 0;
+                $cursorId = (int)($moreResponse->cursor->id ?? 0);
             }
 
         } catch (MongoException $e) {
@@ -1985,11 +2019,38 @@ protected function buildFilter(Query $query): array
             } else {
                 $filter[$attribute]['$in'] = $query->getValues();
             }
+        } elseif ($operator === 'notContains') {
+            if (!$query->onArray()) {
+                $filter[$attribute] = ['$not' => new Regex(".*{$this->escapeWildcards($value)}.*", 'i')];
+            } else {
+                $filter[$attribute]['$nin'] = $query->getValues();
+            }
         } elseif ($operator == '$search') {
-            $filter['$text'][$operator] = $value;
+            if ($query->getMethod() === Query::TYPE_NOT_SEARCH) {
+                // MongoDB doesn't support negating $text expressions directly
+                // Use regex as fallback for NOT search while keeping fulltext for positive search
+                if (empty($value)) {
+                    // If value is not passed, don't add any filter - this will match all documents
+                } else {
+                    // Escape special regex characters and create a pattern that matches the search term as substring
+                    $escapedValue = preg_quote($value, '/');
+                    $filter[$attribute] = ['$not' => new Regex(".*{$escapedValue}.*", 'i')];
+                }
+            } else {
+                $filter['$text'][$operator] = $value;
+            }
         } elseif ($operator === Query::TYPE_BETWEEN) {
             $filter[$attribute]['$lte'] = $value[1];
             $filter[$attribute]['$gte'] = $value[0];
+        } elseif ($operator === Query::TYPE_NOT_BETWEEN) {
+            $filter['$or'] = [
+                [$attribute => ['$lt' => $value[0]]],
+                [$attribute => ['$gt' => $value[1]]]
+            ];
+        } elseif ($operator === '$regex' && $query->getMethod() === Query::TYPE_NOT_STARTS_WITH) {
+            $filter[$attribute] = ['$not' => new Regex('^' . $value, 'i')];
+        } elseif ($operator === '$regex' && $query->getMethod() === Query::TYPE_NOT_ENDS_WITH) {
+            $filter[$attribute] = ['$not' => new Regex($value . '$', 'i')];
         } else {
             $filter[$attribute][$operator] = $value;
         }
@@ -2017,13 +2078,18 @@ protected function getQueryOperator(string $operator): string
             Query::TYPE_GREATER => '$gt',
             Query::TYPE_GREATER_EQUAL => '$gte',
             Query::TYPE_CONTAINS => '$in',
+            Query::TYPE_NOT_CONTAINS => 'notContains',
             Query::TYPE_SEARCH => '$search',
+            Query::TYPE_NOT_SEARCH => '$search',
             Query::TYPE_BETWEEN => 'between',
+            Query::TYPE_NOT_BETWEEN => 'notBetween',
             Query::TYPE_STARTS_WITH,
-            Query::TYPE_ENDS_WITH => '$regex',
+            Query::TYPE_NOT_STARTS_WITH,
+            Query::TYPE_ENDS_WITH,
+            Query::TYPE_NOT_ENDS_WITH => '$regex',
             Query::TYPE_OR => '$or',
             Query::TYPE_AND => '$and',
-            default => throw new DatabaseException('Unknown operator:' . $operator . '. Must be one of ' . Query::TYPE_EQUAL . ', ' . Query::TYPE_NOT_EQUAL . ', ' . Query::TYPE_LESSER . ', ' . Query::TYPE_LESSER_EQUAL . ', ' . Query::TYPE_GREATER . ', ' . Query::TYPE_GREATER_EQUAL . ', ' . Query::TYPE_IS_NULL . ', ' . Query::TYPE_IS_NOT_NULL . ', ' . Query::TYPE_BETWEEN . ', ' . Query::TYPE_CONTAINS . ', ' . Query::TYPE_SEARCH . ', ' . Query::TYPE_SELECT),
+            default => throw new DatabaseException('Unknown operator:' . $operator . '. Must be one of ' . Query::TYPE_EQUAL . ', ' . Query::TYPE_NOT_EQUAL . ', ' . Query::TYPE_LESSER . ', ' . Query::TYPE_LESSER_EQUAL . ', ' . Query::TYPE_GREATER . ', ' . Query::TYPE_GREATER_EQUAL . ', ' . Query::TYPE_IS_NULL . ', ' . Query::TYPE_IS_NOT_NULL . ', ' . Query::TYPE_BETWEEN . ', ' . Query::TYPE_NOT_BETWEEN . ', ' . Query::TYPE_STARTS_WITH . ', ' . Query::TYPE_NOT_STARTS_WITH . ', ' . Query::TYPE_ENDS_WITH . ', ' . Query::TYPE_NOT_ENDS_WITH . ', ' . Query::TYPE_CONTAINS . ', ' . Query::TYPE_NOT_CONTAINS . ', ' . Query::TYPE_SEARCH . ', ' . Query::TYPE_NOT_SEARCH . ', ' . Query::TYPE_SELECT),
         };
     }
 
@@ -2033,9 +2099,15 @@ protected function getQueryValue(string $method, mixed $value): mixed
             case Query::TYPE_STARTS_WITH:
                 $value = $this->escapeWildcards($value);
                 return $value . '.*';
+            case Query::TYPE_NOT_STARTS_WITH:
+                $value = $this->escapeWildcards($value);
+                return $value . '.*';
             case Query::TYPE_ENDS_WITH:
                 $value = $this->escapeWildcards($value);
                 return '.*' . $value;
+            case Query::TYPE_NOT_ENDS_WITH:
+                $value = $this->escapeWildcards($value);
+                return '.*' . $value;
             default:
                 return $value;
         }
@@ -2232,7 +2304,7 @@ public function getSupportForFulltextWildcardIndex(): bool
      */
     public function getSupportForQueryContains(): bool
     {
-        return false;
+        return true;
     }
 
     /**
@@ -2628,4 +2700,45 @@ public function getTenantFilters(
 
         return ['$in' => $values];
     }
+
+    public function decodePoint(string $wkb): array
+    {
+        return [];
+    }
+
+    /**
+     * Decode a WKB or textual LINESTRING into [[x1, y1], [x2, y2], ...]
+     *
+     * @param string $wkb
+     * @return float[][] Array of points, each as [x, y]
+     */
+    public function decodeLinestring(string $wkb): array
+    {
+        return [];
+    }
+
+    /**
+     * Decode a WKB or textual POLYGON into [[[x1, y1], [x2, y2], ...], ...]
+     *
+     * @param string $wkb
+     * @return float[][][] Array of rings, each ring is an array of points [x, y]
+     */
+    public function decodePolygon(string $wkb): array
+    {
+        return [];
+    }
+
+    /**
+     * Get the query to check for tenant when in shared tables mode
+     *
+     * @param string $collection   The collection being queried
+     * @param string $alias  The alias of the parent collection if in a subquery
+     * @return string
+     */
+    public function getTenantQuery(string $collection, string $alias = ''): string
+    {
+        return '';
+    }
+
+
 }

src/Database/Adapter/Pool.php

@@ -470,13 +470,7 @@ public function getKeywords(): array
         return $this->delegate(__FUNCTION__, \func_get_args());
     }
 
-    /**
-     * @param array<string,mixed> $selections
-     * @param string $prefix
-     * @param array<string,mixed> $spatialAttributes
-     * @return mixed
-     */
-    protected function getAttributeProjection(array $selections, string $prefix, array $spatialAttributes = []): mixed
+    protected function getAttributeProjection(array $selections, string $prefix): mixed
     {
         return $this->delegate(__FUNCTION__, \func_get_args());
     }
@@ -550,6 +544,21 @@ public function getSupportForSpatialAxisOrder(): bool
         return $this->delegate(__FUNCTION__, \func_get_args());
     }
 
+    public function decodePoint(string $wkb): array
+    {
+        return $this->delegate(__FUNCTION__, \func_get_args());
+    }
+
+    public function decodeLinestring(string $wkb): array
+    {
+        return $this->delegate(__FUNCTION__, \func_get_args());
+    }
+
+    public function decodePolygon(string $wkb): array
+    {
+        return $this->delegate(__FUNCTION__, \func_get_args());
+    }
+
     public function castingBefore(Document $collection, Document $document): Document
     {
         return $this->delegate(__FUNCTION__, \func_get_args());