Struct DbNexusAdapter 

pub struct DbNexusAdapter { /* private fields */ }

dbnexus 适配器

将 dbnexus 库的 DbPool 适配为 Database trait。 使用 Sea-ORM 进行批量插入操作。

功能要求

• 需要启用 dbnexus feature
• 支持 PostgreSQL、MySQL、SQLite、DuckDB 数据库

示例

use inklog::infrastructure::database::{Database, DbNexusAdapter};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let db = DbNexusAdapter::new("postgres://user:pass@localhost/logs", 10).await?;
     
    let healthy = db.is_healthy().await;
    println!("Database healthy: {}", healthy);
     
    Ok(())
}

Implementations

impl DbNexusAdapter

pub async fn new(url: &str, pool_size: u32) -> Result<Self, InklogError>

创建新的 dbnexus 适配器

参数

• url - 数据库连接字符串
• pool_size - 连接池大小（最大连接数）

返回

成功返回 Ok(Self)，失败返回 Err(InklogError)

错误

• InklogError::DatabaseError - 连接池创建失败

示例

// PostgreSQL
let db = DbNexusAdapter::new("postgres://user:pass@localhost/logs", 10).await?;

// MySQL
let db = DbNexusAdapter::new("mysql://user:pass@localhost/logs", 10).await?;

// SQLite
let db = DbNexusAdapter::new("sqlite://logs.db", 1).await?;

pub async fn with_table_name( url: &str, pool_size: u32, table_name: &str, ) -> Result<Self, InklogError>

创建带有自定义表名的适配器

参数

• url - 数据库连接字符串
• pool_size - 连接池大小（最大连接数）
• table_name - 日志表名称

pub async fn with_full_config( url: &str, pool_size: u32, table_name: &str, permissions_path: Option<String>, admin_role: &str, ) -> Result<Self, InklogError>

创建带完整配置的适配器

支持自定义权限配置文件路径和管理员角色名。 构造完成后自动调用 ensure_table_exists() 创建日志表。

参数

• url - 数据库连接字符串
• pool_size - 连接池大小（最大连接数）
• table_name - 日志表名称
• permissions_path - 权限配置文件路径，None 时不启用权限校验
• admin_role - 管理员角色名

pub fn from_pool(pool: DbPool, table_name: &str) -> Result<Self, InklogError>

从现有 DbPool 创建适配器

用于需要共享连接池的场景。

参数

• pool - 已创建的连接池实例
• table_name - 日志表名称

pub fn from_connection_pool( pool: Arc<dyn ConnectionPool + Send + Sync>, table_name: &str, ) -> Result<Self, InklogError>

从已有的 ConnectionPool trait 对象创建适配器

用于 trait-kit DI 场景：kit 提供 Arc<dyn ConnectionPool + Send + Sync>， 直接包装为 Database trait 实现，无需重新创建连接池。

参数

• pool - dbnexus 连接池 trait 对象（通常来自 kit.require::<DbNexusModule>()）
• table_name - 日志表名称

pub fn pool(&self) -> &dyn ConnectionPool

获取底层连接池引用

pub fn pool_arc(&self) -> Arc<dyn ConnectionPool + Send + Sync>

获取底层连接池的 Arc 克隆

用于需要共享连接池创建新适配器的场景（见 Self::from_connection_pool）。

pub fn table_name(&self) -> &str

获取表名

Trait Implementations

impl Database for DbNexusAdapter

fn insert_batch<'life0, 'life1, 'async_trait>( &'life0 self, records: &'life1 [LogRecord], ) -> Pin<Box<dyn Future<Output = Result<usize, InklogError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

批量插入日志记录

fn is_healthy<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

检查数据库健康状态