Skip to content

Commit b6c6053

Browse files
davecosecoskardudycz
authored andcommitted
Removed MAX from last stream position query
1 parent 082f414 commit b6c6053

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/packages/emmett-sqlite/src/eventStore/schema/appendToStream.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -199,7 +199,7 @@ async function getLastStreamPosition(
199199
expectedStreamVersion: bigint | null,
200200
): Promise<bigint> {
201201
const result = await db.querySingle<{ stream_position: string } | null>(
202-
`SELECT CAST(MAX(stream_position) AS VARCHAR) AS stream_position FROM ${streamsTable.name} WHERE stream_id = ?`,
202+
`SELECT CAST(stream_position AS VARCHAR) AS stream_position FROM ${streamsTable.name} WHERE stream_id = ?`,
203203
[streamId],
204204
);
205205

0 commit comments

Comments
 (0)