10个版本 (4个重大更新)

0.5.0 2023年12月10日
0.4.2 2023年5月3日
0.4.1 2023年4月23日
0.3.1 2023年4月20日
0.1.0 2022年12月25日

#2131数据库接口


4 crate 中使用

MIT 许可证

115KB
2K SLoC

CANYON-SQL

一个全栈式的Rust ORM,支持多种数据库。

  • crates.io
  • Continuous Integration
  • Code Quality
  • Code Coverage Measure
  • Code Coverage Status

Canyon-SQL 是一个高级抽象,用于同时操作多个数据库。它基于 async 语言特性,为用户提供一个高速、高性能的库来处理数据访问。

早期声明

该库仍处于 早期阶段。任何通过 fork + PR 的贡献都将非常感激。目前我们正在进行该项目的非常活跃的开发。

完整文档资源

有一个 work-in-progress 网页,使用 mdBook 构建,包含官方文档。这里您可以找到 Canyon-SQL 的所有技术文档。您可以 点击此链接 阅读它

最重要的功能

  • 默认异步。几乎每个提供的功能都支持并发使用。
  • 使用多个数据源。您可以同时查询多个数据库,甚至不同的数据库!这意味着您将能够在同一项目中并发查询 PostgreSQL 数据库和 SqlServer 数据库。
  • 基于宏。只需几个注解和一个配置文件,您就可以开始编写数据访问代码。
  • 支持迁移。 Canyon-SQL 内置“神模式”,可为您管理数据库中的每个表。您可以在 Canyon 代码中内部修改表,如更改列、设置约束等。此外,未来我们计划允许您以编程方式操作整个服务器,例如创建数据库、更改配置等,一切尽在 Canyon

支持的数据库

Canyon-SQL 目前支持以下数据库

  • PostgreSQL(通过 tokio-postgres 包)
  • SqlServer(通过 tiberius 包)

上述所有包都是基于异步的包,符合 Canyon-SQL 设计指南。

计划添加更多数据库引擎。

通过示例说明

让我们看看 Canyon 代码的样子!

经典的 SELECT * FROM {表名}

let find_all_result: Result<Vec<League>, Box<dyn Error + Send + Sync>> =  League::find_all().await;

// Connection doesn't return an error
assert!(find_all_result.is_ok());
// We retrieved elements from the League table
assert!(!find_all_result.unwrap().is_empty());

在主键列上执行搜索

let find_by_pk_result: Result<Option<League>, Box<dyn Error + Send + Sync>> = League::find_by_pk(&1).await;

assert!(find_by_pk_result.as_ref().unwrap().is_some());

let some_league = find_by_pk_result.unwrap().unwrap();
assert_eq!(some_league.id, 1);
assert_eq!(some_league.ext_id, 100695891328981122_i64);
assert_eq!(some_league.slug, "european-masters");
assert_eq!(some_league.name, "European Masters");
assert_eq!(some_league.region, "EUROPE");
assert_eq!(
    some_league.image_url,
    "http://static.lolesports.com/leagues/EM_Bug_Outline1.png"
);

注意 find_by_pk(...) 参数的起始引用。这个相关函数接收一个 &dyn QueryParameter<'_> 作为参数,而不是一个值。

构建更复杂的查询

为了展示 Canyon 的功能,我们将使用 SelectQueryBuilder<T>,它实现了 QueryBuilder<T> 特性,用于构建更复杂的 where 条件、过滤数据和连接表。

let mut select_with_joins = LeagueTournament::select_query();
    select_with_joins
        .inner_join("tournament", "league.id", "tournament.league_id")
        .left_join("team", "tournament.id", "player.tournament_id")
        .r#where(LeagueFieldValue::id(&7), Comp::Gt)
        .and(LeagueFieldValue::name(&"KOREA"), Comp::Eq)
        .and_values_in(LeagueField::name, &["LCK", "STRANGER THINGS"]);
    // NOTE: We don't have in the docker the generated relationships
    // with the joins, so for now, we are just going to check that the
    // generated SQL by the SelectQueryBuilder<T> is the spected
    assert_eq!(
        select_with_joins.read_sql(),
        "SELECT * FROM league INNER JOIN tournament ON league.id = tournament.league_id LEFT JOIN team ON tournament.id = player.tournament_id WHERE id > $1 AND name = $2  AND name IN ($2, $3) "
    )

注意:目前,当您使用连接时,您需要创建一个新的模型,其中包含两个表中的列(如果您希望这些列中的数据),但只需遵循 CanyonMapper 的常规流程。它将尝试获取每个声明的字段的值。如果您没有声明在 open 子句中(在这种情况下 (*))的字段,则该字段将不会被检索。没问题。但如果您有与数据库中某些列无法映射的字段,程序将崩溃。

更多示例

如果您想看到更多示例,可以查看存储库根目录下的 tests 文件夹。每个可用的数据库操作都进行了测试,因此您可以使用它来查找上述文档中描述的操作的使用方法。

为 CANYON-SQL 做贡献

首先,感谢您考虑帮助我们项目。您可以查看我们的 模板指南

但,为了总结

  • 查看已经打开的问题,看看是否已经有人处理了这个问题。即使如此,您也可以进入参与并说明您的观点,甚至帮助完成任务。
  • Canyon-SQL 创建分叉
  • 如果您创建了一个问题,从存储库的基本分支(这是默认分支)创建一个分支,并将其指向您的分叉
  • 完成更改后,向默认分支打开一个 PR。尽可能好地填写提供的模板
  • 等待批准。在大多数情况下,在批准您的更改之前,需要对这个功能进行测试

关于测试怎么办?

通常在 Canyon 中,隔离的单元测试被编写为 doc-tests,集成测试位于 ./tests 文件夹下

如果您想运行测试(因为这是您克隆仓库后想要做的第一件事),在运行之前需要考虑一些事情。

  • 您需要在目标机器上安装 Docker
  • 如果您有 Docker,并且已经克隆或分叉了 Canyon-SQL,您可以通过运行我们的 docker-compose 文件 (docker/docker-compose.yml) 来运行测试,这将初始化一个 PostgreSQL 数据库并在其上放置内容,使测试能够运行。
  • 最后,一些测试针对 MSSQL。我们没有找到在 Docker 启动时直接插入数据的好方法,而是运行了一个非常特殊的测试,位于 tests/crud/mod.rs,名为 initialize_sql_server_docker_instance。当您运行此测试时,将向在测试运行时创建的表插入初始数据。(如果您知道更好的方法,请打开一个 issue 通知我们,并改进此过程!)

依赖项

~8–23MB
~334K SLoC