9 个版本 (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 日 |
#2875 in 数据库接口
61 次每月下载
用于 canyon_sql
275KB
5K SLoC
CANYON-SQL
适用于多个数据库的全功能 Rust ORM。
Canyon-SQL
是用于处理多个数据库的并发操作的高级抽象。它基于 async
语言特性,为消费者提供高速、高性能的库来处理数据访问。
免责声明(早期阶段)
此库仍处于 早期阶段
。我们非常欢迎通过 fork
+ PR
的方式做出贡献。目前我们正在积极开发此项目。
完整文档资源
有一个 work-in-progress
网页,使用 mdBook
构建,包含官方文档。在这里您可以找到 Canyon-SQL
的所有技术文档。您可以点击此链接 阅读
最重要的功能
- 默认异步。几乎每个提供的功能都准备好用于并发消费。
- 使用多个数据源。您可以同时查询多个数据库,甚至不同的数据库!这意味着您将能够在同一项目中并发查询
PostgreSQL
数据库和SqlServer
数据库。 - 基于宏。通过一些注解和配置文件,您就可以编写数据访问代码。
- 支持迁移。
Canyon-SQL
带有一个 神模式,可以为您管理数据库中的每个表。您可以在Canyon
代码中修改表结构,例如更改列、设置约束等。此外,未来我们还计划允许您以编程方式操作整个服务器,例如创建数据库、更改配置等,一切都可以通过Canyon
实现!
支持的数据库
Canyon-SQL
目前支持以下数据库
- PostgreSQL(通过
tokio-postgres
crate) - SqlServer(通过
tiberius
crate)
上述每个 crate 都是基于 async
的 crate,符合 Canyon-SQL
的设计规范。
计划支持更多数据库引擎。
通过示例说明
让我们来看看 Canyon
代码的样子!
经典的 SELECT * FROM {table_name}
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>
trait,用于构建更复杂的 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 的常规流程。它会尝试检索声明的每个字段的值。如果您没有声明在开放子句中(在本例中为 (*))的字段,则该字段将不会被检索。没问题。但如果您有无法与数据库中的某些列映射的字段,程序将崩溃。
更多示例
如果您想查看更多示例,可以查看该存储库根目录下的 tests
文件夹。每个可用的数据库操作都在那里进行了测试,因此您可以使用它来查找上述文档中描述的操作的使用方法。
为 CANYON-SQL 做出贡献
首先,感谢您考虑帮助我们项目。您可以查看我们的 模板指南。
但,为了总结
- 查看已打开的问题,以查看是否已存在或有人正在解决它。即使如此,您也可以进入参与并说明您的观点,甚至帮助完成任务
- 对
Canyon-SQL
进行分支 - 如果您打开了问题,从存储库的基本分支(即默认分支)创建一个分支,并将其指向您的分支
- 完成更改后,向默认分支打开一个
PR
。尽可能填写提供的模板 - 等待批准。在大多数情况下,在批准您的更改之前,需要对功能进行测试
关于测试呢?
通常在 Canyon
中,隔离的单元测试以 doc-tests 的形式编写,而集成测试位于 ./tests
文件夹下。
如果您想运行测试(因为这是您fork仓库后想要做的第一件事),在运行测试之前需要考虑一些事项。
- 目标机器需要安装 Docker。
- 如果您已经安装了 Docker,并且已经克隆或fork了
Canyon-SQL
,您可以通过运行我们的 docker-compose 文件(docker/docker-compose.yml)
来运行测试,这将初始化一个PostgreSQL
数据库,并将内容放在上面,以便测试能够运行。 - 最后,有一些测试针对
MSSQL
运行。我们没有找到在 Docker 启动时直接插入数据的好方法,而是运行一个位于tests/crud/mod.rs
的非常特殊的测试,命名为initialize_sql_server_docker_instance
。当您运行此测试时,初始数据将被插入到当测试运行时创建的表中。(如果您知道更好的方法,请创建一个问题让我们知道,并改进此过程!)
依赖项
~9–24MB
~349K SLoC