pub struct CachedDatabaseAdapter { /* private fields */ }Expand description
带缓存功能的数据库适配器包装器
Implementations§
Source§impl CachedDatabaseAdapter
impl CachedDatabaseAdapter
Sourcepub fn new(
inner: Box<dyn DatabaseAdapter>,
cache_manager: Arc<CacheManager>,
) -> Self
pub fn new( inner: Box<dyn DatabaseAdapter>, cache_manager: Arc<CacheManager>, ) -> Self
创建新的缓存适配器
Trait Implementations§
Source§impl DatabaseAdapter for CachedDatabaseAdapter
impl DatabaseAdapter for CachedDatabaseAdapter
Source§fn create<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
data: &'life3 HashMap<String, DataValue>,
) -> Pin<Box<dyn Future<Output = QuickDbResult<DataValue>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn create<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
data: &'life3 HashMap<String, DataValue>,
) -> Pin<Box<dyn Future<Output = QuickDbResult<DataValue>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
创建记录 - 创建成功后智能清理相关缓存
Source§fn find_by_id<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
id: &'life3 DataValue,
) -> Pin<Box<dyn Future<Output = QuickDbResult<Option<DataValue>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn find_by_id<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
id: &'life3 DataValue,
) -> Pin<Box<dyn Future<Output = QuickDbResult<Option<DataValue>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
根据ID查找记录 - 先检查缓存，缓存未命中时查询数据库并缓存结果
Source§fn find<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
conditions: &'life3 [QueryCondition],
options: &'life4 QueryOptions,
) -> Pin<Box<dyn Future<Output = QuickDbResult<Vec<DataValue>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
fn find<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
conditions: &'life3 [QueryCondition],
options: &'life4 QueryOptions,
) -> Pin<Box<dyn Future<Output = QuickDbResult<Vec<DataValue>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
查找记录 - 内部统一使用 find_with_groups 实现
Source§fn find_with_groups<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
condition_groups: &'life3 [QueryConditionGroup],
options: &'life4 QueryOptions,
) -> Pin<Box<dyn Future<Output = QuickDbResult<Vec<DataValue>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
fn find_with_groups<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
condition_groups: &'life3 [QueryConditionGroup],
options: &'life4 QueryOptions,
) -> Pin<Box<dyn Future<Output = QuickDbResult<Vec<DataValue>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
使用条件组合查找记录 - 先检查缓存，缓存未命中时查询数据库并缓存结果
Source§fn update<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
conditions: &'life3 [QueryCondition],
data: &'life4 HashMap<String, DataValue>,
) -> Pin<Box<dyn Future<Output = QuickDbResult<u64>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
fn update<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
conditions: &'life3 [QueryCondition],
data: &'life4 HashMap<String, DataValue>,
) -> Pin<Box<dyn Future<Output = QuickDbResult<u64>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
更新记录 - 更新成功后智能清理相关缓存
Source§fn update_by_id<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
id: &'life3 DataValue,
data: &'life4 HashMap<String, DataValue>,
) -> Pin<Box<dyn Future<Output = QuickDbResult<bool>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
fn update_by_id<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
id: &'life3 DataValue,
data: &'life4 HashMap<String, DataValue>,
) -> Pin<Box<dyn Future<Output = QuickDbResult<bool>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
根据ID更新记录 - 更新成功后精确清理相关缓存
Source§fn delete<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
conditions: &'life3 [QueryCondition],
) -> Pin<Box<dyn Future<Output = QuickDbResult<u64>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn delete<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
conditions: &'life3 [QueryCondition],
) -> Pin<Box<dyn Future<Output = QuickDbResult<u64>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
删除记录 - 删除成功后智能清理相关缓存
Source§fn delete_by_id<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
id: &'life3 DataValue,
) -> Pin<Box<dyn Future<Output = QuickDbResult<bool>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn delete_by_id<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
id: &'life3 DataValue,
) -> Pin<Box<dyn Future<Output = QuickDbResult<bool>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
根据ID删除记录 - 删除成功后精确清理相关缓存
Source§fn count<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
conditions: &'life3 [QueryCondition],
) -> Pin<Box<dyn Future<Output = QuickDbResult<u64>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn count<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
conditions: &'life3 [QueryCondition],
) -> Pin<Box<dyn Future<Output = QuickDbResult<u64>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
统计记录数量 - 直接调用内部适配器，不缓存统计结果
Source§fn exists<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
conditions: &'life3 [QueryCondition],
) -> Pin<Box<dyn Future<Output = QuickDbResult<bool>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn exists<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
conditions: &'life3 [QueryCondition],
) -> Pin<Box<dyn Future<Output = QuickDbResult<bool>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
检查记录是否存在 - 直接调用内部适配器，不缓存存在性检查结果
Source§fn create_table<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
fields: &'life3 HashMap<String, FieldType>,
) -> Pin<Box<dyn Future<Output = QuickDbResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn create_table<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
fields: &'life3 HashMap<String, FieldType>,
) -> Pin<Box<dyn Future<Output = QuickDbResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
创建表/集合 - 直接调用内部适配器
Source§fn create_index<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
index_name: &'life3 str,
fields: &'life4 [String],
unique: bool,
) -> Pin<Box<dyn Future<Output = QuickDbResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
fn create_index<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
index_name: &'life3 str,
fields: &'life4 [String],
unique: bool,
) -> Pin<Box<dyn Future<Output = QuickDbResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
创建索引 - 直接调用内部适配器
Source§fn table_exists<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
) -> Pin<Box<dyn Future<Output = QuickDbResult<bool>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn table_exists<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
) -> Pin<Box<dyn Future<Output = QuickDbResult<bool>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
检查表是否存在 - 直接调用内部适配器
Source§fn drop_table<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
) -> Pin<Box<dyn Future<Output = QuickDbResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn drop_table<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
connection: &'life1 DatabaseConnection,
table: &'life2 str,
) -> Pin<Box<dyn Future<Output = QuickDbResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
删除表 - 删除成功后清理所有相关缓存
Auto Trait Implementations§
impl Freeze for CachedDatabaseAdapter
impl !RefUnwindSafe for CachedDatabaseAdapter
impl Send for CachedDatabaseAdapter
impl Sync for CachedDatabaseAdapter
impl Unpin for CachedDatabaseAdapter
impl !UnwindSafe for CachedDatabaseAdapter
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> FmtForward for T
impl<T> FmtForward for T
Source§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
Causes
self to use its Binary implementation when Debug-formatted.Source§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
Causes
self to use its Display implementation when
Debug-formatted.Source§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
Causes
self to use its LowerExp implementation when
Debug-formatted.Source§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
Causes
self to use its LowerHex implementation when
Debug-formatted.Source§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
Causes
self to use its Octal implementation when Debug-formatted.Source§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
Causes
self to use its Pointer implementation when
Debug-formatted.Source§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
Causes
self to use its UpperExp implementation when
Debug-formatted.Source§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
Causes
self to use its UpperHex implementation when
Debug-formatted.Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
Source§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
Pipes by value. This is generally the method you want to use. Read more
Source§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
Borrows
self and passes that borrow into the pipe function. Read moreSource§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
Mutably borrows
self and passes that borrow into the pipe function. Read moreSource§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
Source§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
Source§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
Borrows
self, then passes self.as_ref() into the pipe function.Source§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
Mutably borrows
self, then passes self.as_mut() into the pipe
function.Source§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
Borrows
self, then passes self.deref() into the pipe function.Source§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> Tap for T
impl<T> Tap for T
Source§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Immutable access to the
Borrow<B> of a value. Read moreSource§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
Mutable access to the
BorrowMut<B> of a value. Read moreSource§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
Immutable access to the
AsRef<R> view of a value. Read moreSource§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
Mutable access to the
AsMut<R> view of a value. Read moreSource§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Immutable access to the
Deref::Target of a value. Read moreSource§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Mutable access to the
Deref::Target of a value. Read moreSource§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
Calls
.tap() only in debug builds, and is erased in release builds.Source§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
Calls
.tap_mut() only in debug builds, and is erased in release
builds.Source§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
Calls
.tap_borrow() only in debug builds, and is erased in release
builds.Source§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
Calls
.tap_borrow_mut() only in debug builds, and is erased in release
builds.Source§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
Calls
.tap_ref() only in debug builds, and is erased in release
builds.Source§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
Calls
.tap_ref_mut() only in debug builds, and is erased in release
builds.Source§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
Calls
.tap_deref() only in debug builds, and is erased in release
builds.