Method query

src/query/query_handler.rs:32–45

(&self, sql: &str)

#[async_trait]
impl QueryHandler for QueryHandlerImpl {
    async fn query(&self, sql: &str) -> Result<DbResponse, PgSqliteError> {
        match self {
            QueryHandlerImpl::Direct(db) => {
                db.query(sql).await
            },
            QueryHandlerImpl::Routed(router) => {
                // For routed queries, we need the session state to determine transaction status
                // For now, we'll create a temporary session state - this needs to be refactored
                let session = SessionState::new("temp".to_string(), "temp".to_string());
                router.execute_query(sql, &session).await
                    .map_err(|e| PgSqliteError::Protocol(e.to_string()))
            }
        }
    }
    
    async fn execute(&self, sql: &str) -> Result<DbResponse, PgSqliteError> {
        match self {