hazza/Phraseanet
1
0
Fork 0
mirror of https://github.com/alchemy-fr/Phraseanet.git synced 2025-10-24 02:13:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

create feedEntriesTokens in bulk / doctrine. No more sql

Browse Source
This commit is contained in:
Jean-Yves Gaulier
2020-02-11 15:17:13 +01:00
parent e4d3da9336
commit 5a794c493a
1 changed files with 4 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
lib/Alchemy/Phrasea/Model/Manipulator/TokenManipulator.php
View File

@@ -137,28 +137,9 @@ class TokenManipulator implements ManipulatorInterface
{ {
// $this->removeExpiredTokens(); // $this->removeExpiredTokens();
$conn = $this->repository->getEntityManager()->getConnection();
// use an optimized tmp table we can fill fast (only 2 values changes by row, others are default)
$now = $conn->quote((new \DateTime())->format('Y-m-d H:i:s'));
$conn->executeQuery("CREATE TEMPORARY TABLE `tmpTokens` (\n"
. " `value` char(128),\n"
. " `user_id` int(11),\n"
. " `type` char(32) DEFAULT " . $conn->quote(self::TYPE_FEED_ENTRY) . ",\n"
. " `data` int(11) DEFAULT " . $conn->quote($entry->getId()) . ",\n"
. " `created` datetime DEFAULT " . $now . ",\n"
. " `updated` datetime DEFAULT " . $now . ",\n"
. " `expiration` datetime DEFAULT NULL\n"
. ") ENGINE=MEMORY;"
);
$tokens = []; $tokens = [];
$sql = "";
foreach ($users as $user) { foreach ($users as $user) {
$value = $this->random->generateString(32, self::LETTERS_AND_NUMBERS) . $user->getId(); $value = $this->random->generateString(32, self::LETTERS_AND_NUMBERS) . $user->getId();
// todo: don't build a too long sql, we should flush/run into temp table if l>limit.
// But for now we trust that 100 (see FeedEntrySsuscriber) tokens is ok
$sql .= ($sql?',':'') . ('(' . $conn->quote($value) . ',' . $conn->quote($user->getId()) . ')');
$token = new Token(); $token = new Token();
$token->setUser($user) $token->setUser($user)
@@ -167,11 +148,11 @@ class TokenManipulator implements ManipulatorInterface
->setExpiration(null) ->setExpiration(null)
->setData($entry->getId()); ->setData($entry->getId());
$tokens[] = $token; $tokens[] = $token;
}
$conn->executeQuery("INSERT INTO tmpTokens (`value`, `user_id`) VALUES " . $sql); $this->om->persist($token);
$conn->executeQuery("INSERT INTO Tokens SELECT * FROM tmpTokens"); }
$conn->executeQuery("DROP TABLE tmpTokens"); $this->om->flush();
$this->om->clear();
return $tokens; return $tokens;
} }