| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| |
|
| | if {![info exists testdir]} { |
| | set testdir [file join [file dirname [info script]] .. .. test] |
| | } |
| | source [file join [file dirname [info script]] session_common.tcl] |
| | source $testdir/tester.tcl |
| | ifcapable !session {finish_test; return} |
| | set testprefix session9 |
| |
|
| |
|
| | |
| | |
| | |
| | proc populate_db {} { |
| | drop_all_tables |
| | execsql { |
| | PRAGMA foreign_keys = 1; |
| | CREATE TABLE p1(a PRIMARY KEY, b); |
| | CREATE TABLE c1(a PRIMARY KEY, b REFERENCES p1); |
| | CREATE TABLE c2(a PRIMARY KEY, |
| | b REFERENCES p1 DEFERRABLE INITIALLY DEFERRED |
| | ); |
| |
|
| | INSERT INTO p1 VALUES(1, 'one'); |
| | INSERT INTO p1 VALUES(2, 'two'); |
| | INSERT INTO p1 VALUES(3, 'three'); |
| | INSERT INTO p1 VALUES(4, 'four'); |
| | } |
| | } |
| |
|
| | proc capture_changeset {sql} { |
| | sqlite3session S db main |
| |
|
| | foreach t [db eval {SELECT name FROM sqlite_master WHERE type='table'}] { |
| | S attach $t |
| | } |
| | execsql $sql |
| | set ret [S changeset] |
| | S delete |
| |
|
| | return $ret |
| | } |
| |
|
| | do_test 1.1 { |
| | populate_db |
| | set cc [capture_changeset { |
| | INSERT INTO c1 VALUES('ii', 2); |
| | INSERT INTO c2 VALUES('iii', 3); |
| | }] |
| | set {} {} |
| | } {} |
| |
|
| | proc xConflict {args} { |
| | lappend ::xConflict {*}$args |
| | return $::conflictret |
| | } |
| |
|
| | foreach {tn delrow trans conflictargs conflictret} { |
| | 1 2 0 {FOREIGN_KEY 1} OMIT |
| | 2 3 0 {FOREIGN_KEY 1} OMIT |
| | 3 2 1 {FOREIGN_KEY 1} OMIT |
| | 4 3 1 {FOREIGN_KEY 1} OMIT |
| | 5 2 0 {FOREIGN_KEY 1} ABORT |
| | 6 3 0 {FOREIGN_KEY 1} ABORT |
| | 7 2 1 {FOREIGN_KEY 1} ABORT |
| | 8 3 1 {FOREIGN_KEY 1} ABORT |
| | } { |
| |
|
| | set A(OMIT,0) {0 {}} |
| | set A(OMIT,1) {0 {}} |
| | set A(ABORT,0) {1 SQLITE_CONSTRAINT} |
| | set A(ABORT,1) {1 SQLITE_CONSTRAINT} |
| | do_test 1.2.$tn.1 { |
| | populate_db |
| | execsql { DELETE FROM p1 WHERE a=($delrow+0) } |
| | if {$trans} { execsql BEGIN } |
| |
|
| | set ::xConflict [list] |
| | list [catch {sqlite3changeset_apply db $::cc xConflict} msg] $msg |
| | } $A($conflictret,$trans) |
| |
|
| | do_test 1.2.$tn.2 { set ::xConflict } $conflictargs |
| |
|
| | set A(OMIT,0) {1 1} |
| | set A(OMIT,1) {1 1} |
| | set A(ABORT,0) {0 0} |
| | set A(ABORT,1) {0 0} |
| |
|
| | do_test 1.2.$tn.3 { |
| | execsql { SELECT count(*) FROM c1 UNION ALL SELECT count(*) FROM c2 } |
| | } $A($conflictret,$trans) |
| |
|
| | do_test 1.2.$tn.4 { expr ![sqlite3_get_autocommit db] } $trans |
| | do_test 1.2.$tn.5 { |
| | if { $trans && $conflictret=="ABORT" } { execsql COMMIT } |
| | } {} |
| | catchsql ROLLBACK |
| | } |
| |
|
| | |
| | |
| | |
| | foreach {tn open noclose close} { |
| | 1 BEGIN {} COMMIT |
| | 2 BEGIN {} ROLLBACK |
| |
|
| | 3 {SAVEPOINT one} {} {RELEASE one} |
| | 4 {SAVEPOINT one} {ROLLBACK TO one} {RELEASE one} |
| | } { |
| | execsql $open |
| | do_execsql_test 2.$tn.1 { PRAGMA defer_foreign_keys } {0} |
| |
|
| | do_execsql_test 2.$tn.2 { |
| | PRAGMA defer_foreign_keys = 1; |
| | PRAGMA defer_foreign_keys; |
| | } {1} |
| |
|
| | execsql $noclose |
| | do_execsql_test 2.$tn.3 { PRAGMA defer_foreign_keys } {1} |
| |
|
| | execsql $close |
| | do_execsql_test 2.$tn.4 { PRAGMA defer_foreign_keys } {0} |
| | } |
| |
|
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | drop_all_tables |
| |
|
| | do_execsql_test 3.1 { |
| | CREATE TABLE t1(a PRIMARY KEY, b); |
| | CREATE TABLE t2(x PRIMARY KEY, y); |
| | } |
| |
|
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | do_test 3.2 { |
| | set cc1 [capture_changeset { |
| | INSERT INTO t1 VALUES('one', 'value one'); |
| | }] |
| | set ccdel1 [capture_changeset { DELETE FROM t1; }] |
| | set cc2 [capture_changeset { |
| | INSERT INTO t2 VALUES('value one', 'one'); |
| | }] |
| | set ccdel2 [capture_changeset { DELETE FROM t2; }] |
| | set cc [capture_changeset { |
| | INSERT INTO t1 VALUES('one', 'value one'); |
| | INSERT INTO t2 VALUES('value one', 'one'); |
| | }] |
| | set ccdel [capture_changeset { |
| | DELETE FROM t1; |
| | DELETE FROM t2; |
| | }] |
| | set {} {} |
| | } {} |
| |
|
| | |
| | |
| | |
| | |
| | |
| | do_test 3.3 { |
| |
|
| | drop_all_tables |
| | execsql { |
| | CREATE TABLE t1(a PRIMARY KEY, b REFERENCES t2); |
| | CREATE TABLE t2(x PRIMARY KEY, y REFERENCES t1); |
| | } |
| |
|
| |
|
| | proc conflict_handler {args} { return "ABORT" } |
| | sqlite3changeset_apply db $cc conflict_handler |
| |
|
| | execsql { |
| | SELECT * FROM t1; |
| | SELECT * FROM t2; |
| | } |
| | } {one {value one} {value one} one} |
| |
|
| | do_test 3.3.1 { |
| | list [catch {sqlite3changeset_apply db $::ccdel1 conflict_handler} msg] $msg |
| | } {1 SQLITE_CONSTRAINT} |
| |
|
| | do_test 3.3.2 { |
| | list [catch {sqlite3changeset_apply db $::ccdel2 conflict_handler} msg] $msg |
| | } {1 SQLITE_CONSTRAINT} |
| |
|
| | do_test 3.3.4.1 { |
| | list [catch {sqlite3changeset_apply db $::ccdel conflict_handler} msg] $msg |
| | } {0 {}} |
| | do_execsql_test 3.3.4.2 { |
| | SELECT * FROM t1; |
| | SELECT * FROM t2; |
| | } {} |
| |
|
| | do_test 3.5.1 { |
| | list [catch {sqlite3changeset_apply db $::cc1 conflict_handler} msg] $msg |
| | } {1 SQLITE_CONSTRAINT} |
| | do_test 3.5.2 { |
| | list [catch {sqlite3changeset_apply db $::cc2 conflict_handler} msg] $msg |
| | } {1 SQLITE_CONSTRAINT} |
| |
|
| | |
| | |
| | |
| | |
| | |
| | drop_all_tables |
| | do_execsql_test 4.1 { |
| | CREATE TABLE p1(x PRIMARY KEY, y); |
| | CREATE TABLE c1(a PRIMARY KEY, b REFERENCES p1); |
| | INSERT INTO p1 VALUES(1,1); |
| | } |
| |
|
| | do_execsql_test 4.2.1 { |
| | BEGIN; |
| | PRAGMA defer_foreign_keys = 1; |
| | INSERT INTO c1 VALUES('x', 'x'); |
| | } |
| | do_catchsql_test 4.2.2 { COMMIT } {1 {FOREIGN KEY constraint failed}} |
| | do_catchsql_test 4.2.3 { ROLLBACK } {0 {}} |
| |
|
| | do_execsql_test 4.3.1 { |
| | BEGIN; |
| | PRAGMA defer_foreign_keys = 1; |
| | INSERT INTO c1 VALUES(1, 1); |
| | } |
| | do_catchsql_test 4.3.2 { |
| | INSERT INTO c1 VALUES(1, 'x') |
| | } {1 {UNIQUE constraint failed: c1.a}} |
| |
|
| | do_catchsql_test 4.3.3 { COMMIT } {0 {}} |
| | do_catchsql_test 4.3.4 { BEGIN ; COMMIT } {0 {}} |
| |
|
| | |
| | |
| | |
| | |
| |
|
| | drop_all_tables |
| | reset_db |
| | do_execsql_test 5.1 { |
| | CREATE TABLE x1(x PRIMARY KEY, y); |
| | CREATE TABLE x2(x PRIMARY KEY, y); |
| | INSERT INTO x2 VALUES(1, 1); |
| | INSERT INTO x1 VALUES(1, 1); |
| | } |
| |
|
| | set ::cc [changeset_from_sql { DELETE FROM x1; }] |
| |
|
| | do_execsql_test 5.2 { |
| | INSERT INTO x1 VALUES(1, 1); |
| | CREATE TRIGGER tr1 AFTER DELETE ON x1 BEGIN |
| | INSERT INTO x2 VALUES(old.x, old.y); |
| | END; |
| | } {} |
| |
|
| | proc conflict_handler {args} { return "ABORT" } |
| | do_test 5.3 { |
| | list [catch {sqlite3changeset_apply db $::cc conflict_handler} msg] $msg |
| | } {1 SQLITE_ABORT} |
| |
|
| | do_execsql_test 5.4 { |
| | SELECT * FROM X1; |
| | } {1 1} |
| |
|
| | |
| | reset_db |
| | do_execsql_test 6.0 { |
| | CREATE TABLE p1(a INTEGER PRIMARY KEY, b); |
| | CREATE TABLE c1(x INTEGER PRIMARY KEY, y REFERENCES p1); |
| | } |
| |
|
| | set ::cc [changeset_from_sql { |
| | INSERT INTO c1 VALUES(10, 20); |
| | }] |
| |
|
| | forcedelete test.db2 |
| | sqlite3 db2 test.db2 |
| | do_execsql_test -db db2 6.1 { |
| | CREATE TABLE c1(x INTEGER PRIMARY KEY, y REFERENCES p1); |
| | PRAGMA foreign_keys = ON; |
| | PRAGMA foreign_keys; |
| | } {1} |
| |
|
| | proc conflict_handler {args} { |
| | puts $args |
| | return "OMIT" |
| | } |
| |
|
| | do_test 6.2 { |
| | list [catch {sqlite3changeset_apply_v2 db2 $::cc conflict_handler} msg] $msg |
| | } {1 SQLITE_ERROR} |
| |
|
| | do_test 6.3.1 { sqlite3_errmsg db2 } {no such table: main.p1} |
| | do_test 6.3.2 { sqlite3_errcode db2 } {SQLITE_ERROR} |
| |
|
| | do_test 6.4 { |
| | catchsql { INSERT INTO c1 VALUES(100, 200) } db2 |
| | } {1 {no such table: main.p1}} |
| |
|
| | finish_test |
| |
|