Method createMany

api/src/services/items.ts:444–516

* Create multiple new items at once. Inserts all provided records sequentially wrapped in a transaction. * * Uses `this.createOne` under the hood.

(data: Partial<Item>[], opts: MutationOptions = {})

	 * Uses `this.createOne` under the hood.
	 */
	async createMany(data: Partial<Item>[], opts: MutationOptions = {}): Promise<PrimaryKey[]> {
		if (!opts.mutationTracker) opts.mutationTracker = this.createMutationTracker();

		if (this.collection === 'directus_users') {
			opts.userIntegrityCheckFlags =
				(opts.userIntegrityCheckFlags ?? UserIntegrityCheckFlag.None) | UserIntegrityCheckFlag.UserLimits;
		}

		const { primaryKeys, nestedActionEvents } = await transaction(this.knex, async (knex) => {
			const previousSeatCount = await captureSeatCount(knex, opts.userIntegrityCheckFlags);

			const service = this.fork({ knex });

			let userIntegrityCheckFlags = opts.userIntegrityCheckFlags ?? UserIntegrityCheckFlag.None;

			const primaryKeys: PrimaryKey[] = [];
			const nestedActionEvents: ActionEventParams[] = [];

			const pkField = this.schema.collections[this.collection]!.primary;

			for (const [index, payload] of data.entries()) {
				let bypassAutoIncrementSequenceReset = true;

				// the auto_increment sequence needs to be reset if the current item contains a manual PK and
				// if it's the last item of the batch or if the next item doesn't include a PK and hence one needs to be generated
				if (payload[pkField] && (index === data.length - 1 || !data[index + 1]?.[pkField])) {
					bypassAutoIncrementSequenceReset = false;
				}

				const primaryKey = await service.createOne(payload, {
					...(opts || {}),
					autoPurgeCache: false,
					onRequireUserIntegrityCheck: (flags) => (userIntegrityCheckFlags |= flags),
					bypassEmitAction: (params) => nestedActionEvents.push(params),
					mutationTracker: opts.mutationTracker,
					overwriteDefaults: opts.overwriteDefaults?.[index],
					bypassAutoIncrementSequenceReset,
				});

				primaryKeys.push(primaryKey);
			}

			if (userIntegrityCheckFlags) {
				if (opts.onRequireUserIntegrityCheck) {
					opts.onRequireUserIntegrityCheck(userIntegrityCheckFlags);
				} else {
					await validateUserCountIntegrity({
						flags: userIntegrityCheckFlags,
						knex,
						previousSeatCount,
					});
				}
			}

			return { primaryKeys, nestedActionEvents };
		});

		if (opts.emitEvents !== false) {