Enum Database 

pub enum Database {
    Sqlite(Database),
    PostgreSQL(Database),
    MySQL(Database),
    MSSQL(Database),
}

统一的 Database 枚举

Variants

Sqlite(Database)

PostgreSQL(Database)

MySQL(Database)

MSSQL(Database)

Implementations

impl Database

pub async fn connect(db_type: DbType, connection_string: &str) -> Result<Self>

连接到数据库,根据 DbType 选择后端

pub fn create_table<T: Model>(&self) -> CreateTableExecutor<'_, T>

创建表 - 返回执行器

pub async fn validate_table<T: Model>(&self) -> Result<()>

验证表结构

pub fn insert<I: Insertable>(&self, models: I) -> InsertExecutor<'_, I>

插入记录 - 返回执行器

pub fn insert_or_update<I: Insertable>( &self, models: I, ) -> InsertOrUpdateExecutor<'_, I>

插入或更新记录 - 返回执行器

pub fn insert_or_ignore<I: Insertable>( &self, models: I, ) -> InsertOrIgnoreExecutor<'_, I>

插入或忽略记录 - 返回执行器（存在重复主键时忽略）

pub async fn find_by_id<T: Model + 'static + Send + Sync>( &self, key: impl PrimaryKey, ) -> Result<Option<T>>

根据主键查找单条记录 支持单主键和复合主键

// 单主键
let user: Option<User> = db.find_by_id::<User>(1).await?;
// 复合主键
let record: Option<OrderItem> = db.find_by_id::<OrderItem>((1, 2)).await?;

pub fn select<T: Model>(&self) -> SelectExecutor<'_, T>

创建 Select 查询执行器

pub fn select_column<T: Model, V>(&self) -> GroupedSelectExecutor<'_, T, V>

创建分组聚合查询执行器

pub fn delete<T: Model>(&self) -> DeleteExecutor<'_, T>

创建 Delete 执行器

pub fn update<T: Model>(&self) -> UpdateExecutor<'_, T>

创建 Update 执行器

pub fn from<T: Model + 'static, R: Model>( &self, ) -> RelatedSelectExecutor<'_, T, R>

创建 Related 查询执行器（关联查询）

pub async fn begin(&self) -> Result<Transaction<'_>>

开始事务

pub fn drop_table<T: Model>(&self) -> DropTableExecutor<'_, T>

删除表 - 返回执行器

pub async fn execute<T: Model>(&self, sql: &str) -> Result<Vec<T>>

执行原生 SQL 查询并返回模型列表

pub async fn exec_table<T: Model>(&self, sql: &str) -> Result<Vec<T>>

👎Deprecated since 0.1.0:

请使用 execute 方法

执行原生 SQL 查询并返回模型列表（向后兼容）

pub async fn exec_non_query(&self, sql: &str) -> Result<u64>

执行原生非查询 SQL 并返回影响的行数

pub fn create_pool(db_type: DbType, connection_string: &str) -> PoolBuilder

创建连接池