github/directus
1
0
Fork 0
mirror of https://github.com/directus/directus.git synced 2026-02-01 15:34:57 -05:00
Code Issues Packages Projects Releases Wiki Activity

Create field in transaction

Browse Source 
Fixes #4211
This commit is contained in:
rijkvanzanten
2021-03-04 17:35:39 -05:00
parent 61c5522c06
commit 5afa6c04fc
1 changed files with 22 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
api/src/services/fields.ts
View File

@@ -217,23 +217,31 @@ export class FieldsService {
throw new InvalidPayloadException(`Field "${field.field}" already exists in collection "${collection}"`);
}
if (field.type && ALIAS_TYPES.includes(field.type) === false) {
if (table) {
this.addColumnToTable(table, field as Field);
} else {
await database.schema.alterTable(collection, (table) => {
await this.knex.transaction(async (trx) => {
const itemsService = new ItemsService('directus_fields', {
knex: trx,
accountability: this.accountability,
schema: this.schema,
});
if (field.type && ALIAS_TYPES.includes(field.type) === false) {
if (table) {
this.addColumnToTable(table, field as Field);
} else {
await trx.schema.alterTable(collection, (table) => {
this.addColumnToTable(table, field as Field);
});
}
}
if (field.meta) {
await itemsService.create({
...field.meta,
collection: collection,
field: field.field,
});
}
}
if (field.meta) {
await this.itemsService.create({
...field.meta,
collection: collection,
field: field.field,
});
}
});
if (cache && env.CACHE_AUTO_PURGE) {
await cache.clear();