mirror of
https://github.com/launchbadge/sqlx.git
synced 2025-12-30 13:20:59 +00:00
469f22788e
* refactor: introduce `SqlSafeStr` API * rebase main * Add SqlStr + remove Statement lifetime * Update the definition of Executor and AnyConnectionBackend + update Postgres driver * Update MySql driver * Update Sqlite driver * remove debug clone count * Reduce the amount of SqlStr clones * improve QueryBuilder error message * cargo fmt * fix clippy warnings * fix doc test * Avoid panic in `QueryBuilder::reset` * Use `QueryBuilder` when removing all test db's * Add comment to `SqlStr` Co-authored-by: Austin Bonander <austin.bonander@gmail.com> * Update sqlx-core/src/query_builder.rs Co-authored-by: Austin Bonander <austin.bonander@gmail.com> * Add `Clone` as supertrait to `Statement` * Move `Connection`, `AnyConnectionBackend` and `TransactionManager` to `SqlStr` * Replace `sql_cloned` with `sql` in `Statement` * Update `Executor` trait * Update unit tests + QueryBuilder changes * Remove code in comments * Update comment in `QueryBuilder` * Fix clippy warnings * Update `Migrate` comment * Small changes * Move `Migration` to `SqlStr` --------- Co-authored-by: Austin Bonander <austin.bonander@gmail.com>
74 lines
2.0 KiB
Rust
74 lines
2.0 KiB
Rust
use sqlx::mysql::MySql;
|
|
use sqlx::{Column, Executor, SqlSafeStr, Type, TypeInfo};
|
|
use sqlx_test::new;
|
|
|
|
#[sqlx_macros::test]
|
|
async fn it_describes_simple() -> anyhow::Result<()> {
|
|
let mut conn = new::<MySql>().await?;
|
|
|
|
let d = conn.describe("SELECT * FROM tweet".into_sql_str()).await?;
|
|
|
|
assert_eq!(d.columns()[0].name(), "id");
|
|
assert_eq!(d.columns()[1].name(), "created_at");
|
|
assert_eq!(d.columns()[2].name(), "text");
|
|
assert_eq!(d.columns()[3].name(), "owner_id");
|
|
|
|
assert_eq!(d.nullable(0), Some(false));
|
|
assert_eq!(d.nullable(1), Some(false));
|
|
assert_eq!(d.nullable(2), Some(false));
|
|
assert_eq!(d.nullable(3), Some(true));
|
|
|
|
assert_eq!(d.columns()[0].type_info().name(), "BIGINT");
|
|
assert_eq!(d.columns()[1].type_info().name(), "TIMESTAMP");
|
|
assert_eq!(d.columns()[2].type_info().name(), "TEXT");
|
|
assert_eq!(d.columns()[3].type_info().name(), "BIGINT");
|
|
|
|
Ok(())
|
|
}
|
|
|
|
#[sqlx_macros::test]
|
|
async fn test_boolean() -> anyhow::Result<()> {
|
|
let mut conn = new::<MySql>().await?;
|
|
|
|
conn.execute(
|
|
r#"
|
|
CREATE TEMPORARY TABLE with_bit_and_tinyint (
|
|
id INT PRIMARY KEY AUTO_INCREMENT,
|
|
value_bit_1 BIT(1),
|
|
value_bool BOOLEAN,
|
|
bit_n BIT(64),
|
|
value_int TINYINT
|
|
);
|
|
"#,
|
|
)
|
|
.await?;
|
|
|
|
let d = conn
|
|
.describe("SELECT * FROM with_bit_and_tinyint".into_sql_str())
|
|
.await?;
|
|
|
|
assert_eq!(d.column(2).name(), "value_bool");
|
|
assert_eq!(d.column(2).type_info().name(), "BOOLEAN");
|
|
|
|
assert_eq!(d.column(1).name(), "value_bit_1");
|
|
assert_eq!(d.column(1).type_info().name(), "BIT");
|
|
|
|
assert!(<bool as Type<MySql>>::compatible(&d.column(1).type_info()));
|
|
assert!(<bool as Type<MySql>>::compatible(&d.column(2).type_info()));
|
|
|
|
Ok(())
|
|
}
|
|
|
|
#[sqlx_macros::test]
|
|
async fn uses_alias_name() -> anyhow::Result<()> {
|
|
let mut conn = new::<MySql>().await?;
|
|
|
|
let d = conn
|
|
.describe("SELECT text AS tweet_text FROM tweet".into_sql_str())
|
|
.await?;
|
|
|
|
assert_eq!(d.columns()[0].name(), "tweet_text");
|
|
|
|
Ok(())
|
|
}
|