| 353 | |
| 354 | @pytest.mark.crdb_skip("deferrable") |
| 355 | def test_commit_error(conn): |
| 356 | conn.execute(""" |
| 357 | drop table if exists selfref; |
| 358 | create table selfref ( |
| 359 | x serial primary key, |
| 360 | y int references selfref (x) deferrable initially deferred) |
| 361 | """) |
| 362 | conn.commit() |
| 363 | |
| 364 | conn.execute("insert into selfref (y) values (-1)") |
| 365 | with pytest.raises(e.ForeignKeyViolation): |
| 366 | conn.commit() |
| 367 | assert conn.pgconn.transaction_status == pq.TransactionStatus.IDLE |
| 368 | cur = conn.execute("select 1") |
| 369 | assert cur.fetchone() == (1,) |
| 370 | |
| 371 | |
| 372 | def test_rollback(conn): |