<table>Column typess - towards onConflict clause

Author: olirice

src/graphql.rs

@@ -1095,6 +1095,7 @@ impl ConnectionType {
 pub enum EnumSource {
     Enum(Arc<Enum>),
     FilterIs,
+    TableColumns(Arc<Table>),
 }
 
 #[derive(Clone, Debug, Eq, PartialEq, Hash)]
@@ -1426,22 +1427,40 @@ impl ___Type for MutationType {
                         table: Arc::clone(table),
                         schema: Arc::clone(&self.schema),
                     }),
-                    args: vec![__InputValue {
-                        name_: "objects".to_string(),
-                        type_: __Type::NonNull(NonNullType {
-                            type_: Box::new(__Type::List(ListType {
-                                type_: Box::new(__Type::NonNull(NonNullType {
-                                    type_: Box::new(__Type::InsertInput(InsertInputType {
-                                        table: Arc::clone(table),
-                                        schema: Arc::clone(&self.schema),
+                    args: vec![
+                        __InputValue {
+                            name_: "objects".to_string(),
+                            type_: __Type::NonNull(NonNullType {
+                                type_: Box::new(__Type::List(ListType {
+                                    type_: Box::new(__Type::NonNull(NonNullType {
+                                        type_: Box::new(__Type::InsertInput(InsertInputType {
+                                            table: Arc::clone(table),
+                                            schema: Arc::clone(&self.schema),
+                                        })),
                                     })),
                                 })),
-                            })),
-                        }),
-                        description: None,
-                        default_value: None,
-                        sql_type: None,
-                    }],
+                            }),
+                            description: None,
+                            default_value: None,
+                            sql_type: None,
+                        },
+                        __InputValue {
+                            name_: "update".to_string(),
+                            type_: __Type::NonNull(NonNullType {
+                                type_: Box::new(__Type::List(ListType {
+                                    type_: Box::new(__Type::NonNull(NonNullType {
+                                        type_: Box::new(__Type::InsertInput(InsertInputType {
+                                            table: Arc::clone(table),
+                                            schema: Arc::clone(&self.schema),
+                                        })),
+                                    })),
+                                })),
+                            }),
+                            description: None,
+                            default_value: None,
+                            sql_type: None,
+                        },
+                    ],
                     description: Some(format!(
                         "Adds one or more `{}` records to the collection",
                         table_base_type_name
@@ -1629,6 +1648,10 @@ impl ___Type for EnumType {
                 )
             }
             EnumSource::FilterIs => Some("FilterIs".to_string()),
+            EnumSource::TableColumns(table) => Some(format!(
+                "{}Field",
+                self.schema.graphql_table_base_type_name(&table)
+            )),
         }
     }
 
@@ -1667,6 +1690,15 @@ impl ___Type for EnumType {
                     },
                 ]
             }
+            EnumSource::TableColumns(table) => table
+                .columns
+                .iter()
+                .map(|col| __EnumValue {
+                    name: self.schema.graphql_column_field_name(col),
+                    description: None,
+                    deprecation_reason: None,
+                })
+                .collect(),
         })
     }
 }
@@ -4160,6 +4192,11 @@ impl __Schema {
                     table: Arc::clone(table),
                     schema: Arc::clone(&schema_rc),
                 }));
+                // Used by on conflict
+                types_.push(__Type::Enum(EnumType {
+                    enum_: EnumSource::TableColumns(Arc::clone(table)),
+                    schema: Arc::clone(&schema_rc),
+                }));
             }
 
             if self.graphql_table_update_types_are_valid(table) {

src/parser_util.rs

@@ -412,6 +412,8 @@ pub fn validate_arg_from_type(type_: &__Type, value: &gson::Value) -> Result<gso
                                     .map(|val| GsonValue::String(val.clone()))
                                     .unwrap_or_else(|| value.clone()),
                                 EnumSource::FilterIs => value.clone(),
+                                // TODO(or): Do I need to check directives here?
+                                EnumSource::TableColumns(_e) => value.clone(),
                             }
                         }
                         None => return Err(format!("Invalid input for {} type", enum_name)),