Function commitChange

src/services/sql.ts:69–95

(connection: knexlib.Knex | null, serializedMutation: SerializedMutation, transaction?: knexlib.Knex.Transaction, openDelimiter: string = '`')

	},

	async commitChange(connection: knexlib.Knex | null, serializedMutation: SerializedMutation, transaction?: knexlib.Knex.Transaction, openDelimiter: string = '`'): Promise<void> {
		if (!connection) return;

		const { table, primaryKey, primaryKeyColumn } = serializedMutation;
		let query = '';
		let replacements: Record<string, any> = { primaryKey };
		const closeDelimiter = openDelimiter === '[' ? ']' : openDelimiter;

		const safeTable = sanitizeIdentifier(table, openDelimiter, closeDelimiter);
		const safePkCol = sanitizeIdentifier(primaryKeyColumn, openDelimiter, closeDelimiter);

		if (serializedMutation.type === 'cell-update') {
			const { column, newValue } = serializedMutation;
			const safeColName = sanitizeIdentifier(column.name, openDelimiter, closeDelimiter);
			query = `UPDATE ${safeTable} SET ${safeColName} = :newValue WHERE ${safePkCol} = :primaryKey`;
			replacements = { ...replacements, newValue };
		} else if (serializedMutation.type === 'row-delete') {
			query = `DELETE FROM ${safeTable} WHERE ${safePkCol} = :primaryKey`;
		}

		if (transaction) {
			await transaction.raw(query, replacements);
			await transaction.commit()
		} else {
			await (connection).raw(query, replacements);
		}
	}
}

export function buildWhereClause(engine: DatabaseEngine | SqliteEngine, dialect: KnexClientType | 'sqlite3', whereClause: Record<string, any>, columns: Column[]): WhereEntry[] {