Compare commits

..

4 Commits

6 changed files with 51 additions and 4 deletions

View File

@ -70,6 +70,10 @@
"type": "string", "type": "string",
"format": "date-time" "format": "date-time"
}, },
"uuid_field": {
"type": "string",
"format": "uuid"
},
"tags": { "tags": {
"type": "array", "type": "array",
"items": { "items": {
@ -181,6 +185,17 @@
] ]
} }
} }
},
"uuid.condition": {
"type": "condition",
"properties": {
"$eq": {
"type": [
"string",
"null"
]
}
}
} }
} }
} }
@ -244,6 +259,7 @@
"billing_address", "billing_address",
"gender", "gender",
"birth_date", "birth_date",
"uuid_field",
"tags", "tags",
"ad_hoc", "ad_hoc",
"$and", "$and",
@ -258,6 +274,7 @@
"billing_address", "billing_address",
"gender", "gender",
"birth_date", "birth_date",
"uuid_field",
"tags", "tags",
"ad_hoc", "ad_hoc",
"$and", "$and",
@ -278,6 +295,7 @@
"billing_address", "billing_address",
"gender", "gender",
"birth_date", "birth_date",
"uuid_field",
"tags", "tags",
"ad_hoc", "ad_hoc",
"$and", "$and",
@ -325,6 +343,12 @@
"null" "null"
] ]
}, },
"uuid_field": {
"type": [
"uuid.condition",
"null"
]
},
"first_name": { "first_name": {
"type": [ "type": [
"string.condition", "string.condition",
@ -396,6 +420,7 @@
"string.condition": {}, "string.condition": {},
"integer.condition": {}, "integer.condition": {},
"date.condition": {}, "date.condition": {},
"uuid.condition": {},
"search": {}, "search": {},
"search.filter": { "search.filter": {
"type": "filter", "type": "filter",

View File

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

View File

@ -141,6 +141,8 @@ impl Schema {
if let Some(fmt) = &schema.obj.format { if let Some(fmt) = &schema.obj.format {
if fmt == "date-time" { if fmt == "date-time" {
return Some(vec!["date.condition".to_string()]); return Some(vec!["date.condition".to_string()]);
} else if fmt == "uuid" {
return Some(vec!["uuid.condition".to_string()]);
} }
} }
Some(vec!["string.condition".to_string()]) Some(vec!["string.condition".to_string()])

View File

@ -603,7 +603,7 @@ impl<'a> Compiler<'a> {
if let Some(type_name) = bound_type_name { if let Some(type_name) = bound_type_name {
// Ensure this type actually exists // 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) { if let Some(relation) = self.db.relations.get(&edge.constraint) {
let mut poly_col = None; let mut poly_col = None;
let mut table_to_alias = ""; let mut table_to_alias = "";
@ -621,7 +621,23 @@ impl<'a> Compiler<'a> {
.get(table_to_alias) .get(table_to_alias)
.or_else(|| type_aliases.get(&node.parent_alias)) .or_else(|| type_aliases.get(&node.parent_alias))
{ {
where_clauses.push(format!("{}.{} = '{}'", alias, col, type_name)); // 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));
}
} }
} }
} }

View File

@ -50,6 +50,10 @@ impl Queryer {
Err(drop) => return drop, 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 // 3. Execute via Database Executor
self.execute_sql(schema_id, &sql, args) self.execute_sql(schema_id, &sql, args)
} }

View File

@ -1 +1 @@
1.0.148 1.0.150