Lines Matching refs:db
335 db: RefCell<InnerConnection>, field
400 InnerConnection::open_with_flags(&c_path, flags, None).map(|db| Connection { in open_with_flags()
401 db: RefCell::new(db), in open_with_flags()
425 InnerConnection::open_with_flags(&c_path, flags, Some(&c_vfs)).map(|db| Connection { in open_with_flags_and_vfs()
426 db: RefCell::new(db), in open_with_flags_and_vfs()
590 self.db.borrow_mut().last_insert_rowid() in last_insert_rowid()
712 self.db.borrow_mut().prepare(self, sql) in prepare()
727 let r = self.db.borrow_mut().close(); in close()
787 self.db.borrow_mut().enable_load_extension(1) in load_extension_enable()
802 unsafe { self.db.borrow_mut().enable_load_extension(0) } in load_extension_disable()
848 self.db in load_extension()
868 self.db.borrow().db() in handle()
880 pub unsafe fn from_handle(db: *mut ffi::sqlite3) -> Result<Connection> { in from_handle()
881 let db_path = db_filename(db); in from_handle()
882 let db = InnerConnection::new(db, false); in from_handle() localVariable
884 db: RefCell::new(db), in from_handle()
894 self.db.borrow().get_interrupt_handle() in get_interrupt_handle()
899 self.db.borrow().decode_result(code) in decode_result()
907 self.db.borrow().changes() in changes()
914 self.db.borrow().is_autocommit() in is_autocommit()
922 self.db.borrow().is_busy() in is_busy()
929 self.db.borrow_mut().cache_flush() in cache_flush()
1087 unsafe fn db_filename(db: *mut ffi::sqlite3) -> Option<PathBuf> { in db_filename()
1089 let db_filename = ffi::sqlite3_db_filename(db, db_name.as_ptr()); in db_filename()
1178 let db = Connection::open(&path)?; in test_persistence() localVariable
1183 db.execute_batch(sql)?; in test_persistence()
1187 let db = Connection::open(&path_string)?; in test_persistence() localVariable
1188 let the_answer: Result<i64> = db.query_row("SELECT x FROM foo", [], |r| r.get(0)); in test_persistence()
1198 let db = checked_memory_handle(); in test_open() localVariable
1199 assert!(db.close().is_ok()); in test_open()
1237 let db = Connection::open(&db_path)?; in test_invalid_unicode_file_names() localVariable
1242 db.execute_batch(sql)?; in test_invalid_unicode_file_names()
1245 let db = Connection::open(&db_path)?; in test_invalid_unicode_file_names() localVariable
1246 let the_answer: Result<i64> = db.query_row("SELECT x FROM foo", [], |r| r.get(0)); in test_invalid_unicode_file_names()
1254 let db = Connection::open_in_memory()?; in test_close_retry() localVariable
1264 let raw_db = db.db.borrow_mut().db; in test_close_retry()
1283 let (db, _) = db.close().unwrap_err(); in test_close_retry()
1284 let (db, _) = db.close().unwrap_err(); in test_close_retry()
1285 let (db, _) = db.close().unwrap_err(); in test_close_retry()
1290 db.close().unwrap(); in test_close_retry()
1307 let db = Connection::open_in_memory()?; in test_execute_batch() localVariable
1315 db.execute_batch(sql)?; in test_execute_batch()
1317 db.execute_batch("UPDATE foo SET x = 3 WHERE x < 3")?; in test_execute_batch()
1319 assert!(db.execute_batch("INVALID SQL").is_err()); in test_execute_batch()
1325 let db = Connection::open_in_memory()?; in test_execute() localVariable
1326 db.execute_batch("CREATE TABLE foo(x INTEGER)")?; in test_execute()
1328 assert_eq!(1, db.execute("INSERT INTO foo(x) VALUES (?)", [1i32])?); in test_execute()
1329 assert_eq!(1, db.execute("INSERT INTO foo(x) VALUES (?)", [2i32])?); in test_execute()
1333 db.query_row::<i32, _, _>("SELECT SUM(x) FROM foo", [], |r| r.get(0))? in test_execute()
1341 let db = checked_memory_handle(); in test_execute_select() localVariable
1342 let err = db.execute("SELECT 1 WHERE 1 < ?", [1i32]).unwrap_err(); in test_execute_select()
1353 let db = checked_memory_handle(); in test_execute_multiple() localVariable
1354 let err = db in test_execute_multiple()
1368 let db = Connection::open_in_memory()?; in test_prepare_column_names() localVariable
1369 db.execute_batch("CREATE TABLE foo(x INTEGER);")?; in test_prepare_column_names()
1371 let stmt = db.prepare("SELECT * FROM foo")?; in test_prepare_column_names()
1375 let stmt = db.prepare("SELECT x AS a, x AS b FROM foo")?; in test_prepare_column_names()
1383 let db = Connection::open_in_memory()?; in test_prepare_execute() localVariable
1384 db.execute_batch("CREATE TABLE foo(x INTEGER);")?; in test_prepare_execute()
1386 let mut insert_stmt = db.prepare("INSERT INTO foo(x) VALUES(?)")?; in test_prepare_execute()
1395 let mut update_stmt = db.prepare("UPDATE foo SET x=? WHERE x<?")?; in test_prepare_execute()
1404 let db = Connection::open_in_memory()?; in test_prepare_query() localVariable
1405 db.execute_batch("CREATE TABLE foo(x INTEGER);")?; in test_prepare_query()
1407 let mut insert_stmt = db.prepare("INSERT INTO foo(x) VALUES(?)")?; in test_prepare_query()
1412 let mut query = db.prepare("SELECT x FROM foo WHERE x < ? ORDER BY x DESC")?; in test_prepare_query()
1439 let db = Connection::open_in_memory()?; in test_query_map() localVariable
1447 db.execute_batch(sql)?; in test_query_map()
1449 let mut query = db.prepare("SELECT x, y FROM foo ORDER BY x DESC")?; in test_query_map()
1458 let db = Connection::open_in_memory()?; in test_query_row() localVariable
1466 db.execute_batch(sql)?; in test_query_row()
1470 db.query_row::<i64, _, _>("SELECT SUM(x) FROM foo", [], |r| r.get(0))? in test_query_row()
1473 let result: Result<i64> = db.query_row("SELECT x FROM foo WHERE x > 5", [], |r| r.get(0)); in test_query_row()
1479 let bad_query_result = db.query_row("NOT A PROPER QUERY; test123", [], |_| Ok(())); in test_query_row()
1487 let db = Connection::open_in_memory()?; in test_optional() localVariable
1489 let result: Result<i64> = db.query_row("SELECT 1 WHERE 0 <> 0", [], |r| r.get(0)); in test_optional()
1496 let result: Result<i64> = db.query_row("SELECT 1 WHERE 0 == 0", [], |r| r.get(0)); in test_optional()
1503 let bad_query_result: Result<i64> = db.query_row("NOT A PROPER QUERY", [], |r| r.get(0)); in test_optional()
1511 let db = Connection::open_in_memory()?; in test_pragma_query_row() localVariable
1515 db.query_row::<String, _, _>("PRAGMA journal_mode", [], |r| r.get(0))? in test_pragma_query_row()
1519 db.query_row::<String, _, _>("PRAGMA journal_mode=off", [], |r| r.get(0))? in test_pragma_query_row()
1526 let db = Connection::open_in_memory()?; in test_prepare_failures() localVariable
1527 db.execute_batch("CREATE TABLE foo(x INTEGER);")?; in test_prepare_failures()
1529 let err = db.prepare("SELECT * FROM does_not_exist").unwrap_err(); in test_prepare_failures()
1536 let db = Connection::open_in_memory()?; in test_last_insert_rowid() localVariable
1537 db.execute_batch("CREATE TABLE foo(x INTEGER PRIMARY KEY)")?; in test_last_insert_rowid()
1538 db.execute_batch("INSERT INTO foo DEFAULT VALUES")?; in test_last_insert_rowid()
1540 assert_eq!(db.last_insert_rowid(), 1); in test_last_insert_rowid()
1542 let mut stmt = db.prepare("INSERT INTO foo DEFAULT VALUES")?; in test_last_insert_rowid()
1546 assert_eq!(db.last_insert_rowid(), 10); in test_last_insert_rowid()
1552 let db = Connection::open_in_memory()?; in test_is_autocommit() localVariable
1554 db.is_autocommit(), in test_is_autocommit()
1563 let db = Connection::open_in_memory()?; in test_is_busy() localVariable
1564 assert!(!db.is_busy()); in test_is_busy()
1565 let mut stmt = db.prepare("PRAGMA schema_version")?; in test_is_busy()
1566 assert!(!db.is_busy()); in test_is_busy()
1569 assert!(!db.is_busy()); in test_is_busy()
1571 assert!(db.is_busy()); in test_is_busy()
1574 assert!(!db.is_busy()); in test_is_busy()
1580 let db = Connection::open_in_memory()?; in test_statement_debugging() localVariable
1582 let stmt = db.prepare(query)?; in test_statement_debugging()
1599 let db = Connection::open_in_memory()?; in test_notnull_constraint_error() localVariable
1600 db.execute_batch("CREATE TABLE foo(x NOT NULL)")?; in test_notnull_constraint_error()
1602 let result = db.execute("INSERT INTO foo (x) VALUES (NULL)", []); in test_notnull_constraint_error()
1628 let db = Connection::open_in_memory()?; in test_interrupt() localVariable
1630 let interrupt_handle = db.get_interrupt_handle(); in test_interrupt()
1632 db.create_scalar_function( in test_interrupt()
1643 db.prepare("SELECT interrupt() FROM (SELECT 1 UNION SELECT 2 UNION SELECT 3)")?; in test_interrupt()
1660 let db = checked_memory_handle(); in test_interrupt_close() localVariable
1661 let handle = db.get_interrupt_handle(); in test_interrupt_close()
1663 db.close().unwrap(); in test_interrupt_close()
1676 let db = Connection::open_in_memory()?; in test_get_raw() localVariable
1677 db.execute_batch("CREATE TABLE foo(i, x);")?; in test_get_raw()
1679 let mut insert_stmt = db.prepare("INSERT INTO foo(i, x) VALUES(?, ?)")?; in test_get_raw()
1685 let mut query = db.prepare("SELECT i, x FROM foo")?; in test_get_raw()
1695 let mut query = db.prepare("SELECT x FROM foo")?; in test_get_raw()
1709 let db = Connection::open_in_memory()?; in test_from_handle() localVariable
1710 let handle = unsafe { db.handle() }; in test_from_handle()
1712 let db = unsafe { Connection::from_handle(handle) }?; in test_from_handle() localVariable
1713 db.execute_batch("PRAGMA VACUUM")?; in test_from_handle()
1715 db.close().unwrap(); in test_from_handle()
1761 let db = Connection::open_in_memory()?; in test_query_and_then() localVariable
1769 db.execute_batch(sql)?; in test_query_and_then()
1771 let mut query = db.prepare("SELECT x, y FROM foo ORDER BY x DESC")?; in test_query_and_then()
1781 let db = Connection::open_in_memory()?; in test_query_and_then_fails() localVariable
1789 db.execute_batch(sql)?; in test_query_and_then_fails()
1791 let mut query = db.prepare("SELECT x, y FROM foo ORDER BY x DESC")?; in test_query_and_then_fails()
1811 let db = Connection::open_in_memory()?; in test_query_and_then_custom_error() localVariable
1819 db.execute_batch(sql)?; in test_query_and_then_custom_error()
1821 let mut query = db.prepare("SELECT x, y FROM foo ORDER BY x DESC")?; in test_query_and_then_custom_error()
1832 let db = Connection::open_in_memory()?; in test_query_and_then_custom_error_fails() localVariable
1840 db.execute_batch(sql)?; in test_query_and_then_custom_error_fails()
1842 let mut query = db.prepare("SELECT x, y FROM foo ORDER BY x DESC")?; in test_query_and_then_custom_error_fails()
1874 let db = Connection::open_in_memory()?; in test_query_row_and_then_custom_error() localVariable
1879 db.execute_batch(sql)?; in test_query_row_and_then_custom_error()
1883 db.query_row_and_then(query, [], |row| row.get(1).map_err(CustomError::Sqlite)); in test_query_row_and_then_custom_error()
1891 let db = Connection::open_in_memory()?; in test_query_row_and_then_custom_error_fails() localVariable
1896 db.execute_batch(sql)?; in test_query_row_and_then_custom_error_fails()
1900 db.query_row_and_then(query, [], |row| row.get(1).map_err(CustomError::Sqlite)); in test_query_row_and_then_custom_error_fails()
1908 db.query_row_and_then(query, [], |row| row.get(3).map_err(CustomError::Sqlite)); in test_query_row_and_then_custom_error_fails()
1916 db.query_row_and_then(query, [], |_| Err(CustomError::SomeError)); in test_query_row_and_then_custom_error_fails()
1928 let db = Connection::open_in_memory()?; in test_dynamic() localVariable
1933 db.execute_batch(sql)?; in test_dynamic()
1935 db.query_row("SELECT * FROM foo", [], |r| { in test_dynamic()
1942 let db = Connection::open_in_memory()?; in test_dyn_box() localVariable
1943 db.execute_batch("CREATE TABLE foo(x INTEGER);")?; in test_dyn_box()
1945 db.execute("INSERT INTO foo VALUES(?)", [b])?; in test_dyn_box()
1946 db.query_row("SELECT x FROM foo", [], |r| { in test_dyn_box()
1954 let db = Connection::open_in_memory()?; in test_params() localVariable
1955 db.query_row( in test_params()
1975 let db = Connection::open_in_memory()?; in test_alter_table() localVariable
1976 db.execute_batch("CREATE TABLE x(t);")?; in test_alter_table()
1978 db.execute("ALTER TABLE x RENAME TO y;", [])?; in test_alter_table()
1984 let db = Connection::open_in_memory()?; in test_batch() localVariable
1989 let batch = Batch::new(&db, sql); in test_batch()
2000 let db = Connection::open_in_memory()?; in test_returning() localVariable
2001 db.execute_batch("CREATE TABLE foo(x INTEGER PRIMARY KEY)")?; in test_returning()
2003 db.query_row::<i64, _, _>("INSERT INTO foo DEFAULT VALUES RETURNING ROWID", [], |r| { in test_returning()
2013 let db = Connection::open_in_memory()?; in test_cache_flush() localVariable
2014 db.cache_flush() in test_cache_flush()