                 XCTAssertEqual(Int.fetchOne(db, "SELECT COUNT(*) FROM items4"), 1)
             }
             
-            XCTAssertEqual(observer.lastCommittedEvents.count, 3)
+            XCTAssertEqual(observer.lastCommittedEvents.count, 4)
             XCTAssertTrue(match(event: observer.lastCommittedEvents[0], kind: .Insert, tableName: "items1", rowId: 1))
             XCTAssertTrue(match(event: observer.lastCommittedEvents[1], kind: .Insert, tableName: "items2", rowId: 1))
             XCTAssertTrue(match(event: observer.lastCommittedEvents[2], kind: .Insert, tableName: "items3", rowId: 1))

                try db.execute("INSERT INTO items2 (id) VALUES (NULL)")
                XCTAssertEqual(observer.events.count, 0)
                try db.execute("RELEASE SAVEPOINT sp1")
                
                XCTAssertEqual(Int.fetchOne(db, "SELECT COUNT(*) FROM items1"), 1)
                XCTAssertEqual(Int.fetchOne(db, "SELECT COUNT(*) FROM items2"), 1)

            
            XCTAssertEqual(observer.lastCommittedEvents.count, 2)
            XCTAssertTrue(match(event: observer.lastCommittedEvents[0], kind: .Insert, tableName: "items1", rowId: 1))
            XCTAssertTrue(match(event: observer.lastCommittedEvents[1], kind: .Insert, tableName: "items4", rowId: 1))
        }
    }
    
