ISAR/rusqlite
3
0
Fork 0
mirror of https://github.com/isar/rusqlite.git synced 2024-11-26 19:41:37 +08:00
Code Issues Packages Projects Releases Wiki Activity

Rustfmt

Browse Source
This commit is contained in:
gwenn 2017-05-12 19:18:42 +02:00
parent dfdd42fd09
commit 94670c0119
1 changed files with 16 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/hooks.rs
View File

@ -110,7 +110,8 @@ impl Connection {
self.db.borrow_mut().rollback_hook(hook); self.db.borrow_mut().rollback_hook(hook);
} }
/// Register a callback function to be invoked whenever a row is updated, inserted or deleted in a rowid table. /// Register a callback function to be invoked whenever a row is updated,
/// inserted or deleted in a rowid table.
/// ///
/// The callback parameters are: /// The callback parameters are:
/// ///
@ -154,7 +155,8 @@ impl InnerConnection {
where F: FnMut() -> bool where F: FnMut() -> bool
{ {
let boxed_hook: *mut F = mem::transmute(p_arg); let boxed_hook: *mut F = mem::transmute(p_arg);
assert!(!boxed_hook.is_null(), "Internal error - null function pointer"); assert!(!boxed_hook.is_null(),
"Internal error - null function pointer");
if (*boxed_hook)() { 1 } else { 0 } if (*boxed_hook)() { 1 } else { 0 }
} }
@ -177,7 +179,8 @@ impl InnerConnection {
where F: FnMut() where F: FnMut()
{ {
let boxed_hook: *mut F = mem::transmute(p_arg); let boxed_hook: *mut F = mem::transmute(p_arg);
assert!(!boxed_hook.is_null(), "Internal error - null function pointer"); assert!(!boxed_hook.is_null(),
"Internal error - null function pointer");
(*boxed_hook)(); (*boxed_hook)();
} }
@ -207,7 +210,8 @@ impl InnerConnection {
use std::str; use std::str;
let boxed_hook: *mut F = mem::transmute(p_arg); let boxed_hook: *mut F = mem::transmute(p_arg);
assert!(!boxed_hook.is_null(), "Internal error - null function pointer"); assert!(!boxed_hook.is_null(),
"Internal error - null function pointer");
let action = Action::from(action_code); let action = Action::from(action_code);
let db_name = { let db_name = {
@ -270,7 +274,8 @@ mod test {
called = true; called = true;
false false
}); });
db.execute_batch("BEGIN; CREATE TABLE foo (t TEXT); COMMIT;").unwrap(); db.execute_batch("BEGIN; CREATE TABLE foo (t TEXT); COMMIT;")
.unwrap();
assert!(called); assert!(called);
} }
@ -279,10 +284,9 @@ mod test {
let db = Connection::open_in_memory().unwrap(); let db = Connection::open_in_memory().unwrap();
let mut called = false; let mut called = false;
db.rollback_hook(|| { db.rollback_hook(|| { called = true; });
called = true; db.execute_batch("BEGIN; CREATE TABLE foo (t TEXT); ROLLBACK;")
}); .unwrap();
db.execute_batch("BEGIN; CREATE TABLE foo (t TEXT); ROLLBACK;").unwrap();
assert!(called); assert!(called);
} }
@ -299,8 +303,7 @@ mod test {
called = true; called = true;
}); });
db.execute_batch("CREATE TABLE foo (t TEXT)").unwrap(); db.execute_batch("CREATE TABLE foo (t TEXT)").unwrap();
db.execute_batch("INSERT INTO foo VALUES ('lisa')") db.execute_batch("INSERT INTO foo VALUES ('lisa')").unwrap();
.unwrap();
assert!(called); assert!(called);
} }
} }