unit tests and logic added to prevent coalesce being used by oracle

packages/backend-core/src/sql/sql.ts

@@ -435,6 +435,11 @@ class InternalBuilder {
             )} = ? THEN 1 ELSE 0 END = 1`,
             [value]
           )
+        } else if (SqlClient.ORACLE) {
+          query = query[fnc](
+            `${quotedIdentifier(this.client, key)} = ?`,
+            [value]
+          )
         } else {
           query = query[fnc](
             `COALESCE(${quotedIdentifier(this.client, key)} = ?, FALSE)`,

packages/backend-core/src/sql/utils.ts

@@ -153,9 +153,9 @@ export function isValidTime(value: string) {
 }
 
 export function sqlLog(client: string, query: string, values?: any[]) {
-  if (!environment.SQL_LOGGING_ENABLE) {
+  // if (!environment.SQL_LOGGING_ENABLE) {
-    return
+  //   return
-  }
+  // }
   let string = `[SQL] [${client.toUpperCase()}] query="${query}"`
   if (values) {
     string += ` values="${values.join(", ")}"`

packages/server/src/integrations/tests/sql.spec.ts

@@ -142,7 +142,14 @@ describe("SQL query builder", () => {
     const query = sql._query(generateRelationshipJson({schema: "production"}))
     expect(query).toEqual({
       bindings: [500, 5000],
-      sql: `select "brands"."brand_id" as "brands.brand_id", "brands"."brand_name" as "brands.brand_name", "products"."product_id" as "products.product_id", "products"."product_name" as "products.product_name", "products"."brand_id" as "products.brand_id" from (select * from "production"."brands" order by "test"."id" asc limit $1) as "brands" left join "production"."products" as "products" on "brands"."brand_id" = "products"."brand_id" order by "test"."id" asc limit $2`,
+      sql: `select "brands"."brand_id"       as "brands.brand_id",
+                   "brands"."brand_name"     as "brands.brand_name",
+                   "products"."product_id"   as "products.product_id",
+                   "products"."product_name" as "products.product_name",
+                   "products"."brand_id"     as "products.brand_id"
+            from (select * from "production"."brands" order by "test"."id" asc limit $1) as "brands"
+                     left join "production"."products" as "products" on "brands"."brand_id" = "products"."brand_id"
+            order by "test"."id" asc limit $2`,
     })
   })
 
@@ -150,7 +157,14 @@ describe("SQL query builder", () => {
     const query = sql._query(generateRelationshipJson())
     expect(query).toEqual({
       bindings: [500, 5000],
-      sql: `select "brands"."brand_id" as "brands.brand_id", "brands"."brand_name" as "brands.brand_name", "products"."product_id" as "products.product_id", "products"."product_name" as "products.product_name", "products"."brand_id" as "products.brand_id" from (select * from "brands" order by "test"."id" asc limit $1) as "brands" left join "products" as "products" on "brands"."brand_id" = "products"."brand_id" order by "test"."id" asc limit $2`,
+      sql: `select "brands"."brand_id"       as "brands.brand_id",
+                   "brands"."brand_name"     as "brands.brand_name",
+                   "products"."product_id"   as "products.product_id",
+                   "products"."product_name" as "products.product_name",
+                   "products"."brand_id"     as "products.brand_id"
+            from (select * from "brands" order by "test"."id" asc limit $1) as "brands"
+                     left join "products" as "products" on "brands"."brand_id" = "products"."brand_id"
+            order by "test"."id" asc limit $2`,
     })
   })
 
@@ -160,7 +174,14 @@ describe("SQL query builder", () => {
     )
     expect(query).toEqual({
       bindings: [500, 5000],
-      sql: `select "stores"."store_id" as "stores.store_id", "stores"."store_name" as "stores.store_name", "products"."product_id" as "products.product_id", "products"."product_name" as "products.product_name" from (select * from "production"."stores" order by "test"."id" asc limit $1) as "stores" left join "production"."stocks" as "stocks" on "stores"."store_id" = "stocks"."store_id" left join "production"."products" as "products" on "products"."product_id" = "stocks"."product_id" order by "test"."id" asc limit $2`,
+      sql: `select "stores"."store_id"       as "stores.store_id",
+                   "stores"."store_name"     as "stores.store_name",
+                   "products"."product_id"   as "products.product_id",
+                   "products"."product_name" as "products.product_name"
+            from (select * from "production"."stores" order by "test"."id" asc limit $1) as "stores"
+                     left join "production"."stocks" as "stocks" on "stores"."store_id" = "stocks"."store_id"
+                     left join "production"."products" as "products" on "products"."product_id" = "stocks"."product_id"
+            order by "test"."id" asc limit $2`,
     })
   })
 
@@ -176,7 +197,13 @@ describe("SQL query builder", () => {
     )
     expect(query).toEqual({
       bindings: ["john%", limit, 5000],
-      sql: `select * from (select * from (select * from (select * from "test" where LOWER("test"."name") LIKE :1 order by "test"."id" asc) where rownum <= :2) "test" order by "test"."id" asc) where rownum <= :3`,
+      sql: `select *
+            from (select *
+                  from (select *
+                        from (select * from "test" where LOWER("test"."name") LIKE :1 order by "test"."id" asc)
+                        where rownum <= :2) "test"
+                  order by "test"."id" asc)
+            where rownum <= :3`,
     })
 
     query = new Sql(SqlClient.ORACLE, limit)._query(
@@ -191,7 +218,17 @@ describe("SQL query builder", () => {
     )
     expect(query).toEqual({
       bindings: ["%20%", "%25%", `%"john"%`, `%"mary"%`, limit, 5000],
-      sql: `select * from (select * from (select * from (select * from "test" where (COALESCE(LOWER("test"."age"), '') LIKE :1 AND COALESCE(LOWER("test"."age"), '') LIKE :2) and (COALESCE(LOWER("test"."name"), '') LIKE :3 AND COALESCE(LOWER("test"."name"), '') LIKE :4) order by "test"."id" asc) where rownum <= :5) "test" order by "test"."id" asc) where rownum <= :6`,
+      sql: `select *
+            from (select *
+                  from (select *
+                        from (select *
+                              from "test"
+                              where (COALESCE(LOWER("test"."age"), '') LIKE :1 AND COALESCE(LOWER("test"."age"), '') LIKE :2)
+                                and (COALESCE(LOWER("test"."name"), '') LIKE :3 AND COALESCE(LOWER("test"."name"), '') LIKE :4)
+                              order by "test"."id" asc)
+                        where rownum <= :5) "test"
+                  order by "test"."id" asc)
+            where rownum <= :6`,
     })
 
     query = new Sql(SqlClient.ORACLE, limit)._query(
@@ -205,7 +242,45 @@ describe("SQL query builder", () => {
     )
     expect(query).toEqual({
       bindings: [`%jo%`, limit, 5000],
-      sql: `select * from (select * from (select * from (select * from "test" where LOWER("test"."name") LIKE :1 order by "test"."id" asc) where rownum <= :2) "test" order by "test"."id" asc) where rownum <= :3`,
+      sql: `select *
+            from (select *
+                  from (select *
+                        from (select * from "test" where LOWER("test"."name") LIKE :1 order by "test"."id" asc)
+                        where rownum <= :2) "test"
+                  order by "test"."id" asc)
+            where rownum <= :3`,
+    })
+  })
+
+  it("should not use a coalesce query for oracle when using the equals filter", () => {
+    let query = new Sql(SqlClient.ORACLE, limit)._query(
+      generateReadJson({
+        filters: {
+          equal: {
+            name: "John",
+          },
+        },
+      }))
+
+    expect(query).not.toEqual({
+      bindings: ["John", limit, 5000],
+      sql: `select * from (select * from (select * from (select * from "test" where COALESCE("test"."id" = :2, FALSE) order by "test"."id" asc) where rownum <= :2) "test" order by "test"."id" asc) where rownum <= :3`,
+    })
+  })
+
+  it("should use a direct equality query for oracle when using the equals filter", () => {
+    let query = new Sql(SqlClient.ORACLE, limit)._query(
+      generateReadJson({
+        filters: {
+          equal: {
+            name: "John",
+          },
+        },
+     }))
+
+    expect(query).toEqual({
+      bindings: ["John", limit, 5000],
+      sql: `select * from (select * from (select * from (select * from "test" where "test"."name" = :1 order by "test"."id" asc) where rownum <= :2) "test" order by "test"."id" asc) where rownum <= :3`,
     })
   })
 })