(
&self,
session: &mut Session,
plan: plan::ExecutePlan,
)
| 4285 | // Returns the name of the portal to execute. |
| 4286 | #[instrument] |
| 4287 | pub(super) fn sequence_execute( |
| 4288 | &self, |
| 4289 | session: &mut Session, |
| 4290 | plan: plan::ExecutePlan, |
| 4291 | ) -> Result<String, AdapterError> { |
| 4292 | // Verify the stmt is still valid. |
| 4293 | Self::verify_prepared_statement(self.catalog(), session, &plan.name)?; |
| 4294 | let ps = session |
| 4295 | .get_prepared_statement_unverified(&plan.name) |
| 4296 | .expect("known to exist"); |
| 4297 | let stmt = ps.stmt().cloned(); |
| 4298 | let desc = ps.desc().clone(); |
| 4299 | let state_revision = ps.state_revision; |
| 4300 | let logging = Arc::clone(ps.logging()); |
| 4301 | session.create_new_portal(stmt, logging, desc, plan.params, Vec::new(), state_revision) |
| 4302 | } |
| 4303 | |
| 4304 | #[instrument] |
| 4305 | pub(super) async fn sequence_grant_privileges( |
no test coverage detected