fix: adjust orWhere

Author: jlenon7

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@athenna/database",
-  "version": "5.45.0",
+  "version": "5.46.0",
   "description": "The Athenna database handler for SQL/NoSQL.",
   "license": "MIT",
   "author": "João Lenon <lenon@athenna.io>",

package.json

@@ -1351,6 +1351,12 @@ export class BaseKnexDriver extends Driver<Knex, Knex.QueryBuilder> {
         throw new EmptyColumnException('orWhere')
       }
 
+      if (this.isUsingJsonSelector(statement)) {
+        this.orWhereJson(statement, operation)
+
+        return this
+      }
+
       this.qb.orWhere(statement, operation)
 
       return this
@@ -1364,6 +1370,12 @@ export class BaseKnexDriver extends Driver<Knex, Knex.QueryBuilder> {
       throw new EmptyValueException('orWhere')
     }
 
+    if (this.isUsingJsonSelector(statement)) {
+      this.orWhereJson(statement, operation, value)
+
+      return this
+    }
+
     this.qb.orWhere(statement, operation, value)
 
     return this

src/database/drivers/BaseKnexDriver.ts

@@ -176,10 +176,6 @@ export class PostgresDriver extends BaseKnexDriver {
       throw new Error(`Invalid JSON selector: ${column}`)
     }
 
-    if (!parsed.path.includes('*')) {
-      return super.whereJson(column, operator, value)
-    }
-
     const path = this.parseJsonSelectorToWildcardPath(parsed.path)
     const normalized = this.normalizeJsonOperation(operator, value)
 
@@ -209,10 +205,6 @@ export class PostgresDriver extends BaseKnexDriver {
       throw new Error(`Invalid JSON selector: ${column}`)
     }
 
-    if (!parsed.path.includes('*')) {
-      return super.orWhereJson(column, operator, value)
-    }
-
     const path = this.parseJsonSelectorToWildcardPath(parsed.path)
     const normalized = this.normalizeJsonOperation(operator, value)
 

src/database/drivers/PostgresDriver.ts

@@ -1829,6 +1829,18 @@ export default class PostgresDriverTest {
     assert.deepEqual(data, [{ user_id: '2' }, { user_id: '2' }])
   }
 
+  @Test()
+  public async shouldBeAbleToFilterJsonByKeyUsingWhereSelector({ assert }: Context) {
+    await this.driver.table('events').createMany([
+      { id: '1', metadata: { name: 'admin' } },
+      { id: '2', metadata: { name: 'member' } }
+    ])
+
+    const data = await this.driver.table('events').where('metadata->name', 'admin').findMany()
+
+    assert.deepEqual(data, [{ id: '1', metadata: { name: 'admin' } }])
+  }
+
   @Test()
   public async shouldBeAbleToFilterJsonArrayByIndexUsingWhereJson({ assert }: Context) {
     await this.driver.table('events').createMany([
@@ -2257,6 +2269,18 @@ export default class PostgresDriverTest {
     ])
   }
 
+  @Test()
+  public async shouldBeAbleToFilterJsonUsingOrWhereSelector({ assert }: Context) {
+    await this.driver.table('events').createMany([
+      { id: '1', metadata: { name: 'admin' } },
+      { id: '2', metadata: { name: 'member' } }
+    ])
+
+    const data = await this.driver.table('events').where('id', '0').orWhere('metadata->name', 'member').findMany()
+
+    assert.deepEqual(data, [{ id: '2', metadata: { name: 'member' } }])
+  }
+
   @Test()
   public async shouldBeAbleToAddAOrWhereClauseToTheQueryUsingDriver({ assert }: Context) {
     await this.driver.table('users').createMany([