Lines Matching refs:Table
33 table::Table,
155 db.restore_if_exec_fail(|e: &Table| e.create_with_version(COLUMN_INFO, upgrade_db_version))?; in get_db()
233 let table = Table::new(TABLE_NAME, &db); in check_db_accessible()
337 … self.restore_if_exec_fail(|e: &Table| e.upgrade(DB_UPGRADE_VERSION_V2, UPGRADE_COLUMN_INFO_V2))?; in upgrade()
341 … self.restore_if_exec_fail(|e: &Table| e.upgrade(DB_UPGRADE_VERSION_V3, UPGRADE_COLUMN_INFO_V3))?; in upgrade()
346 … self.restore_if_exec_fail(|e: &Table| e.upgrade(DB_UPGRADE_VERSION, UPGRADE_COLUMN_INFO))?; in upgrade()
444 …pub(crate) fn restore_if_exec_fail<T, F: Fn(&Table) -> Result<T>>(&mut self, func: F) -> Result<T>… in restore_if_exec_fail()
445 let table = Table::new(TABLE_NAME, self); in restore_if_exec_fail()
450 let table = Table::new(TABLE_NAME, self); // Database handle will be changed. in restore_if_exec_fail()
480 let closure = |e: &Table| { in insert_datas()
523 let closure = |e: &Table| e.delete_row(condition, reverse_condition, is_filter_sync); in delete_datas()
532 let closure = |e: &Table| e.delete_with_specific_cond(specific_cond, condition_value); in delete_specific_condition_datas()
558 let closure = |e: &Table| e.update_row(condition, is_filter_sync, datas); in update_datas()
581 let closure = |e: &Table| e.is_data_exists(condition, is_filter_sync); in is_data_exists()
611 …let closure = |e: &Table| e.query_row(columns, condition, query_options, is_filter_sync, COLUMN_IN… in query_datas()
639 …let closure = |e: &Table| e.query_row(columns, condition, query_options, is_filter_sync, COLUMN_IN… in query_data_without_lock()
646 let closure = |e: &Table| e.count_datas(condition, false); in query_data_count()
653 let closure = |e: &Table| e.replace_row(condition, is_filter_sync, datas); in replace_datas()