summaryrefslogtreecommitdiff
path: root/odb-tests/common/section/polymorphism
diff options
context:
space:
mode:
Diffstat (limited to 'odb-tests/common/section/polymorphism')
-rw-r--r--odb-tests/common/section/polymorphism/buildfile41
-rw-r--r--odb-tests/common/section/polymorphism/driver.cxx1807
-rw-r--r--odb-tests/common/section/polymorphism/test.hxx542
-rw-r--r--odb-tests/common/section/polymorphism/testscript33
4 files changed, 2423 insertions, 0 deletions
diff --git a/odb-tests/common/section/polymorphism/buildfile b/odb-tests/common/section/polymorphism/buildfile
new file mode 100644
index 0000000..b9a7514
--- /dev/null
+++ b/odb-tests/common/section/polymorphism/buildfile
@@ -0,0 +1,41 @@
+# file : common/section/polymorphism/buildfile
+# license : GNU GPL v2; see accompanying LICENSE file
+
+import libodb = libodb%lib{odb}
+
+libs =
+
+for db: $databases
+ import libs += libodb-$db%lib{odb-$db}
+
+import libs += lib{common}
+
+exe{driver}: {hxx cxx}{* -*-odb -*-odb-*} {hxx ixx cxx}{test-odb} testscript
+
+# Introduce the metadata library target to make sure the libodb library is
+# resolved for the odb_compile ad hoc rule (see build/root.build for details).
+#
+libue{test-meta}: $libodb
+
+<{hxx ixx cxx}{test-odb}>: hxx{test} libue{test-meta}
+
+for db: $databases
+{
+ exe{driver}: {hxx ixx cxx}{test-odb-$db}: include = $multi
+ <{hxx ixx cxx}{test-odb-$db}>: hxx{test} libue{test-meta}
+}
+
+exe{driver}: libue{test-meta} $libs
+
+# Specify the ODB custom options to be used by the odb_compile ad hoc rule
+# (see build/root.build for details).
+#
+odb_options = --table-prefix t_section_p_ \
+ --generate-schema \
+ --generate-query
+
+cxx.poptions =+ "-I$out_base" "-I$src_base"
+
+# Testscript's run-time prerequisites.
+#
+exe{driver}: ../../../alias{database-client}: include = adhoc
diff --git a/odb-tests/common/section/polymorphism/driver.cxx b/odb-tests/common/section/polymorphism/driver.cxx
new file mode 100644
index 0000000..c15d317
--- /dev/null
+++ b/odb-tests/common/section/polymorphism/driver.cxx
@@ -0,0 +1,1807 @@
+// file : common/section/polymorphism/driver.cxx
+// license : GNU GPL v2; see accompanying LICENSE file
+
+// Test sections in polymorphic objects.
+//
+
+#include <memory> // std::unique_ptr
+#include <iostream>
+
+#include <odb/session.hxx>
+#include <odb/database.hxx>
+#include <odb/transaction.hxx>
+
+#include <libcommon/common.hxx>
+
+#include "test.hxx"
+#include "test-odb.hxx"
+
+#undef NDEBUG
+#include <cassert>
+
+using namespace std;
+using namespace odb::core;
+
+struct failed {};
+
+int
+main (int argc, char* argv[])
+{
+ try
+ {
+ unique_ptr<database> db (create_database (argc, argv));
+
+ // Test basic polymorphic section functionality.
+ //
+ {
+ using namespace test1;
+
+ base b (123, "abc");
+ derived d (234, "bcd", true);
+
+ {
+ transaction t (db->begin ());
+ db->persist (b);
+ db->persist (d);
+ t.commit ();
+
+ assert (b.rs1.loaded ());
+ assert (b.rs2.loaded ());
+ assert (b.rs3.loaded ());
+ assert (b.rs4.loaded ());
+ assert (b.bs1.loaded ());
+
+ assert (d.rs1.loaded ());
+ assert (d.rs2.loaded ());
+ assert (d.rs3.loaded ());
+ assert (d.rs4.loaded ());
+ assert (d.bs1.loaded ());
+ assert (d.ds1.loaded ());
+ }
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<base> pb (db->load<base> (b.id));
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ assert (!pb->rs1.loaded ());
+ assert (!pb->rs2.loaded ());
+ assert (!pb->rs3.loaded ());
+ assert (!pb->rs4.loaded ());
+ assert (!pb->bs1.loaded ());
+
+ assert (!pd->rs1.loaded ());
+ assert (!pd->rs2.loaded ());
+ assert (!pd->rs3.loaded ());
+ assert (!pd->rs4.loaded ());
+ assert (!pd->bs1.loaded ());
+ assert (!pd->ds1.loaded ());
+
+ assert (pb->rs1n != b.rs1n && pb->rs1s != b.rs1s &&
+ pb->rs2n != b.rs2n && pb->rs2v != b.rs2v &&
+ pb->rs3v != b.rs3v &&
+ pb->rs4n != b.rs4n &&
+ pb->bs1n != b.bs1n);
+
+ assert (pd->rs1n != d.rs1n && pd->rs1s != d.rs1s &&
+ pd->rs1b != d.rs1b && pd->rs1v != d.rs1v &&
+ pd->rs2n != d.rs2n && pd->rs2v != d.rs2v &&
+ pd->rs3v != d.rs3v && pd->rs3n != d.rs3n &&
+ pd->rs4n != d.rs4n && pd->rs4s != d.rs4s &&
+ pd->bs1n != d.bs1n && pd->bs1s != d.bs1s &&
+ pd->ds1n != d.ds1n);
+
+ db->load (*pb, pb->rs1);
+ db->load (*pb, pb->rs2);
+ db->load (*pb, pb->rs3);
+ db->load (*pb, pb->rs4);
+ db->load (*pb, pb->bs1);
+
+ root* pr (pd.get ());
+ db->load (*pr, pr->rs1); // Via base.
+ db->load (*pd, pd->rs2);
+ db->load (*pr, pr->rs3); // Via base.
+ db->load (*pd, pd->rs4);
+ db->load (*pd, pd->bs1);
+ db->load (*pd, pd->ds1);
+
+ try
+ {
+ db->load (*pr, pd->bs1); // Object-section association is static.
+ assert (false);
+ }
+ catch (const section_not_in_object&) {}
+
+ assert (pb->rs1.loaded ());
+ assert (pb->rs2.loaded ());
+ assert (pb->rs3.loaded ());
+ assert (pb->rs4.loaded ());
+ assert (pb->bs1.loaded ());
+
+ assert (pd->rs1.loaded ());
+ assert (pd->rs2.loaded ());
+ assert (pd->rs3.loaded ());
+ assert (pd->rs4.loaded ());
+ assert (pd->bs1.loaded ());
+ assert (pd->ds1.loaded ());
+
+ assert (pb->rs1n == b.rs1n && pb->rs1s == b.rs1s &&
+ pb->rs2n == b.rs2n && pb->rs2v == b.rs2v &&
+ pb->rs3v == b.rs3v &&
+ pb->rs4n == b.rs4n &&
+ pb->bs1n == b.bs1n);
+
+ assert (pd->rs1n == d.rs1n && pd->rs1s == d.rs1s &&
+ pd->rs1b == d.rs1b && pd->rs1v == d.rs1v &&
+ pd->rs2n == d.rs2n && pd->rs2v == d.rs2v &&
+ pd->rs3v == d.rs3v && pd->rs3n == d.rs3n &&
+ pd->rs4n == d.rs4n && pd->rs4s == d.rs4s &&
+ pd->bs1n == d.bs1n && pd->bs1s == d.bs1s &&
+ pd->ds1n == d.ds1n);
+ t.commit ();
+ }
+
+ // Update object.
+ //
+ b.rs1n++;
+ b.rs1s += 'd';
+ b.rs1.change ();
+ b.rs2n++;
+ b.rs2v[0]++;
+ b.rs3v[0]++;
+ b.rs4n++;
+ b.bs1n++;
+
+ d.rs1n++;
+ d.rs1s += 'e';
+ d.rs1b = !d.rs1b;
+ d.rs1v[0]++;
+ d.rs1.change ();
+ d.rs2n++;
+ d.rs2v[0]++;
+ d.rs3v[0]++;
+ d.rs3n++;
+ d.rs4n++;
+ d.rs4s += 'e';
+ d.bs1n++;
+ d.bs1s += 'e';
+ d.ds1n++;
+
+ {
+ transaction t (db->begin ());
+ db->update (b);
+ db->update (d);
+ t.commit ();
+
+ assert (!b.rs1.changed ());
+ assert (!d.rs1.changed ());
+ }
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<base> pb (db->load<base> (b.id));
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->load (*pb, pb->rs1);
+ db->load (*pb, pb->rs2);
+ db->load (*pb, pb->rs3);
+ db->load (*pb, pb->rs4);
+ db->load (*pb, pb->bs1);
+
+ db->load (*pd, pd->rs1);
+ db->load (*pd, pd->rs2);
+ db->load (*pd, pd->rs3);
+ db->load (*pd, pd->rs4);
+ db->load (*pd, pd->bs1);
+ db->load (*pd, pd->ds1);
+
+ assert (pb->rs1n == b.rs1n && pb->rs1s == b.rs1s &&
+ pb->rs2n == b.rs2n && pb->rs2v == b.rs2v &&
+ pb->rs3v == b.rs3v &&
+ pb->rs4n == b.rs4n &&
+ pb->bs1n == b.bs1n);
+
+ assert (pd->rs1n == d.rs1n && pd->rs1s == d.rs1s &&
+ pd->rs1b == d.rs1b && pd->rs1v == d.rs1v &&
+ pd->rs2n == d.rs2n && pd->rs2v == d.rs2v &&
+ pd->rs3v == d.rs3v && pd->rs3n == d.rs3n &&
+ pd->rs4n == d.rs4n && pd->rs4s == d.rs4s &&
+ pd->bs1n == d.bs1n && pd->bs1s == d.bs1s &&
+ pd->ds1n == d.ds1n);
+ t.commit ();
+ }
+
+ // Update section.
+ //
+ b.rs1n++;
+ b.rs1s += 'd';
+ b.rs2n++;
+ b.rs2v[0]++;
+ b.rs3v[0]++;
+ b.rs4n++;
+ b.bs1n++;
+
+ d.rs1n++;
+ d.rs1s += 'e';
+ d.rs1b = !d.rs1b;
+ d.rs1v[0]++;
+ d.rs2n++;
+ d.rs2v[0]++;
+ d.rs3v[0]++;
+ d.rs3n++;
+ d.rs4n++;
+ d.rs4s += 'e';
+ d.bs1n++;
+ d.bs1s += 'e';
+ d.ds1n++;
+
+ {
+ transaction t (db->begin ());
+ db->update (b, b.rs1);
+ db->update (b, b.rs2);
+ db->update (b, b.rs3);
+ db->update (b, b.rs4);
+ db->update (b, b.bs1);
+
+ db->update (d, d.rs1);
+ db->update (d, d.rs2);
+ db->update (d, d.rs3);
+ db->update (d, d.rs4);
+ db->update (d, d.bs1);
+ db->update (d, d.ds1);
+ t.commit ();
+ }
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<base> pb (db->load<base> (b.id));
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->load (*pb, pb->rs1);
+ db->load (*pb, pb->rs2);
+ db->load (*pb, pb->rs3);
+ db->load (*pb, pb->rs4);
+ db->load (*pb, pb->bs1);
+
+ db->load (*pd, pd->rs1);
+ db->load (*pd, pd->rs2);
+ db->load (*pd, pd->rs3);
+ db->load (*pd, pd->rs4);
+ db->load (*pd, pd->bs1);
+ db->load (*pd, pd->ds1);
+
+ assert (pb->rs1n == b.rs1n && pb->rs1s == b.rs1s &&
+ pb->rs2n == b.rs2n && pb->rs2v == b.rs2v &&
+ pb->rs3v == b.rs3v &&
+ pb->rs4n == b.rs4n &&
+ pb->bs1n == b.bs1n);
+
+ assert (pd->rs1n == d.rs1n && pd->rs1s == d.rs1s &&
+ pd->rs1b == d.rs1b && pd->rs1v == d.rs1v &&
+ pd->rs2n == d.rs2n && pd->rs2v == d.rs2v &&
+ pd->rs3v == d.rs3v && pd->rs3n == d.rs3n &&
+ pd->rs4n == d.rs4n && pd->rs4s == d.rs4s &&
+ pd->bs1n == d.bs1n && pd->bs1s == d.bs1s &&
+ pd->ds1n == d.ds1n);
+ t.commit ();
+ }
+
+ // Reload.
+ //
+ b.rs1n++;
+ b.rs1s += 'd';
+ b.rs1.change ();
+ b.rs2n++;
+ b.rs2v[0]++;
+ b.rs3v[0]++;
+ b.rs4n++;
+ b.bs1n++;
+
+ d.rs1n++;
+ d.rs1s += 'e';
+ d.rs1b = !d.rs1b;
+ d.rs1v[0]++;
+ d.rs1.change ();
+ d.rs2n++;
+ d.rs2v[0]++;
+ d.rs3v[0]++;
+ d.rs3n++;
+ d.rs4n++;
+ d.rs4s += 'e';
+ d.bs1n++;
+ d.bs1s += 'e';
+ d.ds1n++;
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<base> pb (db->load<base> (b.id));
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->load (*pb, pb->rs1);
+ db->load (*pb, pb->rs2);
+ db->load (*pb, pb->rs3);
+ db->load (*pb, pb->rs4);
+ db->load (*pb, pb->bs1);
+
+ db->load (*pd, pd->rs1);
+ db->load (*pd, pd->rs2);
+ db->load (*pd, pd->rs3);
+ db->load (*pd, pd->rs4);
+ db->load (*pd, pd->bs1);
+ db->load (*pd, pd->ds1);
+
+ db->update (b);
+ db->update (d);
+
+ db->reload (*pb);
+ db->reload (*pd);
+
+ assert (pb->rs1n == b.rs1n && pb->rs1s == b.rs1s &&
+ pb->rs2n == b.rs2n && pb->rs2v == b.rs2v &&
+ pb->rs3v == b.rs3v &&
+ pb->rs4n == b.rs4n &&
+ pb->bs1n == b.bs1n);
+
+ assert (pd->rs1n == d.rs1n && pd->rs1s == d.rs1s &&
+ pd->rs1b == d.rs1b && pd->rs1v == d.rs1v &&
+ pd->rs2n == d.rs2n && pd->rs2v == d.rs2v &&
+ pd->rs3v == d.rs3v && pd->rs3n == d.rs3n &&
+ pd->rs4n == d.rs4n && pd->rs4s == d.rs4s &&
+ pd->bs1n == d.bs1n && pd->bs1s == d.bs1s &&
+ pd->ds1n == d.ds1n);
+
+ t.commit ();
+ }
+ }
+
+ // Test empty section and override "gap".
+ //
+ {
+ using namespace test2;
+
+ derived d (234);
+
+ {
+ transaction t (db->begin ());
+ db->persist (d);
+ t.commit ();
+
+ assert (d.s.loaded ());
+ }
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ assert (!pd->s.loaded ());
+ assert (pd->sn != d.sn && pd->sv != d.sv);
+
+ root* pr (pd.get ());
+ db->load (*pr, pr->s); // Via root.
+
+ assert (pd->s.loaded ());
+ assert (pd->sn == d.sn && pd->sv == d.sv);
+ t.commit ();
+ }
+
+ // Update object.
+ //
+ d.sn++;
+ d.sv[0]++;
+
+ {
+ transaction t (db->begin ());
+ root* pr (&d);
+ db->update (pr); // Via root.
+ t.commit ();
+ }
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ base* pb (pd.get ());
+ db->load (*pb, pb->s); // Via base.
+
+ assert (pd->sn == d.sn && pd->sv == d.sv);
+ t.commit ();
+ }
+
+ // Update section.
+ //
+ d.sn++;
+ d.sv[0]++;
+
+ {
+ transaction t (db->begin ());
+ root* pr (&d);
+ db->update (*pr, pr->s); // Via root.
+ t.commit ();
+ }
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->load (*pd, pd->s);
+
+ assert (pd->sn == d.sn && pd->sv == d.sv);
+ t.commit ();
+ }
+
+ // Reload.
+ //
+ d.sn++;
+ d.sv[0]++;
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->load (*pd, pd->s);
+
+ db->update (d);
+
+ root* pr (pd.get ());
+ db->reload (*pr);
+
+ assert (pd->sn == d.sn && pd->sv == d.sv);
+ t.commit ();
+ }
+ }
+
+ // Test value-only/container-only base/override combinations.
+ //
+ {
+ using namespace test3;
+
+ root r (123);
+ base b (234);
+ derived d (345, "abc");
+
+ {
+ transaction t (db->begin ());
+ db->persist (r);
+ db->persist (b);
+ db->persist (d);
+ t.commit ();
+
+ assert (r.s1.loaded ());
+ assert (r.s2.loaded ());
+ assert (r.s3.loaded ());
+ assert (r.s4.loaded ());
+
+ assert (b.s1.loaded ());
+ assert (b.s2.loaded ());
+ assert (b.s3.loaded ());
+ assert (b.s4.loaded ());
+
+ assert (d.s1.loaded ());
+ assert (d.s2.loaded ());
+ assert (d.s3.loaded ());
+ assert (d.s4.loaded ());
+ }
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<root> pr (db->load<root> (r.id));
+ unique_ptr<base> pb (db->load<base> (b.id));
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ assert (!pr->s1.loaded ());
+ assert (!pr->s2.loaded ());
+ assert (!pr->s3.loaded ());
+ assert (!pr->s4.loaded ());
+
+ assert (!pb->s1.loaded ());
+ assert (!pb->s2.loaded ());
+ assert (!pb->s3.loaded ());
+ assert (!pb->s4.loaded ());
+
+ assert (!pd->s1.loaded ());
+ assert (!pd->s2.loaded ());
+ assert (!pd->s3.loaded ());
+ assert (!pd->s4.loaded ());
+
+ assert (pr->s1n != r.s1n &&
+ pr->s2n != r.s2n &&
+ pr->s3v != r.s3v &&
+ pr->s4nv != r.s4nv);
+
+ assert (pb->s1n != b.s1n &&
+ pb->s2n != b.s2n &&
+ pb->s3v != b.s3v &&
+ pb->s4nv != b.s4nv);
+
+ assert (pd->s1n != d.s1n && pd->s1s != d.s1s &&
+ pd->s2n != d.s2n && pd->s2v != d.s2v &&
+ pd->s3v != d.s3v && pd->s3n != d.s3n &&
+ pd->s4nv != d.s4nv && pd->s4sv != d.s4sv);
+
+ db->load (*pr, pr->s1);
+ db->load (*pr, pr->s2);
+ db->load (*pr, pr->s3);
+ db->load (*pr, pr->s4);
+
+ db->load (*pb, pb->s1);
+ db->load (*pb, pb->s2);
+ db->load (*pb, pb->s3);
+ db->load (*pb, pb->s4);
+
+ root* pdr (pd.get ());
+ db->load (*pdr, pdr->s1);
+ db->load (*pdr, pdr->s2);
+ db->load (*pdr, pdr->s3);
+ db->load (*pdr, pdr->s4);
+
+ assert (pr->s1.loaded ());
+ assert (pr->s2.loaded ());
+ assert (pr->s3.loaded ());
+ assert (pr->s4.loaded ());
+
+ assert (pb->s1.loaded ());
+ assert (pb->s2.loaded ());
+ assert (pb->s3.loaded ());
+ assert (pb->s4.loaded ());
+
+ assert (pd->s1.loaded ());
+ assert (pd->s2.loaded ());
+ assert (pd->s3.loaded ());
+ assert (pd->s4.loaded ());
+
+ assert (pr->s1n == r.s1n &&
+ pr->s2n == r.s2n &&
+ pr->s3v == r.s3v &&
+ pr->s4nv == r.s4nv);
+
+ assert (pb->s1n == b.s1n &&
+ pb->s2n == b.s2n &&
+ pb->s3v == b.s3v &&
+ pb->s4nv == b.s4nv);
+
+ assert (pd->s1n == d.s1n && pd->s1s == d.s1s &&
+ pd->s2n == d.s2n && pd->s2v == d.s2v &&
+ pd->s3v == d.s3v && pd->s3n == d.s3n &&
+ pd->s4nv == d.s4nv && pd->s4sv == d.s4sv);
+ t.commit ();
+ }
+
+ // Update object.
+ //
+ r.s1n++;
+ r.s2n++;
+ r.s3v[0]++;
+ r.s4nv[0]++;
+
+ b.s1n++;
+ b.s2n++;
+ b.s3v[0]++;
+ b.s4nv[0]++;
+
+ d.s1n++;
+ d.s1s += 'd';
+ d.s2n++;
+ d.s2v[0]++;
+ d.s3v[0]++;
+ d.s3n++;
+ d.s4nv[0]++;
+ d.s4sv[0] += 'd';
+
+ {
+ transaction t (db->begin ());
+ db->update (r);
+ db->update (b);
+ db->update (d);
+ t.commit ();
+ }
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<root> pr (db->load<root> (r.id));
+ unique_ptr<base> pb (db->load<base> (b.id));
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->load (*pr, pr->s1);
+ db->load (*pr, pr->s2);
+ db->load (*pr, pr->s3);
+ db->load (*pr, pr->s4);
+
+ db->load (*pb, pb->s1);
+ db->load (*pb, pb->s2);
+ db->load (*pb, pb->s3);
+ db->load (*pb, pb->s4);
+
+ db->load (*pd, pd->s1);
+ db->load (*pd, pd->s2);
+ db->load (*pd, pd->s3);
+ db->load (*pd, pd->s4);
+
+ assert (pr->s1n == r.s1n &&
+ pr->s2n == r.s2n &&
+ pr->s3v == r.s3v &&
+ pr->s4nv == r.s4nv);
+
+ assert (pb->s1n == b.s1n &&
+ pb->s2n == b.s2n &&
+ pb->s3v == b.s3v &&
+ pb->s4nv == b.s4nv);
+
+ assert (pd->s1n == d.s1n && pd->s1s == d.s1s &&
+ pd->s2n == d.s2n && pd->s2v == d.s2v &&
+ pd->s3v == d.s3v && pd->s3n == d.s3n &&
+ pd->s4nv == d.s4nv && pd->s4sv == d.s4sv);
+ t.commit ();
+ }
+
+ // Update section.
+ //
+ r.s1n++;
+ r.s2n++;
+ r.s3v[0]++;
+ r.s4nv[0]++;
+
+ b.s1n++;
+ b.s2n++;
+ b.s3v[0]++;
+ b.s4nv[0]++;
+
+ d.s1n++;
+ d.s1s += 'd';
+ d.s2n++;
+ d.s2v[0]++;
+ d.s3v[0]++;
+ d.s3n++;
+ d.s4nv[0]++;
+ d.s4sv[0] += 'd';
+
+ {
+ transaction t (db->begin ());
+ db->update (r, r.s1);
+ db->update (r, r.s2);
+ db->update (r, r.s3);
+ db->update (r, r.s4);
+
+ db->update (b, b.s1);
+ db->update (b, b.s2);
+ db->update (b, b.s3);
+ db->update (b, b.s4);
+
+ root& rr (d);
+ db->update (rr, rr.s1);
+ db->update (rr, rr.s2);
+ db->update (rr, rr.s3);
+ db->update (rr, rr.s4);
+ t.commit ();
+ }
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<root> pr (db->load<root> (r.id));
+ unique_ptr<base> pb (db->load<base> (b.id));
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->load (*pr, pr->s1);
+ db->load (*pr, pr->s2);
+ db->load (*pr, pr->s3);
+ db->load (*pr, pr->s4);
+
+ db->load (*pb, pb->s1);
+ db->load (*pb, pb->s2);
+ db->load (*pb, pb->s3);
+ db->load (*pb, pb->s4);
+
+ db->load (*pd, pd->s1);
+ db->load (*pd, pd->s2);
+ db->load (*pd, pd->s3);
+ db->load (*pd, pd->s4);
+
+ assert (pr->s1n == r.s1n &&
+ pr->s2n == r.s2n &&
+ pr->s3v == r.s3v &&
+ pr->s4nv == r.s4nv);
+
+ assert (pb->s1n == b.s1n &&
+ pb->s2n == b.s2n &&
+ pb->s3v == b.s3v &&
+ pb->s4nv == b.s4nv);
+
+ assert (pd->s1n == d.s1n && pd->s1s == d.s1s &&
+ pd->s2n == d.s2n && pd->s2v == d.s2v &&
+ pd->s3v == d.s3v && pd->s3n == d.s3n &&
+ pd->s4nv == d.s4nv && pd->s4sv == d.s4sv);
+ t.commit ();
+ }
+
+ // Reload.
+ //
+ r.s1n++;
+ r.s2n++;
+ r.s3v[0]++;
+ r.s4nv[0]++;
+
+ b.s1n++;
+ b.s2n++;
+ b.s3v[0]++;
+ b.s4nv[0]++;
+
+ d.s1n++;
+ d.s1s += 'd';
+ d.s2n++;
+ d.s2v[0]++;
+ d.s3v[0]++;
+ d.s3n++;
+ d.s4nv[0]++;
+ d.s4sv[0] += 'd';
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<root> pr (db->load<root> (r.id));
+ unique_ptr<base> pb (db->load<base> (b.id));
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->load (*pr, pr->s1);
+ db->load (*pr, pr->s2);
+ db->load (*pr, pr->s3);
+ db->load (*pr, pr->s4);
+
+ db->load (*pb, pb->s1);
+ db->load (*pb, pb->s2);
+ db->load (*pb, pb->s3);
+ db->load (*pb, pb->s4);
+
+ db->load (*pd, pd->s1);
+ db->load (*pd, pd->s2);
+ db->load (*pd, pd->s3);
+ db->load (*pd, pd->s4);
+
+ db->update (r);
+ db->update (b);
+ db->update (d);
+
+ db->reload (*pr);
+ db->reload (*pb);
+ db->reload (*pd);
+
+ assert (pr->s1n == r.s1n &&
+ pr->s2n == r.s2n &&
+ pr->s3v == r.s3v &&
+ pr->s4nv == r.s4nv);
+
+ assert (pb->s1n == b.s1n &&
+ pb->s2n == b.s2n &&
+ pb->s3v == b.s3v &&
+ pb->s4nv == b.s4nv);
+
+ assert (pd->s1n == d.s1n && pd->s1s == d.s1s &&
+ pd->s2n == d.s2n && pd->s2v == d.s2v &&
+ pd->s3v == d.s3v && pd->s3n == d.s3n &&
+ pd->s4nv == d.s4nv && pd->s4sv == d.s4sv);
+ t.commit ();
+ }
+ }
+
+ // Test basic polymorphic optimistic section functionality.
+ //
+ {
+ using namespace test4;
+
+ base b (123, "abc");
+ derived d (234, "bcd", true);
+
+ {
+ transaction t (db->begin ());
+ db->persist (b);
+ db->persist (d);
+ t.commit ();
+
+ assert (b.rs1.loaded ());
+ assert (b.rs2.loaded ());
+ assert (b.rs3.loaded ());
+ assert (b.rs4.loaded ());
+ assert (b.bs1.loaded ());
+
+ assert (d.rs1.loaded ());
+ assert (d.rs2.loaded ());
+ assert (d.rs3.loaded ());
+ assert (d.rs4.loaded ());
+ assert (d.bs1.loaded ());
+ assert (d.ds1.loaded ());
+ }
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<base> pb (db->load<base> (b.id));
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ assert (!pb->rs1.loaded ());
+ assert (!pb->rs2.loaded ());
+ assert (!pb->rs3.loaded ());
+ assert (!pb->rs4.loaded ());
+ assert (!pb->bs1.loaded ());
+
+ assert (!pd->rs1.loaded ());
+ assert (!pd->rs2.loaded ());
+ assert (!pd->rs3.loaded ());
+ assert (!pd->rs4.loaded ());
+ assert (!pd->bs1.loaded ());
+ assert (!pd->ds1.loaded ());
+
+ assert (pb->rs1n != b.rs1n && pb->rs1s != b.rs1s &&
+ pb->rs2n != b.rs2n &&
+ pb->rs3n != b.rs3n &&
+ pb->rs4n != b.rs4n && pb->rs4s != b.rs4s);
+
+ assert (pd->rs1n != d.rs1n && pd->rs1s != d.rs1s &&
+ pd->rs1b != d.rs1b && pd->rs1v != d.rs1v &&
+ pd->rs2n != d.rs2n &&
+ pd->rs3n != d.rs3n && pd->rs3s != d.rs3s &&
+ pd->rs4n != d.rs4n && pd->rs4s != d.rs4s &&
+ pd->rs4v != d.rs4v &&
+ pd->bs1n != d.bs1n &&
+ pd->ds1v != d.ds1v);
+
+ db->load (*pb, pb->rs1);
+ db->load (*pb, pb->rs2);
+ db->load (*pb, pb->rs3);
+ db->load (*pb, pb->rs4);
+ db->load (*pb, pb->bs1); // No-op.
+
+ root* pr (pd.get ());
+ db->load (*pr, pr->rs1); // Via base.
+ db->load (*pd, pd->rs2);
+ db->load (*pd, pd->rs3);
+ db->load (*pr, pr->rs4); // Via base.
+ db->load (*pd, pd->bs1);
+ db->load (*pd, pd->ds1);
+
+ assert (pb->rs1.loaded ());
+ assert (pb->rs2.loaded ());
+ assert (pb->rs3.loaded ());
+ assert (pb->rs4.loaded ());
+ assert (pb->bs1.loaded ());
+
+ assert (pd->rs1.loaded ());
+ assert (pd->rs2.loaded ());
+ assert (pd->rs3.loaded ());
+ assert (pd->rs4.loaded ());
+ assert (pd->bs1.loaded ());
+ assert (pd->ds1.loaded ());
+
+ assert (pb->rs1n == b.rs1n && pb->rs1s == b.rs1s &&
+ pb->rs2n == b.rs2n &&
+ pb->rs3n == b.rs3n &&
+ pb->rs4n == b.rs4n && pb->rs4s == b.rs4s);
+
+ assert (pd->rs1n == d.rs1n && pd->rs1s == d.rs1s &&
+ pd->rs1b == d.rs1b && pd->rs1v == d.rs1v &&
+ pd->rs2n == d.rs2n &&
+ pd->rs3n == d.rs3n && pd->rs3s == d.rs3s &&
+ pd->rs4n == d.rs4n && pd->rs4s == d.rs4s &&
+ pd->rs4v == d.rs4v &&
+ pd->bs1n == d.bs1n &&
+ pd->ds1v == d.ds1v);
+ t.commit ();
+ }
+
+ base b1 (b);
+ derived d1 (d);
+
+ // Update object.
+ //
+ for (unsigned short s (1); s < 7; ++s)
+ {
+ b1.rs1n++;
+ b1.rs1s += 'd';
+ b1.rs1.change ();
+ b1.rs4s += 'd';
+
+ d1.rs1n++;
+ d1.rs1s += 'e';
+ d1.rs1b = !d.rs1b;
+ d1.rs1v[0]++;
+ d1.rs1.change ();
+ d1.rs4s += 'e';
+ d1.rs4v[0]++;
+ d1.bs1n++;
+ d1.ds1v[0]++;
+
+ transaction t (db->begin ());
+ unique_ptr<base> pb (db->load<base> (b.id));
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->update (b1);
+ db->update (d1);
+
+ assert (!b1.rs1.changed ());
+ assert (!d1.rs1.changed ());
+
+ assert (b.v != b1.v);
+ assert (d.v != d1.v);
+
+ try
+ {
+ bool a (false);
+ switch (s)
+ {
+ case 1: db->load (*pb, pb->rs1); break;
+ case 2: db->load (*pb, pb->rs2); break;
+ case 3: db->load (*pb, pb->rs3); break;
+ case 4: db->load (*pb, pb->rs4); break;
+ case 5:
+ case 6: a = true; break; // No-op.
+ default: break;
+ }
+ assert (a);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (*pb);
+
+ assert (!pb->rs1.loaded ());
+ assert (!pb->rs2.loaded ());
+ assert (!pb->rs3.loaded ());
+ assert (!pb->rs3.loaded ());
+ assert (!pb->bs1.loaded ());
+
+ db->load (*pb, pb->rs1);
+ db->load (*pb, pb->rs2);
+ db->load (*pb, pb->rs3);
+ db->load (*pb, pb->rs4);
+ db->load (*pb, pb->bs1); // No-op.
+
+ assert (pb->rs1n == b1.rs1n && pb->rs1s == b1.rs1s &&
+ pb->rs2n == b1.rs2n &&
+ pb->rs3n == b1.rs3n &&
+ pb->rs4n == b1.rs4n && pb->rs4s == b1.rs4s);
+ }
+
+ try
+ {
+ switch (s)
+ {
+ case 1: db->load (*pd, pd->rs1); break;
+ case 2: db->load (*pd, pd->rs2); break;
+ case 3: db->load (*pd, pd->rs3); break;
+ case 4: db->load (*pd, pd->rs4); break;
+ case 5: db->load (*pd, pd->bs1); break;
+ case 6: db->load (*pd, pd->ds1); break;
+ default: break;
+ }
+ assert (false);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (*pd);
+
+ assert (!pd->rs1.loaded ());
+ assert (!pd->rs2.loaded ());
+ assert (!pd->rs3.loaded ());
+ assert (!pd->rs4.loaded ());
+ assert (!pd->bs1.loaded ());
+ assert (!pd->ds1.loaded ());
+
+ db->load (*pd, pd->rs1);
+ db->load (*pd, pd->rs2);
+ db->load (*pd, pd->rs3);
+ db->load (*pd, pd->rs4);
+ db->load (*pd, pd->bs1);
+ db->load (*pd, pd->ds1);
+
+ assert (pd->rs1n == d1.rs1n && pd->rs1s == d1.rs1s &&
+ pd->rs1b == d1.rs1b && pd->rs1v == d1.rs1v &&
+ pd->rs2n == d1.rs2n &&
+ pd->rs3n == d1.rs3n && pd->rs3s == d1.rs3s &&
+ pd->rs4n == d1.rs4n && pd->rs4s == d1.rs4s &&
+ pd->rs4v == d1.rs4v &&
+ pd->bs1n == d1.bs1n &&
+ pd->ds1v == d1.ds1v);
+ }
+
+ db->reload (b);
+ db->reload (d);
+
+ assert (b.v == b1.v);
+ assert (d.v == d1.v);
+
+ assert (b.rs1n == b1.rs1n && b.rs1s == b1.rs1s &&
+ b.rs2n == b1.rs2n &&
+ b.rs3n == b1.rs3n &&
+ b.rs4n == b1.rs4n && b.rs4s == b1.rs4s);
+
+ assert (d.rs1n == d1.rs1n && d.rs1s == d1.rs1s &&
+ d.rs1b == d1.rs1b && d.rs1v == d1.rs1v &&
+ d.rs2n == d1.rs2n &&
+ d.rs3n == d1.rs3n && d.rs3s == d1.rs3s &&
+ d.rs4n == d1.rs4n && d.rs4s == d1.rs4s &&
+ d.rs4v == d1.rs4v &&
+ d.bs1n == d1.bs1n &&
+ d.ds1v == d1.ds1v);
+
+ t.commit ();
+ }
+
+ // Update section.
+ //
+ for (unsigned short s (1); s < 7; ++s)
+ {
+ transaction t (db->begin ());
+ unique_ptr<base> pb (db->load<base> (b.id));
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ switch (s)
+ {
+ case 1:
+ b1.rs1n++;
+ b1.rs1s += 'd';
+
+ d1.rs1n++;
+ d1.rs1s += 'e';
+ d1.rs1b = !d.rs1b;
+ d1.rs1v[0]++;
+
+ db->update (b1, b1.rs1);
+ db->update (d1, d1.rs1);
+
+ assert (b.v != b1.v);
+ assert (d.v != d1.v);
+ break;
+ case 2:
+ db->update (b1, b1.rs2); // No-op.
+ db->update (d1, d1.rs2); // No-op.
+
+ assert (b.v == b1.v);
+ assert (d.v == d1.v);
+ continue; // Object hasn't changed.
+ case 3:
+ db->update (b1, b1.rs3); // No-op.
+ db->update (d1, d1.rs3); // No-op.
+
+ assert (b.v == b1.v);
+ assert (d.v == d1.v);
+ continue; // Object hasn't changed.
+ case 4:
+ b1.rs4s += 'd';
+
+ d1.rs4s += 'e';
+ d1.rs4v[0]++;
+
+ db->update (b1, b1.rs4);
+ db->update (d1, d1.rs4);
+
+ assert (b.v != b1.v);
+ assert (d.v != d1.v);
+ break;
+ case 5:
+ d1.bs1n++;
+
+ db->update (b1, b1.bs1); // No-op.
+ db->update (d1, d1.bs1);
+
+ assert (b.v == b1.v);
+ assert (d.v != d1.v);
+ break;
+ case 6:
+ d1.ds1v[0]++;
+
+ db->update (d1, d1.ds1);
+
+ assert (d.v != d1.v);
+ break;
+ default: break;
+ }
+
+ try
+ {
+ bool a (false);
+ switch (s)
+ {
+ case 1: db->load (*pb, pb->rs1); break;
+ case 4: db->load (*pb, pb->rs4); break;
+ case 5:
+ case 6: a = true; break; // No-op.
+ default: break;
+ }
+ assert (a);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (*pb);
+
+ assert (!pb->rs1.loaded ());
+ assert (!pb->rs2.loaded ());
+ assert (!pb->rs3.loaded ());
+ assert (!pb->rs4.loaded ());
+ assert (!pb->bs1.loaded ());
+
+ db->load (*pb, pb->rs1);
+ db->load (*pb, pb->rs2);
+ db->load (*pb, pb->rs3);
+ db->load (*pb, pb->rs4);
+ db->load (*pb, pb->bs1); // No-op.
+
+ assert (pb->rs1n == b1.rs1n && pb->rs1s == b1.rs1s &&
+ pb->rs2n == b1.rs2n &&
+ pb->rs3n == b1.rs3n &&
+ pb->rs4n == b1.rs4n && pb->rs4s == b1.rs4s);
+ }
+
+ try
+ {
+ switch (s)
+ {
+ case 1: db->load (*pd, pd->rs1); break;
+ case 4: db->load (*pd, pd->rs4); break;
+ case 5: db->load (*pd, pd->bs1); break;
+ case 6: db->load (*pd, pd->ds1); break;
+ default: break;
+ }
+ assert (false);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (*pd);
+
+ assert (!pd->rs1.loaded ());
+ assert (!pd->rs2.loaded ());
+ assert (!pd->rs3.loaded ());
+ assert (!pd->rs4.loaded ());
+ assert (!pd->bs1.loaded ());
+ assert (!pd->ds1.loaded ());
+
+ db->load (*pd, pd->rs1);
+ db->load (*pd, pd->rs2);
+ db->load (*pd, pd->rs3);
+ db->load (*pd, pd->rs4);
+ db->load (*pd, pd->bs1);
+ db->load (*pd, pd->ds1);
+
+ assert (pd->rs1n == d1.rs1n && pd->rs1s == d1.rs1s &&
+ pd->rs1b == d1.rs1b && pd->rs1v == d1.rs1v &&
+ pd->rs2n == d1.rs2n &&
+ pd->rs3n == d1.rs3n && pd->rs3s == d1.rs3s &&
+ pd->rs4n == d1.rs4n && pd->rs4s == d1.rs4s &&
+ pd->rs4v == d1.rs4v &&
+ pd->bs1n == d1.bs1n &&
+ pd->ds1v == d1.ds1v);
+ }
+
+ db->reload (b);
+ db->reload (d);
+
+ assert (b.v == b1.v);
+ assert (d.v == d1.v);
+
+ assert (b.rs1n == b1.rs1n && b.rs1s == b1.rs1s &&
+ b.rs2n == b1.rs2n &&
+ b.rs3n == b1.rs3n &&
+ b.rs4n == b1.rs4n && b.rs4s == b1.rs4s);
+
+ assert (d.rs1n == d1.rs1n && d.rs1s == d1.rs1s &&
+ d.rs1b == d1.rs1b && d.rs1v == d1.rs1v &&
+ d.rs2n == d1.rs2n &&
+ d.rs3n == d1.rs3n && d.rs3s == d1.rs3s &&
+ d.rs4n == d1.rs4n && d.rs4s == d1.rs4s &&
+ d.rs4v == d1.rs4v &&
+ d.bs1n == d1.bs1n &&
+ d.ds1v == d1.ds1v);
+
+ t.commit ();
+ }
+
+ // Update changed section.
+ //
+ for (unsigned short s (1); s < 7; ++s)
+ {
+ if (s == 2 || s == 3) // Readonly sections.
+ continue;
+
+ transaction t (db->begin ());
+
+ switch (s)
+ {
+ case 1:
+ b1.rs1n++;
+ b1.rs1s += 'd';
+
+ d1.rs1n++;
+ d1.rs1s += 'e';
+ d1.rs1b = !d.rs1b;
+ d1.rs1v[0]++;
+
+ db->update (b1, b1.rs1);
+ db->update (d1, d1.rs1);
+ break;
+ case 4:
+ b1.rs4s += 'd';
+
+ d1.rs4s += 'e';
+ d1.rs4v[0]++;
+
+ db->update (b1, b1.rs4);
+ db->update (d1, d1.rs4);
+ break;
+ case 5:
+ d1.bs1n++;
+
+ db->update (b1, b1.bs1); // No-op.
+ db->update (d1, d1.bs1);
+ break;
+ case 6:
+ d1.ds1v[0]++;
+
+ db->update (d1, d1.bs1);
+ break;
+ default: break;
+ }
+
+ try
+ {
+ bool a (false);
+ switch (s)
+ {
+ case 1: db->update (b, b.rs1); break;
+ case 4: db->update (b, b.rs4); break;
+ case 5:
+ case 6: a = true; break; // No-op.
+ default: break;
+ }
+ assert (a);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (b);
+
+ switch (s)
+ {
+ case 1: db->update (b, b.rs1); break;
+ case 4: db->update (b, b.rs4); break;
+ default: break;
+ }
+ }
+
+ try
+ {
+ switch (s)
+ {
+ case 1: db->update (d, d.rs1); break;
+ case 4: db->update (d, d.rs4); break;
+ case 5: db->update (d, d.bs1); break;
+ case 6: db->update (d, d.ds1); break;
+ default: break;
+ }
+ assert (false);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (d);
+
+ switch (s)
+ {
+ case 1: db->update (d, d.rs1); break;
+ case 4: db->update (d, d.rs4); break;
+ case 5: db->update (d, d.bs1); break;
+ case 6: db->update (d, d.ds1); break;
+ default: break;
+ }
+ }
+
+ db->reload (b1);
+ db->reload (d1);
+
+ t.commit ();
+ }
+ }
+
+ // Test polymorphic optimistic readonly/empty to readwrite section
+ // override.
+ //
+ {
+ using namespace test5;
+
+ base b;
+ derived d (123);
+
+ {
+ transaction t (db->begin ());
+ db->persist (b);
+ db->persist (d);
+ t.commit ();
+
+ assert (b.s.loaded ());
+ assert (d.s.loaded ());
+ }
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<base> pb (db->load<base> (b.id));
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ assert (!pb->s.loaded ());
+ assert (!pd->s.loaded ());
+ assert (pd->sn != d.sn);
+
+ db->load (*pb, pb->s); // No-op.
+ db->load (*pd, pd->s);
+
+ assert (pb->s.loaded ());
+ assert (pd->s.loaded ());
+
+ assert (pd->sn == d.sn);
+
+ t.commit ();
+ }
+
+ // Update object.
+ //
+ base b1 (b);
+ derived d1 (d);
+ d1.sn++;
+ d1.s.change ();
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->update (d1);
+
+ assert (!d1.s.changed ());
+ assert (d.v != d1.v);
+
+ try
+ {
+ db->load (*pd, pd->s);
+ assert (false);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (*pd);
+ assert (!pd->s.loaded ());
+ db->load (*pd, pd->s);
+ assert (pd->sn == d1.sn);
+ }
+
+ db->reload (d);
+ assert (d.v == d1.v);
+ assert (d.sn == d1.sn);
+ t.commit ();
+ }
+
+ // Update section.
+ //
+ d1.sn++;
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->update (b1, b1.s); // No-op.
+ db->update (d1, d1.s);
+
+ assert (b.v == b1.v);
+ assert (d.v != d1.v);
+
+ try
+ {
+ db->load (*pd, pd->s);
+ assert (false);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (*pd);
+ assert (!pd->s.loaded ());
+ db->load (*pd, pd->s);
+
+ assert (pd->sn == d1.sn);
+ }
+
+ db->reload (d);
+ assert (d.v == d1.v);
+ assert (d.sn == d1.sn);
+ t.commit ();
+ }
+
+ // Update changed section.
+ //
+ d1.sn++;
+
+ {
+ transaction t (db->begin ());
+ db->update (d1, d1.s);
+
+ try
+ {
+ db->update (d, d.s);
+ assert (false);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (d);
+ db->update (d, d.s);
+ }
+
+ t.commit ();
+ }
+ }
+
+ // Test polymorphic optimistic readonly/empty to readwrite section
+ // override, eager-loaded case.
+ //
+ {
+ using namespace test6;
+
+ derived d (123);
+
+ {
+ transaction t (db->begin ());
+ db->persist (d);
+ t.commit ();
+
+ assert (d.s.loaded ());
+ }
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ assert (pd->s.loaded ());
+ assert (pd->sn == d.sn);
+
+ t.commit ();
+ }
+
+ // Update object.
+ //
+ derived d1 (d);
+ d1.sn++;
+ d1.s.change ();
+
+ {
+ transaction t (db->begin ());
+
+ db->update (d1);
+
+ assert (!d1.s.changed ());
+ assert (d.v != d1.v);
+
+ db->reload (d);
+ assert (d.v == d1.v);
+ assert (d.sn == d1.sn);
+ t.commit ();
+ }
+
+ // Update section.
+ //
+ d1.sn++;
+
+ {
+ transaction t (db->begin ());
+
+ db->update (d1, d1.s);
+ assert (d.v != d1.v);
+
+ db->reload (d);
+ assert (d.v == d1.v);
+ assert (d.sn == d1.sn);
+ t.commit ();
+ }
+
+ // Update changed section.
+ //
+ d1.sn++;
+
+ {
+ transaction t (db->begin ());
+ db->update (d1, d1.s);
+
+ try
+ {
+ db->update (d, d.s);
+ assert (false);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (d);
+ db->update (d, d.s);
+ }
+
+ t.commit ();
+ }
+ }
+
+ // Test polymorphic optimistic section added in derived.
+ //
+ {
+ using namespace test7;
+
+ base b;
+ derived d (123);
+
+ {
+ transaction t (db->begin ());
+ db->persist (b);
+ db->persist (d);
+ t.commit ();
+
+ assert (b.s.loaded ());
+ assert (d.s.loaded ());
+ }
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<base> pb (db->load<base> (b.id));
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ assert (!pb->s.loaded ());
+ assert (!pd->s.loaded ());
+ assert (pd->sn != d.sn);
+
+ db->load (*pb, pb->s); // No-op.
+ db->load (*pd, pd->s);
+
+ assert (pb->s.loaded ());
+ assert (pd->s.loaded ());
+
+ assert (pd->sn == d.sn);
+
+ t.commit ();
+ }
+
+ // Update object.
+ //
+ base b1 (b);
+ derived d1 (d);
+ d1.sn++;
+ d1.s.change ();
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->update (d1);
+
+ assert (!d1.s.changed ());
+ assert (d.v != d1.v);
+
+ try
+ {
+ db->load (*pd, pd->s);
+ assert (false);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (*pd);
+ assert (!pd->s.loaded ());
+ db->load (*pd, pd->s);
+ assert (pd->sn == d1.sn);
+ }
+
+ db->reload (d);
+ assert (d.v == d1.v);
+ assert (d.sn == d1.sn);
+ t.commit ();
+ }
+
+ // Update section.
+ //
+ d1.sn++;
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->update (b1, b1.s); // No-op.
+ db->update (d1, d1.s);
+
+ assert (b.v == b1.v);
+ assert (d.v != d1.v);
+
+ try
+ {
+ db->load (*pd, pd->s);
+ assert (false);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (*pd);
+ assert (!pd->s.loaded ());
+ db->load (*pd, pd->s);
+
+ assert (pd->sn == d1.sn);
+ }
+
+ db->reload (d);
+ assert (d.v == d1.v);
+ assert (d.sn == d1.sn);
+ t.commit ();
+ }
+
+ // Update changed section.
+ //
+ d1.sn++;
+
+ {
+ transaction t (db->begin ());
+ db->update (d1, d1.s);
+
+ try
+ {
+ db->update (d, d.s);
+ assert (false);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (d);
+ db->update (d, d.s);
+ }
+
+ t.commit ();
+ }
+ }
+
+ // Test reuse/polymorphic inheritance and optimistic mix.
+ //
+ {
+ using namespace test8;
+
+ derived d (123);
+
+ {
+ transaction t (db->begin ());
+ db->persist (d);
+ t.commit ();
+
+ assert (d.s.loaded ());
+ }
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ assert (!pd->s.loaded ());
+ assert (pd->sn != d.sn);
+
+ db->load (*pd, pd->s);
+
+ assert (pd->s.loaded ());
+ assert (pd->sn == d.sn);
+
+ t.commit ();
+ }
+
+ // Update object.
+ //
+ derived d1 (d);
+ d1.sn++;
+ d1.s.change ();
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->update (d1);
+
+ assert (!d1.s.changed ());
+ assert (d.v != d1.v);
+
+ try
+ {
+ db->load (*pd, pd->s);
+ assert (false);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (*pd);
+ assert (!pd->s.loaded ());
+ db->load (*pd, pd->s);
+ assert (pd->sn == d1.sn);
+ }
+
+ db->reload (d);
+ assert (d.v == d1.v);
+ assert (d.sn == d1.sn);
+ t.commit ();
+ }
+
+ // Update section.
+ //
+ d1.sn++;
+
+ {
+ transaction t (db->begin ());
+ unique_ptr<derived> pd (db->load<derived> (d.id));
+
+ db->update (d1, d1.s);
+ assert (d.v != d1.v);
+
+ try
+ {
+ db->load (*pd, pd->s);
+ assert (false);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (*pd);
+ assert (!pd->s.loaded ());
+ db->load (*pd, pd->s);
+
+ assert (pd->sn == d1.sn);
+ }
+
+ db->reload (d);
+ assert (d.v == d1.v);
+ assert (d.sn == d1.sn);
+ t.commit ();
+ }
+
+ // Update changed section.
+ //
+ d1.sn++;
+
+ {
+ transaction t (db->begin ());
+ db->update (d1, d1.s);
+
+ try
+ {
+ db->update (d, d.s);
+ assert (false);
+ }
+ catch (const object_changed&)
+ {
+ db->reload (d);
+ db->update (d, d.s);
+ }
+
+ t.commit ();
+ }
+ }
+
+ // Test reuse/polymorphic inheritance and optimistic mix.
+ //
+ {
+ using namespace test9;
+ using std::shared_ptr;
+
+ unsigned long long id;
+
+ {
+ container c (123);
+
+ c.e1.push_back (shared_ptr<element> (new element (11)));
+ c.e1.push_back (shared_ptr<element> (new element (12)));
+
+ c.e2.push_back (shared_ptr<element> (new element (21)));
+ c.e2.push_back (shared_ptr<element> (new element (22)));
+
+ transaction t (db->begin ());
+
+ db->persist (c.e1[0]);
+ db->persist (c.e1[1]);
+ db->persist (c.e2[0]);
+ db->persist (c.e2[1]);
+
+ id = db->persist (c);
+
+ t.commit ();
+ }
+
+ {
+ transaction t (db->begin ());
+
+ shared_ptr<container> c (db->load<container> (id));
+
+ assert (c->n == 123);
+ db->load (*c, c->s);
+ assert (c->e1.size () == 2 && c->e1[0]->n == 11 && c->e1[1]->n == 12);
+ assert (c->e2.size () == 2 && c->e2[0]->n == 21 && c->e2[1]->n == 22);
+
+ t.commit ();
+ }
+ }
+ }
+ catch (const odb::exception& e)
+ {
+ cerr << e.what () << endl;
+ return 1;
+ }
+}
diff --git a/odb-tests/common/section/polymorphism/test.hxx b/odb-tests/common/section/polymorphism/test.hxx
new file mode 100644
index 0000000..6d524bd
--- /dev/null
+++ b/odb-tests/common/section/polymorphism/test.hxx
@@ -0,0 +1,542 @@
+// file : common/section/polymorphism/test.hxx
+// license : GNU GPL v2; see accompanying LICENSE file
+
+#ifndef TEST_HXX
+#define TEST_HXX
+
+#include <string>
+#include <vector>
+#include <memory>
+
+#include <odb/core.hxx>
+#include <odb/section.hxx>
+
+// Test basic polymorphic section functionality.
+//
+#pragma db namespace table("t1_")
+namespace test1
+{
+ #pragma db object polymorphic abstract
+ struct root
+ {
+ root (int n): rs1n (n), rs2n (n), rs4n (n) {rs2v.push_back (n);}
+ virtual ~root () {}
+
+ #pragma db id auto
+ unsigned long id;
+
+ // rs1: override in base and derived
+ //
+ #pragma db load(lazy) update(change)
+ odb::section rs1;
+
+ #pragma db section(rs1)
+ int rs1n;
+
+ // rs2: no override
+ //
+ #pragma db load(lazy)
+ odb::section rs2;
+
+ #pragma db section(rs2)
+ int rs2n;
+
+ #pragma db section(rs2)
+ std::vector<int> rs2v;
+
+ // rs3: empty
+ //
+ #pragma db load(lazy)
+ odb::section rs3;
+
+ // rs4: override "gap"
+ //
+ #pragma db load(lazy)
+ odb::section rs4;
+
+ #pragma db section(rs4)
+ int rs4n;
+ };
+
+ #pragma db object
+ struct base: root
+ {
+ base (int n = 999, const std::string& s = "xxx")
+ : root (n), rs1s (s), bs1n (n) {rs3v.push_back (n);}
+
+ // rs1
+ //
+ #pragma db section(rs1)
+ std::string rs1s;
+
+ // rs3
+ //
+ #pragma db section(rs3)
+ std::vector<int> rs3v;
+
+ // bs1: override in derived
+ //
+ #pragma db load(lazy)
+ odb::section bs1;
+
+ #pragma db section(bs1)
+ int bs1n;
+ };
+
+ #pragma db object
+ struct derived: base
+ {
+ derived (int n = 999, const std::string& s = "xxx", bool b = false)
+ : base (n, s), rs1b (b), rs3n (n), rs4s (s), bs1s (s), ds1n (n)
+ {rs1v.push_back (n);}
+
+ // rs1
+ //
+ #pragma db section(rs1)
+ bool rs1b;
+
+ #pragma db section(rs1)
+ std::vector<int> rs1v;
+
+ // rs3
+ //
+ #pragma db section(rs3)
+ int rs3n;
+
+ // rs4
+ //
+ #pragma db section(rs4)
+ std::string rs4s;
+
+ // bs1
+ //
+ #pragma db section(bs1)
+ std::string bs1s;
+
+ // ds1: no override
+ //
+ #pragma db load(lazy)
+ odb::section ds1;
+
+ #pragma db section(ds1)
+ int ds1n;
+ };
+}
+
+// Test empty section and override "gap".
+//
+#pragma db namespace table("t2_")
+namespace test2
+{
+ #pragma db object polymorphic abstract
+ struct root
+ {
+ virtual ~root () {}
+
+ #pragma db id auto
+ unsigned long id;
+
+ #pragma db load(lazy)
+ odb::section s;
+ };
+
+ #pragma db object abstract
+ struct base: root
+ {
+ // The "gap".
+ };
+
+ #pragma db object
+ struct derived: base
+ {
+ derived (int n = 999): sn (n) {sv.push_back (n);}
+
+ #pragma db section(s)
+ int sn;
+
+ #pragma db section(s)
+ std::vector<int> sv;
+ };
+}
+
+// Test value-only/container-only base/override combinations.
+//
+#pragma db namespace table("t3_")
+namespace test3
+{
+ #pragma db object polymorphic
+ struct root
+ {
+ root (int n = 999)
+ : s1n (n), s2n (n) {s3v.push_back (n); s4nv.push_back (n);}
+ virtual ~root () {}
+
+ #pragma db id auto
+ unsigned long id;
+
+ // value/value
+ //
+ #pragma db load(lazy)
+ odb::section s1;
+
+ #pragma db section(s1)
+ int s1n;
+
+ // value/container
+ //
+ #pragma db load(lazy)
+ odb::section s2;
+
+ #pragma db section(s2)
+ int s2n;
+
+ // container/value
+ //
+ #pragma db load(lazy)
+ odb::section s3;
+
+ #pragma db section(s3)
+ std::vector<int> s3v;
+
+ // container/container
+ //
+ #pragma db load(lazy)
+ odb::section s4;
+
+ #pragma db section(s4)
+ std::vector<int> s4nv;
+ };
+
+ #pragma db object
+ struct base: root
+ {
+ base (int n = 999): root (n) {}
+
+ // The "gap".
+ };
+
+ #pragma db object
+ struct derived: base
+ {
+ derived (int n = 999, const std::string& s = "xxx")
+ : base (n), s1s (s), s3n (n) {s2v.push_back (n); s4sv.push_back (s);}
+
+ #pragma db section(s1)
+ std::string s1s;
+
+ #pragma db section(s2)
+ std::vector<int> s2v;
+
+ #pragma db section(s3)
+ int s3n;
+
+ #pragma db section(s4)
+ std::vector<std::string> s4sv;
+ };
+}
+
+// Test basic polymorphic optimistic section functionality.
+//
+#pragma db namespace table("t4_")
+namespace test4
+{
+ #pragma db object polymorphic optimistic abstract sectionable
+ struct root
+ {
+ root (int n): rs1n (n), rs2n (n), rs3n (n), rs4n (n) {}
+ virtual ~root () {}
+
+ #pragma db id auto
+ unsigned long id;
+
+ #pragma db version
+ unsigned long long v;
+
+ // rs1: readwrite, override
+ //
+ #pragma db load(lazy) update(change)
+ odb::section rs1;
+
+ #pragma db section(rs1)
+ int rs1n;
+
+ // rs2: readonly, no override
+ //
+ #pragma db load(lazy)
+ odb::section rs2;
+
+ #pragma db section(rs2)
+ const int rs2n;
+
+ // rs3: readonly, readonly override
+ //
+ #pragma db load(lazy)
+ odb::section rs3;
+
+ #pragma db section(rs3)
+ const int rs3n;
+
+ // rs4: readonly, readwrite override
+ //
+ #pragma db load(lazy)
+ odb::section rs4;
+
+ #pragma db section(rs4)
+ const int rs4n;
+ };
+
+ #pragma db object
+ struct base: root
+ {
+ base (int n = 999, const std::string& s = "xxx")
+ : root (n), rs1s (s), rs4s (s) {}
+
+ // rs1
+ //
+ #pragma db section(rs1)
+ std::string rs1s;
+
+ // rs4
+ //
+ #pragma db section(rs4)
+ std::string rs4s;
+
+ // bs2: empty, readwrite override
+ //
+ #pragma db load(lazy)
+ odb::section bs1;
+ };
+
+ #pragma db object
+ struct derived: base
+ {
+ derived (int n = 999, const std::string& s = "xxx", bool b = false)
+ : base (n, s), rs1b (b), rs3s (s), bs1n (n)
+ {
+ rs1v.push_back (n);
+ rs4v.push_back (n);
+ ds1v.push_back (n);
+ }
+
+ // rs1
+ //
+ #pragma db section(rs1)
+ bool rs1b;
+
+ #pragma db section(rs1)
+ std::vector<int> rs1v;
+
+ // rs3
+ //
+ #pragma db section(rs3)
+ const std::string rs3s;
+
+ // rs4
+ //
+ #pragma db section(rs4)
+ std::vector<int> rs4v;
+
+ // bs1
+ //
+ #pragma db section(bs1)
+ int bs1n;
+
+ // ds1: readwrite
+ //
+ #pragma db load(lazy)
+ odb::section ds1;
+
+ #pragma db section(ds1)
+ std::vector<int> ds1v;
+ };
+}
+
+// Test polymorphic optimistic readonly/empty to readwrite section override.
+//
+#pragma db namespace table("t5_")
+namespace test5
+{
+ #pragma db object polymorphic optimistic abstract
+ struct root
+ {
+ virtual ~root () {}
+
+ #pragma db id auto
+ unsigned long id;
+
+ #pragma db version
+ unsigned long long v;
+
+ #pragma db load(lazy) update(change)
+ odb::section s;
+ };
+
+ #pragma db object
+ struct base: root
+ {
+ // The "gap".
+ };
+
+ #pragma db object
+ struct derived: base
+ {
+ derived (int n = 999): sn (n) {}
+
+ #pragma db section(s)
+ int sn;
+ };
+}
+
+// Test polymorphic optimistic readonly/empty to readwrite section override,
+// eager-loaded case.
+//
+#pragma db namespace table("t6_")
+namespace test6
+{
+ #pragma db object polymorphic optimistic abstract
+ struct root
+ {
+ virtual ~root () {}
+
+ #pragma db id auto
+ unsigned long id;
+
+ #pragma db version
+ unsigned long long v;
+
+ #pragma db update(change)
+ odb::section s;
+ };
+
+ #pragma db object abstract
+ struct base: root
+ {
+ // The "gap".
+ };
+
+ #pragma db object
+ struct derived: base
+ {
+ derived (int n = 999): sn (n) {}
+
+ #pragma db section(s)
+ int sn;
+ };
+}
+
+// Test polymorphic optimistic section added in derived.
+//
+#pragma db namespace table("t7_")
+namespace test7
+{
+ #pragma db object polymorphic optimistic sectionable
+ struct root
+ {
+ virtual ~root () {}
+
+ #pragma db id auto
+ unsigned long id;
+
+ #pragma db version
+ unsigned long long v;
+ };
+
+ #pragma db object
+ struct base: root
+ {
+ #pragma db load(lazy) update(change)
+ odb::section s;
+ };
+
+ #pragma db object
+ struct derived: base
+ {
+ derived (int n = 999): sn (n) {}
+
+ #pragma db section(s)
+ int sn;
+ };
+}
+
+// Test reuse/polymorphic inheritance and optimistic mix.
+//
+#pragma db namespace table("t8_")
+namespace test8
+{
+ #pragma db object optimistic sectionable abstract
+ struct root
+ {
+ #pragma db id auto
+ unsigned long id;
+
+ #pragma db version
+ unsigned long long v;
+ };
+
+ #pragma db object polymorphic sectionable
+ struct base: root
+ {
+ virtual ~base () {}
+ };
+
+ #pragma db object
+ struct derived: base
+ {
+ derived (int n = 999): sn (n) {}
+
+ #pragma db load(lazy) update(change)
+ odb::section s;
+
+ #pragma db section(s)
+ int sn;
+ };
+}
+
+// Test id overwrite regression.
+//
+// The key here is the setup: the object that contains the containers in a
+// section and the pointers to objects stored in those containers. And these
+// objects derive polymorphically from the same base (and thus shared the id
+// bindind).
+//
+#pragma db namespace table("t9_")
+namespace test9
+{
+ #pragma db object polymorphic pointer(std::shared_ptr)
+ struct base
+ {
+ virtual ~base () {}
+
+ #pragma db id auto
+ unsigned long id;
+ };
+
+ #pragma db object
+ struct element: base
+ {
+ element (int n_ = 0): n (n_) {}
+
+ int n;
+ };
+
+ typedef std::vector<std::shared_ptr<element>> elements;
+
+ #pragma db object
+ struct container: base
+ {
+ container (int n_ = 0): n (n_) {}
+
+ int n;
+
+ #pragma db load(lazy) update(always)
+ odb::section s;
+
+ #pragma db section(s)
+ elements e1;
+
+ #pragma db section(s)
+ elements e2;
+ };
+}
+
+#endif // TEST_HXX
diff --git a/odb-tests/common/section/polymorphism/testscript b/odb-tests/common/section/polymorphism/testscript
new file mode 100644
index 0000000..f2cd536
--- /dev/null
+++ b/odb-tests/common/section/polymorphism/testscript
@@ -0,0 +1,33 @@
+# file : common/section/polymorphism/testscript
+# license : GNU GPL v2; see accompanying LICENSE file
+
+.include ../../../database-options.testscript
+
+: mysql
+:
+if $mysql
+{
+ .include ../../../mysql.testscript
+
+ $create_schema;
+ $*
+}
+
+: sqlite
+:
+if $sqlite
+{
+ .include ../../../sqlite.testscript
+
+ $*
+}
+
+: pgsql
+:
+if $pgsql
+{
+ .include ../../../pgsql.testscript
+
+ $create_schema;
+ $*
+}
generated by cgit v1.1 at 2024-05-20 06:28:56 +0000