What is going wrong then

crates/query-engine/translation/src/translation/mutation/v2/common.rs

@@ -107,7 +107,7 @@ pub struct CheckArgument {
 // but now we are able to override this
 pub fn get_version_prefix(mutations_prefix: &Option<String>) -> String {
     match mutations_prefix {
-        None => "v2_".to_string(),
+        None => format!("{}_", super::VERSION),
         Some(str) => match str.as_str() {
             "" => String::new(),
             _ => format!("{str}_"),

crates/query-engine/translation/src/translation/mutation/v2/delete.rs

@@ -6,7 +6,6 @@ use crate::translation::helpers::{self, TableSourceAndReference};
 use crate::translation::query::filtering;
 use crate::translation::query::values;
 use ndc_models as models;
-use ndc_postgres_configuration::Configuration;
 use nonempty::NonEmpty;
 use query_engine_metadata::metadata;
 use query_engine_metadata::metadata::database;

crates/query-engine/translation/src/translation/mutation/v2/generate.rs

@@ -30,11 +30,13 @@ pub fn generate(
         }
 
         // Insert mutations.
-        let (name, insert_mutation) = insert::generate(collection_name, table_info);
+        let (name, insert_mutation) =
+            insert::generate(collection_name, table_info, mutations_prefix);
         mutations.insert(name, Mutation::InsertMutation(insert_mutation));
 
         // Update mutations.
-        let update_mutations = generate_update_by_unique(collection_name, table_info);
+        let update_mutations =
+            generate_update_by_unique(collection_name, table_info, mutations_prefix);
         for (name, update_mutation) in update_mutations {
             mutations.insert(name, Mutation::UpdateMutation(update_mutation));
         }

crates/query-engine/translation/src/translation/mutation/v2/insert.rs

@@ -11,7 +11,7 @@ use query_engine_metadata::metadata::database;
 use query_engine_sql::sql;
 use std::collections::{BTreeMap, BTreeSet};
 
-use super::common::CheckArgument;
+use super::common::{self, CheckArgument};
 
 /// A representation of an auto-generated insert mutation.
 ///
@@ -31,8 +31,13 @@ pub struct InsertMutation {
 pub fn generate(
     collection_name: &models::CollectionName,
     table_info: &database::TableInfo,
+    mutations_prefix: &Option<String>,
 ) -> (models::ProcedureName, InsertMutation) {
-    let name = format!("insert_{collection_name}").into();
+    let name = format!(
+        "{}insert_{collection_name}",
+        common::get_version_prefix(mutations_prefix)
+    )
+    .into();
 
     let description = format!("Insert into the {collection_name} table");
 

crates/query-engine/translation/src/translation/mutation/v2/translate.rs

@@ -5,7 +5,6 @@ use std::collections::BTreeMap;
 use crate::translation::error::Error;
 use crate::translation::helpers::{Env, State};
 use ndc_models as models;
-use ndc_postgres_configuration::Configuration;
 use query_engine_sql::sql;
 
 /// Translate a built-in delete mutation into an ExecutionPlan (SQL) to be run against the database.

crates/query-engine/translation/src/translation/mutation/v2/update.rs

@@ -48,6 +48,7 @@ pub struct Constraint {
 pub fn generate_update_by_unique(
     collection_name: &models::CollectionName,
     table_info: &database::TableInfo,
+    mutations_prefix: &Option<String>,
 ) -> Vec<(models::ProcedureName, UpdateMutation)> {
     table_info
         .uniqueness_constraints
@@ -63,7 +64,11 @@ pub fn generate_update_by_unique(
                     keys,
                 )?;
 
-            let name = format!("update_{collection_name}_by_{constraint_name}").into();
+            let name = format!(
+                "{}update_{collection_name}_by_{constraint_name}",
+                common::get_version_prefix(mutations_prefix)
+            )
+            .into();
 
             let description = format!(
                 "Update any row on the '{collection_name}' collection using the {}",