Struct Database 

pub struct Database { /* private fields */ }

数据库连接管理器

管理 MySQL 数据库连接池，提供查询构建和执行的入口点

示例

use yang_db::Database;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 连接数据库
    let db = Database::connect("mysql://user:password@localhost:3306/test").await?;
     
    // 使用查询构建器
    let builder = db.table("users")
        .field("id")
        .field("name");
     
    // 执行查询（需要实现 select 方法）
    // let users = builder.select::<User>().await?;
     
    Ok(())
}

Implementations

impl Database

pub async fn connect(url: &str) -> Result<Self, DbError>

创建数据库连接

参数

• url: 数据库连接字符串，格式：mysql://user:password@host:port/database

返回

• Ok(Database): 成功创建的数据库实例
• Err(DbError): 连接失败错误

pub async fn connect_with_config( url: &str, config: DatabaseConfig, ) -> Result<Self, DbError>

使用自定义配置创建数据库连接

pub fn table(&self, table_name: &str) -> QueryBuilder<'_>

选择表，返回查询构建器

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

where T: for<'r> FromRow<'r, MySqlRow> + Send + Unpin,

执行原生 SELECT 查询

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

执行原生 INSERT/UPDATE/DELETE 查询

pub async fn transaction(&self) -> Result<Transaction, DbError>

开始事务

pub async fn init(&self, sql_script: &str) -> Result<(), DbError>

初始化数据库（执行 SQL 脚本）

pub async fn create_table(&self, create_sql: &str) -> Result<(), DbError>

创建表

pub async fn drop_table(&self, table_name: &str) -> Result<(), DbError>

删除表

pub async fn table_exists(&self, table_name: &str) -> Result<bool, DbError>

检查表是否存在