|
1 /* Any copyright is dedicated to the Public Domain. |
|
2 * http://creativecommons.org/publicdomain/zero/1.0/ */ |
|
3 |
|
4 Cu.import("resource://gre/modules/XPCOMUtils.jsm"); |
|
5 Cu.import("resource://services-common/async.js"); |
|
6 Cu.import("resource://services-common/utils.js"); |
|
7 |
|
8 _("Make sure querySpinningly will synchronously fetch rows for a query asyncly"); |
|
9 |
|
10 const SQLITE_CONSTRAINT_VIOLATION = 19; // http://www.sqlite.org/c3ref/c_abort.html |
|
11 |
|
12 let Svc = {}; |
|
13 XPCOMUtils.defineLazyServiceGetter(Svc, "Form", |
|
14 "@mozilla.org/satchel/form-history;1", |
|
15 "nsIFormHistory2"); |
|
16 |
|
17 function querySpinningly(query, names) { |
|
18 let q = Svc.Form.DBConnection.createStatement(query); |
|
19 let r = Async.querySpinningly(q, names); |
|
20 q.finalize(); |
|
21 return r; |
|
22 } |
|
23 |
|
24 function run_test() { |
|
25 initTestLogging("Trace"); |
|
26 |
|
27 _("Make sure the call is async and allows other events to process"); |
|
28 let isAsync = false; |
|
29 CommonUtils.nextTick(function() { isAsync = true; }); |
|
30 do_check_false(isAsync); |
|
31 |
|
32 _("Empty out the formhistory table"); |
|
33 let r0 = querySpinningly("DELETE FROM moz_formhistory"); |
|
34 do_check_eq(r0, null); |
|
35 |
|
36 _("Make sure there's nothing there"); |
|
37 let r1 = querySpinningly("SELECT 1 FROM moz_formhistory"); |
|
38 do_check_eq(r1, null); |
|
39 |
|
40 _("Insert a row"); |
|
41 let r2 = querySpinningly("INSERT INTO moz_formhistory (fieldname, value) VALUES ('foo', 'bar')"); |
|
42 do_check_eq(r2, null); |
|
43 |
|
44 _("Request a known value for the one row"); |
|
45 let r3 = querySpinningly("SELECT 42 num FROM moz_formhistory", ["num"]); |
|
46 do_check_eq(r3.length, 1); |
|
47 do_check_eq(r3[0].num, 42); |
|
48 |
|
49 _("Get multiple columns"); |
|
50 let r4 = querySpinningly("SELECT fieldname, value FROM moz_formhistory", ["fieldname", "value"]); |
|
51 do_check_eq(r4.length, 1); |
|
52 do_check_eq(r4[0].fieldname, "foo"); |
|
53 do_check_eq(r4[0].value, "bar"); |
|
54 |
|
55 _("Get multiple columns with a different order"); |
|
56 let r5 = querySpinningly("SELECT fieldname, value FROM moz_formhistory", ["value", "fieldname"]); |
|
57 do_check_eq(r5.length, 1); |
|
58 do_check_eq(r5[0].fieldname, "foo"); |
|
59 do_check_eq(r5[0].value, "bar"); |
|
60 |
|
61 _("Add multiple entries (sqlite doesn't support multiple VALUES)"); |
|
62 let r6 = querySpinningly("INSERT INTO moz_formhistory (fieldname, value) SELECT 'foo', 'baz' UNION SELECT 'more', 'values'"); |
|
63 do_check_eq(r6, null); |
|
64 |
|
65 _("Get multiple rows"); |
|
66 let r7 = querySpinningly("SELECT fieldname, value FROM moz_formhistory WHERE fieldname = 'foo'", ["fieldname", "value"]); |
|
67 do_check_eq(r7.length, 2); |
|
68 do_check_eq(r7[0].fieldname, "foo"); |
|
69 do_check_eq(r7[1].fieldname, "foo"); |
|
70 |
|
71 _("Make sure updates work"); |
|
72 let r8 = querySpinningly("UPDATE moz_formhistory SET value = 'updated' WHERE fieldname = 'more'"); |
|
73 do_check_eq(r8, null); |
|
74 |
|
75 _("Get the updated"); |
|
76 let r9 = querySpinningly("SELECT value, fieldname FROM moz_formhistory WHERE fieldname = 'more'", ["fieldname", "value"]); |
|
77 do_check_eq(r9.length, 1); |
|
78 do_check_eq(r9[0].fieldname, "more"); |
|
79 do_check_eq(r9[0].value, "updated"); |
|
80 |
|
81 _("Grabbing fewer fields than queried is fine"); |
|
82 let r10 = querySpinningly("SELECT value, fieldname FROM moz_formhistory", ["fieldname"]); |
|
83 do_check_eq(r10.length, 3); |
|
84 |
|
85 _("Generate an execution error"); |
|
86 let query = "INSERT INTO moz_formhistory (fieldname, value) VALUES ('one', NULL)"; |
|
87 let stmt = Svc.Form.DBConnection.createStatement(query); |
|
88 let r11, except; ; |
|
89 try { |
|
90 r11 = Async.querySpinningly(stmt); |
|
91 } catch(e) { |
|
92 except = e; |
|
93 } |
|
94 stmt.finalize() |
|
95 do_check_true(!!except); |
|
96 do_check_eq(except.result, SQLITE_CONSTRAINT_VIOLATION); |
|
97 |
|
98 _("Cleaning up"); |
|
99 querySpinningly("DELETE FROM moz_formhistory"); |
|
100 |
|
101 _("Make sure the timeout got to run before this function ends"); |
|
102 do_check_true(isAsync); |
|
103 } |