applyJsonDiff() — drizzle-orm Function Reference

Source Code

drizzle-kit/src/jsonDiffer.js lines 208–411

export function applyJsonDiff(json1, json2) {
	json1 = JSON.parse(JSON.stringify(json1));
	json2 = JSON.parse(JSON.stringify(json2));

	// deep copy, needed because of the bug in diff library
	const rawDiff = diff(json1, json2);

	const difference = JSON.parse(JSON.stringify(rawDiff || {}));
	difference.schemas = difference.schemas || {};
	difference.tables = difference.tables || {};
	difference.enums = difference.enums || {};
	difference.sequences = difference.sequences || {};
	difference.roles = difference.roles || {};
	difference.policies = difference.policies || {};
	difference.views = difference.views || {};

	// remove added/deleted schemas
	const schemaKeys = Object.keys(difference.schemas);
	for (let key of schemaKeys) {
		if (key.endsWith('__added') || key.endsWith('__deleted')) {
			delete difference.schemas[key];
			continue;
		}
	}

	// remove added/deleted tables
	const tableKeys = Object.keys(difference.tables);
	for (let key of tableKeys) {
		if (key.endsWith('__added') || key.endsWith('__deleted')) {
			delete difference.tables[key];
			continue;
		}

		// supply table name and schema for altered tables
		const table = json1.tables[key];
		difference.tables[key] = {
			name: table.name,
			schema: table.schema,
			...difference.tables[key],
		};
	}

	for (let [tableKey, tableValue] of Object.entries(difference.tables)) {
		const table = difference.tables[tableKey];
		const columns = tableValue.columns || {};
		const columnKeys = Object.keys(columns);
		for (let key of columnKeys) {
			if (key.endsWith('__added') || key.endsWith('__deleted')) {
				delete table.columns[key];
				continue;
			}
		}

		if (Object.keys(columns).length === 0) {
			delete table['columns'];
		}

		if (
			'name' in table
			&& 'schema' in table
			&& Object.keys(table).length === 2
		) {
			delete difference.tables[tableKey];
		}
	}

	const enumsEntries = Object.entries(difference.enums);
	const alteredEnums = enumsEntries
		.filter((it) => !(it[0].includes('__added') || it[0].includes('__deleted')))
		.map((it) => {
			const enumEntry = json1.enums[it[0]];
			const { name, schema, values } = enumEntry;

			const sequence = mapArraysDiff(values, it[1].values);
			const addedValues = sequence
				.filter((it) => it.type === 'added')
				.map((it) => {
					return {
						before: it.before,
						value: it.value,
					};