yujunjun/strapi
1
0
Fork 0
mirror of https://github.com/strapi/strapi.git synced 2025-11-02 02:44:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

finally drop temp table

Browse Source
This commit is contained in:
Pierre Noël 2022-11-15 18:57:13 +01:00
parent e2234ed9f1
commit 306d5c4abc
1 changed files with 74 additions and 63 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

137
packages/core/database/lib/entity-manager/regular-relations.js
View File

@ -295,75 +295,86 @@ const cleanOrderColumnsForOldDatabases = async ({
if (hasOrderColumn(attribute) && id) {
const tempOrderTableName = `tempOrderTableName_${now}`;
await db.connection
.raw(
`
CREATE TEMPORARY TABLE :tempOrderTableName:
SELECT
try {
await db.connection
.raw(
`
CREATE TEMPORARY TABLE :tempOrderTableName:
SELECT
id,
(
SELECT count(*)
FROM :joinTableName: b
WHERE a.:orderColumnName: >= b.:orderColumnName: AND a.:joinColumnName: = b.:joinColumnName: AND a.:joinColumnName: = :id
) AS src_order
FROM :joinTableName: a`,
{
tempOrderTableName,
joinTableName: joinTable.name,
orderColumnName,
joinColumnName: joinColumn.name,
id,
(
SELECT count(*)
FROM :joinTableName: b
WHERE a.:orderColumnName: >= b.:orderColumnName: AND a.:joinColumnName: = b.:joinColumnName: AND a.:joinColumnName: = :id
) AS src_order
FROM :joinTableName: a`,
{
tempOrderTableName,
joinTableName: joinTable.name,
orderColumnName,
joinColumnName: joinColumn.name,
id,
}
)
.transacting(trx);
await db.connection
.raw(
`UPDATE ?? as a, (SELECT * FROM ??) AS b
}
)
.transacting(trx);
await db.connection
.raw(
`UPDATE ?? as a, (SELECT * FROM ??) AS b
SET ?? = b.src_order
WHERE a.id = b.id`,
[joinTable.name, tempOrderTableName, orderColumnName]
)
.transacting(trx);
await db.connection.raw(`DROP TEMPORARY TABLE ${tempOrderTableName}`).transacting(trx);
[joinTable.name, tempOrderTableName, orderColumnName]
)
.transacting(trx);
} finally {
await db.connection
.raw(`DROP TEMPORARY TABLE IF EXISTS ${tempOrderTableName}`)
.transacting(trx);
}
}
if (hasInverseOrderColumn(attribute) && !isEmpty(inverseRelIds)) {
const tempInvOrderTableName = `tempInvOrderTableName_${now}`;
await db.connection
.raw(
`
CREATE TEMPORARY TABLE ??
SELECT
id,
(
SELECT count(*)
FROM ?? b
WHERE a.?? >= b.?? AND a.?? = b.?? AND a.?? IN (${inverseRelIds
.map(() => '?')
.join(', ')})
) AS inv_order
FROM ?? a`,
[
tempInvOrderTableName,
joinTable.name,
inverseOrderColumnName,
inverseOrderColumnName,
inverseJoinColumn.name,
inverseJoinColumn.name,
inverseJoinColumn.name,
...inverseRelIds,
joinTable.name,
]
)
.transacting(trx);
await db.connection
.raw(
`UPDATE ?? as a, (SELECT * FROM ??) AS b
SET ?? = b.inv_order
WHERE a.id = b.id`,
[joinTable.name, tempInvOrderTableName, inverseOrderColumnName]
)
.transacting(trx);
await db.connection.raw(`DROP TEMPORARY TABLE ${tempInvOrderTableName}`).transacting(trx);
try {
await db.connection
.raw(
`
CREATE TEMPORARY TABLE ??
SELECT
id,
(
SELECT count(*)
FROM ?? b
WHERE a.?? >= b.?? AND a.?? = b.?? AND a.?? IN (${inverseRelIds
.map(() => '?')
.join(', ')})
) AS inv_order
FROM ?? a`,
[
tempInvOrderTableName,
joinTable.name,
inverseOrderColumnName,
inverseOrderColumnName,
inverseJoinColumn.name,
inverseJoinColumn.name,
inverseJoinColumn.name,
...inverseRelIds,
joinTable.name,
]
)
.transacting(trx);
await db.connection
.raw(
`UPDATE ?? as a, (SELECT * FROM ??) AS b
SET ?? = b.inv_order
WHERE a.id = b.id`,
[joinTable.name, tempInvOrderTableName, inverseOrderColumnName]
)
.transacting(trx);
} finally {
await db.connection
.raw(`DROP TEMPORARY TABLE IF EXISTS ${tempInvOrderTableName}`)
.transacting(trx);
}
}
};