2026-01-28 13:38:57 +00:00
|
|
|
#![cfg(feature = "sqlite")]
|
|
|
|
|
|
|
|
|
|
use sqlx::Sqlite;
|
|
|
|
|
|
|
|
|
|
mod common;
|
|
|
|
|
|
|
|
|
|
#[tokio::test]
|
|
|
|
|
async fn execute() {
|
2026-02-26 17:33:09 +00:00
|
|
|
let observability =
|
|
|
|
|
opentelemetry_testing::ObservabilityContainer::create().await;
|
2026-01-28 13:38:57 +00:00
|
|
|
let provider = observability.install().await;
|
|
|
|
|
|
|
|
|
|
let pool = sqlx::SqlitePool::connect(":memory:").await.unwrap();
|
|
|
|
|
let pool = sqlx_tracing::Pool::from(pool);
|
|
|
|
|
|
2026-02-26 17:33:09 +00:00
|
|
|
common::should_trace(
|
|
|
|
|
"trace_pool",
|
|
|
|
|
"sqlite",
|
|
|
|
|
&observability,
|
|
|
|
|
&provider,
|
|
|
|
|
&pool,
|
|
|
|
|
)
|
|
|
|
|
.await;
|
2026-01-28 13:38:57 +00:00
|
|
|
|
|
|
|
|
{
|
|
|
|
|
let mut conn = pool.acquire().await.unwrap();
|
2026-02-26 17:33:09 +00:00
|
|
|
common::should_trace(
|
|
|
|
|
"trace_conn",
|
|
|
|
|
"sqlite",
|
|
|
|
|
&observability,
|
|
|
|
|
&provider,
|
|
|
|
|
&mut conn,
|
|
|
|
|
)
|
|
|
|
|
.await;
|
2026-01-28 13:38:57 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
{
|
2026-02-26 17:33:09 +00:00
|
|
|
let mut tx: sqlx_tracing::Transaction<'_, Sqlite> =
|
|
|
|
|
pool.begin().await.unwrap();
|
2026-01-28 13:38:57 +00:00
|
|
|
common::should_trace(
|
|
|
|
|
"trace_tx",
|
|
|
|
|
"sqlite",
|
|
|
|
|
&observability,
|
|
|
|
|
&provider,
|
|
|
|
|
&mut tx.executor(),
|
|
|
|
|
)
|
|
|
|
|
.await;
|
|
|
|
|
}
|
|
|
|
|
}
|