1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
use lib 't';
BEGIN {
# to handle systems with no installed Test module
# we include the t dir (where a copy of Test.pm is located)
# as a fallback
eval { require Test; };
use Test;
use DBStagTest;
plan tests => 2;
}
use DBIx::DBStag;
use DBI;
use Data::Stag;
use FileHandle;
drop(qw( person address));
my $ddl = <<EOM
CREATE TABLE address (
address_id serial NOT NULL PRIMARY KEY,
addressline varchar(255),
city VARCHAR(255)
);
CREATE TABLE person (
person_id serial NOT NULL PRIMARY KEY,
fname varchar(255),
lname varchar(255),
address_id integer REFERENCES address(address_id) ON DELETE CASCADE,
UNIQUE (fname, lname)
);
EOM
;
my $data = <<EOM
(personset
(person
(fname "joe")
(lname "bloggs")
(address
(addressline "1 a street")
(city "san francisco")))
(person
(fname "fred")
(lname "minger")
(address
(addressline "5555 bogging avenue")
(city "LA"))))
EOM
;
my $dbh = dbh();
#DBI->trace(1);
$dbh->do($ddl);
$dbh->mapping([
Data::Stag->from('sxprstr',
'(map (table "person") (col "address_id") (fktable "address") (fkcol "address_id"))')
]);
my $personset = Data::Stag->from('sxprstr', $data);
my @persons = $personset->getnode_person;
foreach (@persons) {
$dbh->storenode($_);
}
our $NEW_ADDRESS = "some new address";
my $rset = $dbh->selectall_stag("SELECT * FROM person NATURAL JOIN address WHERE fname = 'joe'",
);
print $rset->sxpr;
my $joe = $rset->getnode_person;
my $OLD_ADDRESS = $joe->sgetnode_address->sget_addressline;
$joe->sgetnode_address->set_addressline($NEW_ADDRESS);
$dbh->storenode($joe);
$rset = $dbh->selectall_stag("SELECT * FROM person NATURAL JOIN address WHERE fname = 'joe'",
);
$joe = $rset->getnode_person;
ok($joe->sgetnode_address->sget_addressline eq $NEW_ADDRESS);
$joe->unset_person_id;
$joe->sgetnode_address->set_addressline($OLD_ADDRESS);
$dbh->storenode($joe);
$rset = $dbh->selectall_stag("SELECT * FROM person NATURAL JOIN address WHERE fname = 'joe'",
);
$joe = $rset->getnode_person;
ok($joe->sgetnode_address->sget_addressline eq $OLD_ADDRESS);
$dbh->disconnect;
|
