1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
#[macro_export]
macro_rules! mssql_executor_alias {
(
$pub:vis $name:ident
) => {
$pub trait $name<'c>: sqlx::MssqlExecutor<'c> {}
impl<'c, T: sqlx::MssqlExecutor<'c>> $name<'c> for T {}
};
}
#[macro_export]
macro_rules! mysql_executor_alias {
(
$pub:vis $name:ident
) => {
$pub trait $name<'c>: sqlx::MySqlExecutor<'c> {}
impl<'c, T: sqlx::MySqlExecutor<'c>> $name<'c> for T {}
};
}
#[macro_export]
macro_rules! postgres_executor_alias {
(
$pub:vis $name:ident
) => {
$pub trait $name<'c>: sqlx::PgExecutor<'c> {}
impl<'c, T: sqlx::PgExecutor<'c>> $name<'c> for T {}
};
}
#[macro_export]
macro_rules! sqlite_executor_alias {
(
$pub:vis $name:ident
) => {
$pub trait $name<'c>: sqlx::SqliteExecutor<'c> {}
impl<'c, T: sqlx::SqliteExecutor<'c>> $name<'c> for T {}
};
}
#[cfg(test)]
mod tests {
crate::postgres_executor_alias!(pub FooPgExecutor);
crate::sqlite_executor_alias!(pub FooSqliteExecutor);
use tokio::time::{timeout, Duration};
#[tokio::test]
async fn simple() {
async fn postgres_execute<'c, E: FooPgExecutor<'c>>(executor: E) {
let _ = sqlx::query("select 1").execute(executor).await;
}
let pool = sqlx::postgres::PgPoolOptions::new()
.connect_lazy("postgres://127.0.0.1:5432")
.expect("");
match timeout(Duration::from_millis(500), postgres_execute(&pool)).await {
Ok(_) => {}
Err(_) => {
eprintln!("timeout")
}
}
#[allow(dead_code)]
async fn sqlite_execute<'c, E: FooSqliteExecutor<'c>>(executor: E) {
let _ = sqlx::query("select 1").execute(executor).await;
}
}
}