e57c15b3ce
* wip: vendor sqlx-tracing * (compiles) standardize pg types used * more standardization * general log message improvements * wip: improve sqlx-tracing architecture * unify sqlx::Executor type * wip: try fix sqlx tracing * wip: sqlx-tracing compiles * so close * it compiles * fix ci
34 lines
896 B
Rust
34 lines
896 B
Rust
#![cfg(feature = "sqlite")]
|
|
|
|
use sqlx::Sqlite;
|
|
|
|
mod common;
|
|
|
|
#[tokio::test]
|
|
async fn execute() {
|
|
let observability = opentelemetry_testing::ObservabilityContainer::create().await;
|
|
let provider = observability.install().await;
|
|
|
|
let pool = sqlx::SqlitePool::connect(":memory:").await.unwrap();
|
|
let pool = sqlx_tracing::Pool::from(pool);
|
|
|
|
common::should_trace("trace_pool", "sqlite", &observability, &provider, &pool).await;
|
|
|
|
{
|
|
let mut conn = pool.acquire().await.unwrap();
|
|
common::should_trace("trace_conn", "sqlite", &observability, &provider, &mut conn).await;
|
|
}
|
|
|
|
{
|
|
let mut tx: sqlx_tracing::Transaction<'_, Sqlite> = pool.begin().await.unwrap();
|
|
common::should_trace(
|
|
"trace_tx",
|
|
"sqlite",
|
|
&observability,
|
|
&provider,
|
|
&mut tx.executor(),
|
|
)
|
|
.await;
|
|
}
|
|
}
|