This commit is contained in:
2021-08-20 01:58:02 -05:00
parent 80916d3a49
commit 4b859492c1
2 changed files with 11 additions and 11 deletions

View File

@@ -12,10 +12,10 @@ static INSERT_EVENT: &str = "
INSERT INTO INSERT INTO
events events
( (
aggregate_type, aggregate_type,
aggregate_id, aggregate_id,
sequence, sequence,
payload, payload,
metadata metadata
) )
VALUES VALUES
@@ -47,14 +47,14 @@ static UPDATE_EVENTS: &str = "
UPDATE UPDATE
events events
SET SET
payload = $4, payload = $1,
metadata = $5 metadata = $1
WHERE WHERE
aggregate_type = $1 aggregate_type = $3
AND AND
aggregate_id = $2 aggregate_id = $4
AND AND
sequence = $3; sequence = $5;
"; ";
async fn get_pool() -> Result<PgPool, sqlx::Error> { async fn get_pool() -> Result<PgPool, sqlx::Error> {
@@ -189,11 +189,11 @@ async fn test_insert_select_update() -> Result<(), sqlx::Error> {
}; };
let rows_affected = sqlx::query(UPDATE_EVENTS) let rows_affected = sqlx::query(UPDATE_EVENTS)
.bind(payload)
.bind(metadata)
.bind(&aggregate_type) .bind(&aggregate_type)
.bind(&aggregate_id) .bind(&aggregate_id)
.bind(1) .bind(1)
.bind(payload)
.bind(metadata)
.execute(&pool) .execute(&pool)
.await? .await?
.rows_affected(); .rows_affected();

View File

@@ -26,10 +26,10 @@ static INSERT_EVENT: &str = "
INSERT INTO INSERT INTO
events events
( (
aggregate_type, aggregate_type,
aggregate_id, aggregate_id,
sequence, sequence,
payload, payload,
metadata metadata
) )
VALUES VALUES