JSON Array update command Spanner - FIX

denes · denes · commit 56a28e575686 · 2025-05-26T14:05:55.000-03:00
diff --git a/src/query-builder/UpdateQueryBuilder.ts b/src/query-builder/UpdateQueryBuilder.ts
@@ -24,8 +24,7 @@ import { DriverUtils } from "../driver/DriverUtils"
  */
 export class UpdateQueryBuilder<Entity extends ObjectLiteral>
     extends QueryBuilder<Entity>
-    implements WhereExpressionBuilder
-{
+    implements WhereExpressionBuilder {
     readonly "@instanceof" = Symbol.for("UpdateQueryBuilder")
 
     // -------------------------------------------------------------------------
@@ -182,7 +181,7 @@ export class UpdateQueryBuilder<Entity extends ObjectLiteral>
             if (transactionStartedByUs) {
                 try {
                     await queryRunner.rollbackTransaction()
-                } catch (rollbackError) {}
+                } catch (rollbackError) { }
             }
             throw error
         } finally {
@@ -537,18 +536,26 @@ export class UpdateQueryBuilder<Entity extends ObjectLiteral>
                             // support for SQL expressions in update query
                             updateColumnAndValues.push(
                                 this.escape(column.databaseName) +
-                                    " = " +
-                                    value(),
+                                " = " +
+                                value(),
                             )
                         } else if (
                             (this.connection.driver.options.type === "sap" ||
                                 this.connection.driver.options.type ===
-                                    "spanner") &&
+                                "spanner") &&
                             value === null
                         ) {
                             updateColumnAndValues.push(
                                 this.escape(column.databaseName) + " = NULL",
                             )
+                        } else if (this.connection.driver.options.type ==="spanner" &&
+                            value !== null && 
+                            Array.isArray(value) &&
+                            column.type === "json"
+                        ) {
+                            updateColumnAndValues.push(
+                                this.escape(column.databaseName) + " = JSON '" + JSON.stringify(value) + "'",
+                            )
                         } else {
                             if (
                                 this.connection.driver.options.type === "mssql"
@@ -566,15 +573,15 @@ export class UpdateQueryBuilder<Entity extends ObjectLiteral>
                                     this.connection.driver,
                                 ) ||
                                     this.connection.driver.options.type ===
-                                        "aurora-mysql") &&
+                                    "aurora-mysql") &&
                                 this.connection.driver.spatialTypes.indexOf(
                                     column.type,
                                 ) !== -1
                             ) {
                                 const useLegacy = (
                                     this.connection.driver as
-                                        | MysqlDriver
-                                        | AuroraMysqlDriver
+                                    | MysqlDriver
+                                    | AuroraMysqlDriver
                                 ).options.legacySpatialSupport
                                 const geomFromText = useLegacy
                                     ? "GeomFromText"
@@ -599,7 +606,7 @@ export class UpdateQueryBuilder<Entity extends ObjectLiteral>
                                 }
                             } else if (
                                 this.connection.driver.options.type ===
-                                    "mssql" &&
+                                "mssql" &&
                                 this.connection.driver.spatialTypes.indexOf(
                                     column.type,
                                 ) !== -1
@@ -616,8 +623,8 @@ export class UpdateQueryBuilder<Entity extends ObjectLiteral>
                             }
                             updateColumnAndValues.push(
                                 this.escape(column.databaseName) +
-                                    " = " +
-                                    expression,
+                                " = " +
+                                expression,
                             )
                         }
                     })
@@ -635,17 +642,17 @@ export class UpdateQueryBuilder<Entity extends ObjectLiteral>
                 )
                     updateColumnAndValues.push(
                         this.escape(metadata.versionColumn.databaseName) +
-                            " = " +
-                            this.escape(metadata.versionColumn.databaseName) +
-                            " + 1",
+                        " = " +
+                        this.escape(metadata.versionColumn.databaseName) +
+                        " + 1",
                     )
                 if (
                     metadata.updateDateColumn &&
                     updatedColumns.indexOf(metadata.updateDateColumn) === -1
                 )
                     updateColumnAndValues.push(
                         this.escape(metadata.updateDateColumn.databaseName) +
-                            " = CURRENT_TIMESTAMP",
+                        " = CURRENT_TIMESTAMP",
                     ) // todo: fix issue with CURRENT_TIMESTAMP(6) being used, can "DEFAULT" be used?!
             }
         } else {
