version: 1.0.151

fixtures/queryer.json

@@ -2432,7 +2432,7 @@
               "  JOIN agreego.entity entity_2 ON entity_2.id = order_1.id",
               "  WHERE",
               "    NOT entity_2.archived",
-              "    AND order_1.counterparty_type = 'organization'",
+              "    AND order_1.counterparty_type IN ('bot', 'organization', 'person')",
               "))))"
             ]
           ]

src/queryer/compiler.rs

@@ -603,7 +603,7 @@ impl<'a> Compiler<'a> {
 
             if let Some(type_name) = bound_type_name {
               // Ensure this type actually exists
-              if self.db.types.contains_key(&type_name) {
+              if let Some(type_def) = self.db.types.get(&type_name) {
                 if let Some(relation) = self.db.relations.get(&edge.constraint) {
                   let mut poly_col = None;
                   let mut table_to_alias = "";
@@ -621,6 +621,21 @@ impl<'a> Compiler<'a> {
                       .get(table_to_alias)
                       .or_else(|| type_aliases.get(&node.parent_alias))
                     {
+                      // DEBUG: See what variations we have for this type
+                      #[cfg(not(test))]
+                      pgrx::notice!("JSPG_POLY_BOUNDS: type={}, col={}, variations_len={}, variations={:?}", type_name, col, type_def.variations.len(), type_def.variations);
+
+                      // Use IN clause with all variations to support inherited types.
+                      // e.g., "asset" has variations ["asset", "property", "unit", ...]
+                      // so target_type IN ('asset','property','unit') instead of = 'asset'
+                      if type_def.variations.len() > 1 {
+                        let quoted: Vec<String> = type_def.variations.iter()
+                          .map(|v| format!("'{}'", v))
+                          .collect();
+                        where_clauses.push(format!(
+                          "{}.{} IN ({})", alias, col, quoted.join(", ")
+                        ));
+                      } else {
                         where_clauses.push(format!("{}.{} = '{}'", alias, col, type_name));
                       }
                     }
@@ -632,6 +647,7 @@ impl<'a> Compiler<'a> {
         }
       }
     }
+  }
 
   fn resolve_filter_alias(
     r#type: &crate::database::r#type::Type,

src/queryer/mod.rs

@@ -50,6 +50,10 @@ impl Queryer {
       Err(drop) => return drop,
     };
 
+    // DEBUG: Emit compiled SQL as a NOTICE for inspection
+    #[cfg(not(test))]
+    pgrx::notice!("JSPG_SQL[{}]: {}", schema_id, sql);
+
     // 3. Execute via Database Executor
     self.execute_sql(schema_id, &sql, args)
   }

src/validator/mod.rs

@@ -42,13 +42,46 @@ impl Validator {
   }
 
   pub fn validate(&self, schema_id: &str, instance: &Value) -> crate::drop::Drop {
-    let schema_opt = self.db.schemas.get(schema_id);
+    let schema_arc = if schema_id.trim().starts_with('{') {
+      match serde_json::from_str::<crate::database::schema::Schema>(schema_id) {
+        Ok(schema) => {
+          let mut errors = Vec::new();
+          schema.compile(&self.db, "inline", "inline".to_string(), &mut errors);
+          if !errors.is_empty() {
+            return crate::drop::Drop::with_errors(errors);
+          }
+          Arc::new(schema)
+        }
+        Err(e) => {
+          return crate::drop::Drop::with_errors(vec![crate::drop::Error {
+            code: "SCHEMA_PARSE_FAILED".to_string(),
+            message: format!("Failed to parse inline schema: {}", e),
+            details: crate::drop::ErrorDetails::default(),
+          }]);
+        }
+      }
+    } else {
+      match self.db.schemas.get(schema_id) {
+        Some(schema) => Arc::clone(schema),
+        None => {
+          return crate::drop::Drop::with_errors(vec![crate::drop::Error {
+            code: "SCHEMA_NOT_FOUND".to_string(),
+            message: format!("Schema {} not found", schema_id),
+            details: crate::drop::ErrorDetails {
+              path: Some("/".to_string()),
+              cause: None,
+              context: None,
+              schema: None,
+            },
+          }]);
+        }
+      }
+    };
 
-    if let Some(schema) = schema_opt {
     let ctx = ValidationContext::new(
       &self.db,
-        &schema,
+      &schema_arc,
-        &schema,
+      &schema_arc,
       instance,
       HashSet::new(),
       false,
@@ -87,17 +120,5 @@ impl Validator {
         },
       }]),
     }
-    } else {
-      crate::drop::Drop::with_errors(vec![crate::drop::Error {
-        code: "SCHEMA_NOT_FOUND".to_string(),
-        message: format!("Schema {} not found", schema_id),
-        details: crate::drop::ErrorDetails {
-          path: Some("/".to_string()),
-          cause: None,
-          context: None,
-          schema: None,
-        },
-      }])
-    }
   }
 }

version

@@ -1 +1 @@
-1.0.149
+1.0.151