[NO_TICKET] fix: run spanner relational queries sequential to prevent…

… seqno errors (#10) * fix: run spanner relational queries sequential to prevent seqno errors * fix: update package-lock
streamyard · Jul 4, 2023 · 5f88552 · 5f88552
1 parent e9baaa8
commit 5f88552
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 4 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,7 +1,7 @@
 {
  "name": "@streamyard/typeorm",
  "private": true,
- "version": "0.3.16-1",
+ "version": "0.3.16-2",
  "description": "Data-Mapper ORM for TypeScript, ES7, ES6, ES5. Supports MySQL, PostgreSQL, MariaDB, SQLite, MS SQL Server, Oracle, MongoDB, Spanner databases.",
  "license": "MIT",
  "readmeFilename": "README.md",

diff --git a/src/persistence/SubjectExecutor.ts b/src/persistence/SubjectExecutor.ts
@@ -524,6 +524,9 @@ export class SubjectExecutor {
  * Updates all given subjects in the database.
  */
  protected async executeUpdateOperations(): Promise<void> {
+ const isSpanner =
+ this.queryRunner.connection.driver.options.type === "spanner"
+
  const updateSubject = async (subject: Subject) => {
  if (!subject.identifier)
  throw new SubjectWithoutIdentifierError(subject)
@@ -645,7 +648,7 @@ export class SubjectExecutor {
  const remainingSubjects: Subject[] = []
 
  for (const subject of this.updateSubjects) {
- if (subject.metadata.treeType === "nested-set") {
+ if (subject.metadata.treeType === "nested-set" || isSpanner) {
  nestedSetSubjects.push(subject)
  } else {
  remainingSubjects.push(subject)