Method commitChange

src/database-engines/sqlite-engine.ts:368–419

(mutation: SerializedMutation, transaction: SQLiteTransaction)

  }

  async commitChange(mutation: SerializedMutation, transaction: SQLiteTransaction): Promise<void> {
    try {
      let db: Database;

      db = transaction.getConnection();

      return new Promise<void>((resolve, reject) => {
        const { type, table, primaryKeyColumn, primaryKey } = mutation;

        if (type === 'cell-update') {
          const setClauses: string[] = [];
          const params: any[] = [];

          setClauses.push(`${this.escapeIdentifier(mutation.column.name)} = ?`);
          params.push(this.transformValueForSqlite(mutation.newValue));

          // Add primary key value to params
          params.push(this.transformValueForSqlite(primaryKey));

          const query = `UPDATE ${this.escapeIdentifier(table)}
                         SET ${setClauses.join(', ')}
                         WHERE ${this.escapeIdentifier(primaryKeyColumn)} = ?`;

          db.run(query, params, function (err) {
            if (err) {
              reportError(`SQLite update error: ${err}`);
              reject(err);
              return;
            }
            resolve();
          });
        } else if (type === 'row-delete') {
          const query = `DELETE FROM ${this.escapeIdentifier(table)}
                         WHERE ${this.escapeIdentifier(primaryKeyColumn)} = ?`;

          db.run(query, [this.transformValueForSqlite(primaryKey)], function (err) {
            if (err) {
              reportError(`SQLite delete error: ${err}`);
              reject(err);
              return;
            }
            resolve();
          });
        } else {
          reject(new Error(`Unsupported mutation type: ${type}`));
        }
      });
    } catch (err) {
      reportError(`SQLite commit change error: ${err}`);
      throw err;
    }
  }

  async raw(code: string): Promise<any> {
    return this.rawQuery(code)