[svn:p5ee] r8687 - p5ee/trunk/App-Repository/t

Author: spadkins
Date: Tue Jan 23 15:51:34 2007
New Revision: 8687

Modified:
   p5ee/trunk/App-Repository/t/DBI-insert.t

Log:
more tests

Modified: p5ee/trunk/App-Repository/t/DBI-insert.t
==============================================================================
--- p5ee/trunk/App-Repository/t/DBI-insert.t	(original)
+++ p5ee/trunk/App-Repository/t/DBI-insert.t	Tue Jan 23 15:51:34 2007
@@ -156,6 +156,101 @@
         }),
         "insert \\ and ' and \\' seems to work");
     is($db->get("test_person",11,"first_name"),'%@$\\\'', "yep. first_name worked.");
+
+    my $new_hashes =
+       [{ age=>39, first_name=>"stephen", gender=>"M", state=>"GA", foo=>"bar"},
+        { age=>37, first_name=>"susan", gender=>"F", state=>"GA", foo=>"bar"},
+        { age=>6, first_name=>"maryalice", gender=>"F", state=>"GA", foo=>"bar"},
+        { age=>3, first_name=>"paul", gender=>"M", state=>"GA", foo=>"bar"},
+        { age=>1, first_name=>"christine", gender=>"F", state=>"GA", foo=>"bar"},
+        { age=>45, first_name=>"tim", gender=>"M", state=>"GA", foo=>"bar"},
+        { age=>39, first_name=>"keith", gender=>"M", state=>"GA", foo=>"bar"},];
+
+    my $new_rows =
+       [[39,"stephen",  "M","GA"],
+        [37,"susan",    "F","GA"],
+        [6,"maryalice", "F","GA"],
+        [3,"paul",      "M","GA"],
+        [1,"christine", "F","GA"],
+        [45,"tim",      "M","GA"],
+        [39,"keith",    "M","GA"],];
+
+    my $dup_rows =
+       [[1, 39,"stephen",  "M","GA"],
+        [2, 37,"susan",    "F","GA"],
+        [3, 6,"maryalice", "F","GA"],
+        [4, 3,"paul",      "M","GA"],
+        [5, 1,"christine", "F","GA"],
+        [6, 45,"tim",      "M","GA"],
+        [7, 39,"keith",    "M","GA"],];
+
+    my ($expect_sql, $sql);
+$expect_sql = <<EOF;
+insert into test_person
+  (age, first_name, gender, state)
+values
+  (39, 'stephen', 'M', 'GA'),
+  (37, 'susan', 'F', 'GA'),
+  (6, 'maryalice', 'F', 'GA'),
+  (3, 'paul', 'M', 'GA'),
+  (1, 'christine', 'F', 'GA'),
+  (45, 'tim', 'M', 'GA'),
+  (39, 'keith', 'M', 'GA')
+EOF
+$sql = $db->_mk_insert_rows_sql("test_person", ["age","first_name","gender","state"], $new_rows);
+is($sql, $expect_sql, "_mk_insert_rows_sql(): 7 rows, bulk insert");
+$sql = $db->_mk_insert_rows_sql("test_person", ["age","first_name","gender","state"], $new_hashes);
+is($sql, $expect_sql, "_mk_insert_rows_sql(): 7 rows, bulk insert (from hashes)");
+
+$expect_sql = <<EOF;
+replace into test_person
+  (age, first_name, gender, state)
+values
+  (39, 'stephen', 'M', 'GA'),
+  (37, 'susan', 'F', 'GA'),
+  (6, 'maryalice', 'F', 'GA'),
+  (3, 'paul', 'M', 'GA'),
+  (1, 'christine', 'F', 'GA'),
+  (45, 'tim', 'M', 'GA'),
+  (39, 'keith', 'M', 'GA')
+EOF
+$sql = $db->_mk_insert_rows_sql("test_person", ["age","first_name","gender","state"], $new_rows, { replace => 1 });
+is($sql, $expect_sql, "_mk_insert_rows_sql(): 7 rows, bulk replace");
+
+$expect_sql = <<EOF;
+insert into test_person
+  (person_id, age, first_name, gender, state)
+values
+  (1, 39, 'stephen', 'M', 'GA'),
+  (2, 37, 'susan', 'F', 'GA'),
+  (3, 6, 'maryalice', 'F', 'GA'),
+  (4, 3, 'paul', 'M', 'GA'),
+  (5, 1, 'christine', 'F', 'GA'),
+  (6, 45, 'tim', 'M', 'GA'),
+  (7, 39, 'keith', 'M', 'GA')
+on duplicate key update
+   person_id = values(person_id),
+   age = values(age),
+   first_name = values(first_name),
+   gender = values(gender),
+   state = values(state)
+EOF
+$sql = $db->_mk_insert_rows_sql("test_person", ["person_id", "age","first_name","gender","state"], $dup_rows, { update => 1 });
+is($sql, $expect_sql, "_mk_insert_rows_sql(): 7 rows, bulk insert/update");
+
+#######################################
+my ($nrows);
+$nrows = $db->insert_rows("test_person", ["age","first_name","gender","state"], $new_rows);
+is($nrows, 7, "insert_rows(): 7 rows, bulk insert");
+$nrows = $db->insert_rows("test_person", ["person_id","age","first_name","gender","state"], $dup_rows, { replace => 1 });
+is($nrows, 14, "insert_rows(): 7 rows (14 affected), bulk replace");
+$nrows = $db->insert_rows("test_person", ["person_id", "age","first_name","gender","state"], $dup_rows, { update => 1 });
+is($nrows, 14, "insert_rows(): 7 rows (14 affected), bulk insert/update");
+$nrows = $db->insert_rows("test_person", ["person_id","age","first_name","gender","state"], $dup_rows, { replace => 1, maxrows => 4 });
+is($nrows, 14, "insert_rows(): 7 rows (14 affected), bulk replace (4 at a time)");
+$nrows = $db->insert_rows("test_person", ["person_id", "age","first_name","gender","state"], $dup_rows, { update => 1, maxrows => 4 });
+is($nrows, 14, "insert_rows(): 7 rows (14 affected), bulk insert/update (4 at a time)");
+
 }
 
 exit 0;