(&self, update: &Update)
| 919 | } |
| 920 | |
| 921 | async fn handle_update(&self, update: &Update) -> DFResult<DataFrame> { |
| 922 | let table_name = match &update.table.relation { |
| 923 | TableFactor::Table { name, .. } => name.clone(), |
| 924 | other => { |
| 925 | return Err(DataFusionError::Plan(format!( |
| 926 | "Unsupported target table in UPDATE: {other}" |
| 927 | ))) |
| 928 | } |
| 929 | }; |
| 930 | let (catalog, _catalog_name, identifier) = self.resolve_catalog_and_table(&table_name)?; |
| 931 | |
| 932 | let table = catalog |
| 933 | .get_table(&identifier) |
| 934 | .await |
| 935 | .map_err(to_datafusion_error)?; |
| 936 | |
| 937 | crate::update::execute_update(self, update, table).await |
| 938 | } |
| 939 | |
| 940 | async fn handle_delete(&self, delete: &Delete) -> DFResult<DataFrame> { |
| 941 | let tables = match &delete.from { |
no test coverage detected