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
//! Async optimizations for high-performance database operations.
//!
//! This module provides utilities for:
//! - **Concurrent execution**: Run independent database operations in parallel
//! - **Pipelined operations**: Execute multiple queries with minimal round-trips
//! - **Introspection optimization**: Fetch schema metadata concurrently
//!
//! # Performance Gains
//!
//! | Optimization | Use Case | Typical Improvement |
//! |--------------|----------|---------------------|
//! | Concurrent introspection | `db pull` with many tables | 40-60% faster |
//! | Parallel trigger creation | Migrations with procedures | 30-50% faster |
//! | Pipelined bulk ops | Batch inserts/updates | 50-70% faster |
//!
//! # Example
//!
//! ```rust,ignore
//! use prax_query::async_optimize::{
//! concurrent::{ConcurrentExecutor, ConcurrencyConfig},
//! pipeline::{QueryPipeline, PipelineConfig},
//! };
//!
//! // Concurrent execution with controlled parallelism
//! let executor = ConcurrentExecutor::new(ConcurrencyConfig::default());
//! let results = executor.execute_all(tasks).await?;
//!
//! // Pipelined database operations
//! let pipeline = QueryPipeline::new(PipelineConfig::default())
//! .add_query("SELECT * FROM users WHERE id = $1", vec![1.into()])
//! .add_query("SELECT * FROM posts WHERE author_id = $1", vec![1.into()]);
//! let results = pipeline.execute(&client).await?;
//! ```
pub use ;
pub use ;
pub use ;