Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-21 16:08:22 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Explicit order asc

Browse source
This commit is contained in:
Jake Barnby 2025-10-03 20:00:32 +13:00
parent 2bc90db1f6
commit deb3d75375
No known key found for this signature in database
GPG key ID: C437A8CC85B96E9C
2 changed files with 17 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/Appwrite/Databases/TransactionState.php
View file

@ -4,6 +4,8 @@ namespace Appwrite\Databases;
use Utopia\Database\Database;
use Utopia\Database\Document;
use Utopia\Database\Exception;
use Utopia\Database\Exception\Timeout;
use Utopia\Database\Query;
/**
@ -32,6 +34,9 @@ class TransactionState
* @param string|null $transactionId Optional transaction ID
* @param array $queries Optional query filters
* @return Document
* @throws Exception
* @throws Exception\Query
* @throws Timeout
*/
public function getDocument(
string $collectionId,
@ -90,6 +95,9 @@ class TransactionState
* @param string|null $transactionId Optional transaction ID
* @param array $queries Optional query filters
* @return array Array of Document objects
* @throws Exception
* @throws Exception\Query
* @throws Timeout
*/
public function listDocuments(
string $collectionId,
@ -147,6 +155,9 @@ class TransactionState
* @param string|null $transactionId Optional transaction ID
* @param array $queries Optional query filters
* @return int Document count
* @throws Exception
* @throws Exception\Query
* @throws Timeout
*/
public function countDocuments(
string $collectionId,
@ -328,6 +339,9 @@ class TransactionState
*
* @param string $transactionId Transaction ID
* @return array State array with structure: [collectionId => [docId => ['action' => ..., 'document' => ..., 'exists' => ...]]]
* @throws Exception
* @throws Exception\Query
* @throws Timeout
*/
private function getTransactionState(string $transactionId): array
{
@ -339,6 +353,8 @@ class TransactionState
// Fetch operations ordered by sequence to replay in exact order
$operations = $this->dbForProject->find('transactionLogs', [
Query::equal('transactionInternalId', [$transaction->getSequence()]),
Query::orderAsc(),
Query::limit(PHP_INT_MAX)
]);
$state = [];

1
src/Appwrite/Platform/Modules/Databases/Http/Databases/Transactions/Update.php
View file

@ -137,6 +137,7 @@ class Update extends Action
// Fetch operations ordered by sequence by default to replay operations in exact order they were created
$operations = $dbForProject->find('transactionLogs', [
Query::equal('transactionInternalId', [$transaction->getSequence()]),
Query::orderAsc(),
Query::limit(PHP_INT_MAX),
]);