added sql file for regex

Author: dplewis

spec/MongoTransform.spec.js

@@ -319,6 +319,18 @@ describe('parseObjectToMongoObjectForCreate', () => {
     expect(output.ts.iso).toEqual('2017-01-18T00:00:00.000Z');
     done();
   });
+
+  it('$regex in $all list', (done) => {
+    var input = {
+      arrayField: {'$all': [{$regex: '^\\Qone\\E'}, {$regex: '^\\Qtwo\\E'}, {$regex: '^\\Qthree\\E'}]},
+    };
+    var outputValue = {
+      arrayField: {'$all': [/^\Qone\E/, /^\Qtwo\E/, /^\Qthree\E/]},
+    };
+    var output = transform.transformWhere(null, input);
+    jequal(outputValue.arrayField, output.arrayField);
+    done();
+  });
 });
 
 describe('transformUpdate', () => {

spec/ParseQuery.spec.js

@@ -5,8 +5,31 @@
 'use strict';
 
 const Parse = require('parse/node');
+const TestObject = Parse.Object.extend('TestObject');
 
 describe('Parse.Query testing', () => {
+  it('containsAllStartingWith should match all strings that starts with string', (done) => {
+    const obj1 = new TestObject({strings: ['the', 'brown', 'lazy', 'fox', 'jumps']});
+    const obj2 = new TestObject({strings: ['the', 'brown', 'fox', 'jumps']});
+    const obj3 = new TestObject({strings: ['over', 'the', 'lazy', 'dog']});
+    Parse.Object.saveAll([obj1, obj2, obj3]).then(() => {
+      const query = new Parse.Query(TestObject);
+      const strings = ['the', 'fox', 'lazy'];
+      return query.containsAllStartingWith('strings', strings).find();
+    }).then((results) => {
+      console.log(results);
+      equal(results.length, 1);
+      arrayContains(results, obj1);
+      const query = new Parse.Query(TestObject);
+      return query.containsAllStartingWith('strings', ['the', 'lazy']).find();
+    }).then((results) => {
+      equal(results.length, 2);
+      arrayContains(results, obj1);
+      arrayContains(results, obj3);
+      done();
+    }, done.fail);
+  });
+
   it("basic query", function(done) {
     var baz = new TestObject({ foo: 'baz' });
     var qux = new TestObject({ foo: 'qux' });

src/Adapters/Storage/Mongo/MongoTransform.js

@@ -448,6 +448,8 @@ const transformInteriorAtom = atom => {
     return DateCoder.JSONToDatabase(atom);
   } else if (BytesCoder.isValidJSON(atom)) {
     return BytesCoder.JSONToDatabase(atom);
+  } else if (typeof atom === 'object' && atom && atom.$regex !== undefined) {
+    return new RegExp(atom.$regex);
   } else {
     return atom;
   }

src/Adapters/Storage/Postgres/PostgresStorageAdapter.js

@@ -321,7 +321,15 @@ const buildWhereClause = ({ schema, query, index }) => {
     }
 
     if (Array.isArray(fieldValue.$all) && isArrayField) {
-      patterns.push(`array_contains_all($${index}:name, $${index + 1}::jsonb)`);
+      if (fieldValue.$all[0].$regex) {
+        for (let i = 0; i < fieldValue.$all.length; i += 1) {
+          const value = processRegexPattern(fieldValue.$all[i].$regex);
+          fieldValue.$all[i] = value.substring(1) + '%';
+        }
+        patterns.push(`array_contains_all_regex($${index}:name, $${index + 1}::jsonb)`);
+      } else {
+        patterns.push(`array_contains_all($${index}:name, $${index + 1}::jsonb)`);
+      }
       values.push(fieldName, JSON.stringify(fieldValue.$all));
       index += 2;
     }
@@ -1288,6 +1296,7 @@ export class PostgresStorageAdapter {
             t.none(sql.array.addUnique),
             t.none(sql.array.remove),
             t.none(sql.array.containsAll),
+            t.none(sql.array.containsAllRegex),
             t.none(sql.array.contains)
           ]);
         });

src/Adapters/Storage/Postgres/sql/array/contains-all-regex.sql

@@ -0,0 +1,11 @@
+CREATE OR REPLACE FUNCTION array_contains_all_regex(
+  "array"   jsonb,
+  "values"  jsonb
+)
+  RETURNS boolean
+  LANGUAGE sql
+  IMMUTABLE
+  STRICT
+AS $function$
+  SELECT RES.CNT = jsonb_array_length("values") FROM (SELECT COUNT(*) as CNT FROM jsonb_array_elements_text("array") as elt WHERE elt LIKE ANY (SELECT jsonb_array_elements_text("values"))) as RES;
+$function$;

src/Adapters/Storage/Postgres/sql/index.js

@@ -9,6 +9,7 @@ module.exports = {
     addUnique: sql('array/add-unique.sql'),
     contains: sql('array/contains.sql'),
     containsAll: sql('array/contains-all.sql'),
+    containsAllRegex: sql('array/contains-all-regex.sql'),
     remove: sql('array/remove.sql')
   },
   misc: {