Function test_transaction_commit

tests/database.rs:30–53

()

    #[tokio::test]
    async fn test_transaction_commit() {
        run_test(async {
            let pool = connection_pool().await;
            let executor = Arc::new(RwLock::new(Executor::new(pool)));
            // let mut uow = UnitOfWork::<Repository<BoardAggregate>, BoardAggregate>::new(
            //     connection.read().await.executor(),
            // );

            executor.write().await.begin().await.unwrap();

            let mut board_repo: Repository<BoardAggregate> =
                board_repository_helper(executor.clone());

            let mut board_aggregate = board_create_helper(BoardState::Unpublished);
            let id = board_repo.add(&mut board_aggregate).await.unwrap();

            executor.write().await.commit().await.unwrap();

            //TODO Should exist

            let _board_aggregate = board_repo.get(&id).await.unwrap();
        })
        .await;
    }

    #[tokio::test]
    async fn test_transaction_rollback() {