Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 9e362f2168 | |||
| 9fffc7707f | |||
| c5d652c6fd | |||
| d2cdd680ed |
@ -791,8 +791,8 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"invoice",
|
"entity",
|
||||||
"entity"
|
"invoice"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"id",
|
"id",
|
||||||
@ -867,8 +867,8 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"invoice_line",
|
"entity",
|
||||||
"entity"
|
"invoice_line"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"id",
|
"id",
|
||||||
|
|||||||
@ -110,8 +110,8 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"activity",
|
"entity",
|
||||||
"entity"
|
"activity"
|
||||||
],
|
],
|
||||||
"variations": [
|
"variations": [
|
||||||
"activity",
|
"activity",
|
||||||
@ -166,9 +166,9 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"invoice",
|
"entity",
|
||||||
"activity",
|
"activity",
|
||||||
"entity"
|
"invoice"
|
||||||
],
|
],
|
||||||
"variations": [
|
"variations": [
|
||||||
"invoice"
|
"invoice"
|
||||||
@ -237,8 +237,8 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"attachment",
|
"entity",
|
||||||
"entity"
|
"attachment"
|
||||||
],
|
],
|
||||||
"variations": [
|
"variations": [
|
||||||
"attachment"
|
"attachment"
|
||||||
|
|||||||
@ -219,8 +219,8 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"organization",
|
"entity",
|
||||||
"entity"
|
"organization"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"id",
|
"id",
|
||||||
@ -262,9 +262,9 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"user",
|
"entity",
|
||||||
"organization",
|
"organization",
|
||||||
"entity"
|
"user"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"id",
|
"id",
|
||||||
@ -359,10 +359,10 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"person",
|
"entity",
|
||||||
"user",
|
|
||||||
"organization",
|
"organization",
|
||||||
"entity"
|
"user",
|
||||||
|
"person"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"id",
|
"id",
|
||||||
@ -445,8 +445,8 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"order",
|
"entity",
|
||||||
"entity"
|
"order"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"id",
|
"id",
|
||||||
@ -504,8 +504,8 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"order_line",
|
"entity",
|
||||||
"entity"
|
"order_line"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"id",
|
"id",
|
||||||
@ -548,8 +548,8 @@
|
|||||||
"name": "relationship",
|
"name": "relationship",
|
||||||
"relationship": true,
|
"relationship": true,
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"relationship",
|
"entity",
|
||||||
"entity"
|
"relationship"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"source_id",
|
"source_id",
|
||||||
@ -611,9 +611,9 @@
|
|||||||
"name": "contact",
|
"name": "contact",
|
||||||
"relationship": true,
|
"relationship": true,
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"contact",
|
"entity",
|
||||||
"relationship",
|
"relationship",
|
||||||
"entity"
|
"contact"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"is_primary",
|
"is_primary",
|
||||||
@ -683,8 +683,8 @@
|
|||||||
{
|
{
|
||||||
"name": "phone_number",
|
"name": "phone_number",
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"phone_number",
|
"entity",
|
||||||
"entity"
|
"phone_number"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"number",
|
"number",
|
||||||
@ -741,8 +741,8 @@
|
|||||||
{
|
{
|
||||||
"name": "email_address",
|
"name": "email_address",
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"email_address",
|
"entity",
|
||||||
"entity"
|
"email_address"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"address",
|
"address",
|
||||||
@ -834,8 +834,8 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"attachment",
|
"entity",
|
||||||
"entity"
|
"attachment"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"id",
|
"id",
|
||||||
@ -887,8 +887,8 @@
|
|||||||
{
|
{
|
||||||
"name": "account",
|
"name": "account",
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"account",
|
"entity",
|
||||||
"entity"
|
"account"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"id",
|
"id",
|
||||||
@ -1031,8 +1031,8 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"invoice",
|
"entity",
|
||||||
"entity"
|
"invoice"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"id",
|
"id",
|
||||||
@ -1107,8 +1107,8 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"hierarchy": [
|
"hierarchy": [
|
||||||
"invoice_line",
|
"entity",
|
||||||
"entity"
|
"invoice_line"
|
||||||
],
|
],
|
||||||
"fields": [
|
"fields": [
|
||||||
"id",
|
"id",
|
||||||
@ -1309,10 +1309,10 @@
|
|||||||
"sql": [
|
"sql": [
|
||||||
[
|
[
|
||||||
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*) || to_jsonb(t3.*) || to_jsonb(t4.*)",
|
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*) || to_jsonb(t3.*) || to_jsonb(t4.*)",
|
||||||
"FROM agreego.\"person\" t1",
|
"FROM agreego.\"entity\" t1",
|
||||||
"JOIN agreego.\"user\" t2 ON ",
|
"JOIN agreego.\"organization\" t2 ON ",
|
||||||
"JOIN agreego.\"organization\" t3 ON ",
|
"JOIN agreego.\"user\" t3 ON ",
|
||||||
"JOIN agreego.\"entity\" t4 ON ",
|
"JOIN agreego.\"person\" t4 ON ",
|
||||||
"WHERE",
|
"WHERE",
|
||||||
" (\"first_name\" = 'LookupFirst'",
|
" (\"first_name\" = 'LookupFirst'",
|
||||||
" AND \"last_name\" = 'LookupLast'",
|
" AND \"last_name\" = 'LookupLast'",
|
||||||
@ -1320,17 +1320,62 @@
|
|||||||
" AND \"pronouns\" = 'they/them'))"
|
" AND \"pronouns\" = 'they/them'))"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"UPDATE agreego.\"person\" SET",
|
"INSERT INTO agreego.\"entity\" (",
|
||||||
" contact_id = 'abc-contact'",
|
" \"created_at\",",
|
||||||
"WHERE",
|
" \"created_by\",",
|
||||||
" id = '{{uuid:mocks.0.id}}'"
|
" \"id\",",
|
||||||
|
" \"modified_at\",",
|
||||||
|
" \"modified_by\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" '{{timestamp}}',",
|
||||||
|
" '00000000-0000-0000-0000-000000000000',",
|
||||||
|
" '{{uuid:generated_0}}',",
|
||||||
|
" '{{timestamp}}',",
|
||||||
|
" '00000000-0000-0000-0000-000000000000',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"UPDATE agreego.\"entity\" SET",
|
"INSERT INTO agreego.\"organization\" (",
|
||||||
" modified_at = '{{timestamp}}',",
|
" \"id\",",
|
||||||
" modified_by = '00000000-0000-0000-0000-000000000000'",
|
" \"type\"",
|
||||||
"WHERE",
|
")",
|
||||||
" id = '{{uuid:mocks.0.id}}'"
|
"VALUES (",
|
||||||
|
" '{{uuid:generated_0}}',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"INSERT INTO agreego.\"user\" (",
|
||||||
|
" \"id\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" '{{uuid:generated_0}}',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"INSERT INTO agreego.\"person\" (",
|
||||||
|
" \"contact_id\",",
|
||||||
|
" \"date_of_birth\",",
|
||||||
|
" \"first_name\",",
|
||||||
|
" \"id\",",
|
||||||
|
" \"last_name\",",
|
||||||
|
" \"pronouns\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" 'abc-contact',",
|
||||||
|
" '{{timestamp}}',",
|
||||||
|
" 'LookupFirst',",
|
||||||
|
" '{{uuid:generated_0}}',",
|
||||||
|
" 'LookupLast',",
|
||||||
|
" 'they/them',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"INSERT INTO agreego.change (",
|
"INSERT INTO agreego.change (",
|
||||||
@ -1343,40 +1388,45 @@
|
|||||||
" \"modified_by\"",
|
" \"modified_by\"",
|
||||||
")",
|
")",
|
||||||
"VALUES (",
|
"VALUES (",
|
||||||
|
" NULL,",
|
||||||
" '{",
|
" '{",
|
||||||
" \"contact_id\": \"old-contact\"",
|
" \"first_name\": \"LookupFirst\",",
|
||||||
" }',",
|
" \"last_name\": \"LookupLast\",",
|
||||||
" '{",
|
" \"date_of_birth\": \"{{timestamp}}\",",
|
||||||
|
" \"pronouns\": \"they/them\",",
|
||||||
" \"contact_id\": \"abc-contact\",",
|
" \"contact_id\": \"abc-contact\",",
|
||||||
" \"type\": \"person\"",
|
" \"type\": \"person\"",
|
||||||
" }',",
|
" }',",
|
||||||
" '{{uuid:mocks.0.id}}',",
|
|
||||||
" '{{uuid:generated_0}}',",
|
" '{{uuid:generated_0}}',",
|
||||||
" 'update',",
|
" '{{uuid:generated_1}}',",
|
||||||
|
" 'create',",
|
||||||
" '{{timestamp}}',",
|
" '{{timestamp}}',",
|
||||||
" '00000000-0000-0000-0000-000000000000'",
|
" '00000000-0000-0000-0000-000000000000'",
|
||||||
")"
|
")"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"(SELECT pg_notify('entity', '{",
|
"(SELECT pg_notify('entity', '{",
|
||||||
" \"kind\": \"update\",",
|
" \"kind\": \"create\",",
|
||||||
" \"complete\": {",
|
" \"complete\": {",
|
||||||
" \"id\": \"{{uuid:mocks.0.id}}\",",
|
|
||||||
" \"type\": \"person\",",
|
|
||||||
" \"first_name\": \"LookupFirst\",",
|
" \"first_name\": \"LookupFirst\",",
|
||||||
" \"last_name\": \"LookupLast\",",
|
" \"last_name\": \"LookupLast\",",
|
||||||
" \"date_of_birth\": \"{{timestamp}}\",",
|
" \"date_of_birth\": \"{{timestamp}}\",",
|
||||||
" \"pronouns\": \"they/them\",",
|
" \"pronouns\": \"they/them\",",
|
||||||
" \"contact_id\": \"abc-contact\",",
|
" \"contact_id\": \"abc-contact\",",
|
||||||
|
" \"id\": \"{{uuid:generated_0}}\",",
|
||||||
|
" \"type\": \"person\",",
|
||||||
|
" \"created_by\": \"00000000-0000-0000-0000-000000000000\",",
|
||||||
|
" \"created_at\": \"{{timestamp}}\",",
|
||||||
" \"modified_by\": \"00000000-0000-0000-0000-000000000000\",",
|
" \"modified_by\": \"00000000-0000-0000-0000-000000000000\",",
|
||||||
" \"modified_at\": \"{{timestamp}}\"",
|
" \"modified_at\": \"{{timestamp}}\"",
|
||||||
" },",
|
" },",
|
||||||
" \"new\": {",
|
" \"new\": {",
|
||||||
|
" \"first_name\": \"LookupFirst\",",
|
||||||
|
" \"last_name\": \"LookupLast\",",
|
||||||
|
" \"date_of_birth\": \"{{timestamp}}\",",
|
||||||
|
" \"pronouns\": \"they/them\",",
|
||||||
" \"contact_id\": \"abc-contact\",",
|
" \"contact_id\": \"abc-contact\",",
|
||||||
" \"type\": \"person\"",
|
" \"type\": \"person\"",
|
||||||
" },",
|
|
||||||
" \"old\": {",
|
|
||||||
" \"contact_id\": \"old-contact\"",
|
|
||||||
" }",
|
" }",
|
||||||
"}'))"
|
"}'))"
|
||||||
]
|
]
|
||||||
@ -1412,10 +1462,10 @@
|
|||||||
"sql": [
|
"sql": [
|
||||||
[
|
[
|
||||||
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*) || to_jsonb(t3.*) || to_jsonb(t4.*)",
|
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*) || to_jsonb(t3.*) || to_jsonb(t4.*)",
|
||||||
"FROM agreego.\"person\" t1",
|
"FROM agreego.\"entity\" t1",
|
||||||
"JOIN agreego.\"user\" t2 ON ",
|
"JOIN agreego.\"organization\" t2 ON ",
|
||||||
"JOIN agreego.\"organization\" t3 ON ",
|
"JOIN agreego.\"user\" t3 ON ",
|
||||||
"JOIN agreego.\"entity\" t4 ON ",
|
"JOIN agreego.\"person\" t4 ON ",
|
||||||
"WHERE",
|
"WHERE",
|
||||||
" t1.id = '{{uuid:data.id}}'",
|
" t1.id = '{{uuid:data.id}}'",
|
||||||
" OR (\"first_name\" = 'LookupFirst'",
|
" OR (\"first_name\" = 'LookupFirst'",
|
||||||
@ -1424,17 +1474,62 @@
|
|||||||
" AND \"pronouns\" = 'they/them'))"
|
" AND \"pronouns\" = 'they/them'))"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"UPDATE agreego.\"person\" SET",
|
"INSERT INTO agreego.\"entity\" (",
|
||||||
" contact_id = 'abc-contact'",
|
" \"created_at\",",
|
||||||
"WHERE",
|
" \"created_by\",",
|
||||||
" id = '{{uuid:mocks.0.id}}'"
|
" \"id\",",
|
||||||
|
" \"modified_at\",",
|
||||||
|
" \"modified_by\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" '{{timestamp}}',",
|
||||||
|
" '00000000-0000-0000-0000-000000000000',",
|
||||||
|
" '{{uuid:data.id}}',",
|
||||||
|
" '{{timestamp}}',",
|
||||||
|
" '00000000-0000-0000-0000-000000000000',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"UPDATE agreego.\"entity\" SET",
|
"INSERT INTO agreego.\"organization\" (",
|
||||||
" modified_at = '{{timestamp}}',",
|
" \"id\",",
|
||||||
" modified_by = '00000000-0000-0000-0000-000000000000'",
|
" \"type\"",
|
||||||
"WHERE",
|
")",
|
||||||
" id = '{{uuid:mocks.0.id}}'"
|
"VALUES (",
|
||||||
|
" '{{uuid:data.id}}',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"INSERT INTO agreego.\"user\" (",
|
||||||
|
" \"id\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" '{{uuid:data.id}}',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"INSERT INTO agreego.\"person\" (",
|
||||||
|
" \"contact_id\",",
|
||||||
|
" \"date_of_birth\",",
|
||||||
|
" \"first_name\",",
|
||||||
|
" \"id\",",
|
||||||
|
" \"last_name\",",
|
||||||
|
" \"pronouns\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" 'abc-contact',",
|
||||||
|
" '{{timestamp}}',",
|
||||||
|
" 'LookupFirst',",
|
||||||
|
" '{{uuid:data.id}}',",
|
||||||
|
" 'LookupLast',",
|
||||||
|
" 'they/them',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"INSERT INTO agreego.change (",
|
"INSERT INTO agreego.change (",
|
||||||
@ -1447,42 +1542,46 @@
|
|||||||
" \"modified_by\"",
|
" \"modified_by\"",
|
||||||
")",
|
")",
|
||||||
"VALUES (",
|
"VALUES (",
|
||||||
|
" NULL,",
|
||||||
" '{",
|
" '{",
|
||||||
" \"contact_id\": \"old-contact\"",
|
" \"first_name\": \"LookupFirst\",",
|
||||||
" }',",
|
" \"last_name\": \"LookupLast\",",
|
||||||
" '{",
|
" \"date_of_birth\": \"{{timestamp}}\",",
|
||||||
|
" \"pronouns\": \"they/them\",",
|
||||||
" \"contact_id\": \"abc-contact\",",
|
" \"contact_id\": \"abc-contact\",",
|
||||||
" \"type\": \"person\"",
|
" \"type\": \"person\"",
|
||||||
" }',",
|
" }',",
|
||||||
" '{{uuid:mocks.0.id}}',",
|
" '{{uuid:data.id}}',",
|
||||||
" '{{uuid:generated_0}}',",
|
" '{{uuid:generated_0}}',",
|
||||||
" 'update',",
|
" 'create',",
|
||||||
" '{{timestamp}}',",
|
" '{{timestamp}}',",
|
||||||
" '00000000-0000-0000-0000-000000000000'",
|
" '00000000-0000-0000-0000-000000000000'",
|
||||||
")"
|
")"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"(SELECT pg_notify('entity', '{",
|
"(SELECT pg_notify('entity', '{",
|
||||||
" \"kind\": \"update\",",
|
" \"kind\": \"create\",",
|
||||||
" \"complete\": {",
|
" \"complete\": {",
|
||||||
" \"id\": \"{{uuid:mocks.0.id}}\",",
|
|
||||||
" \"type\": \"person\",",
|
|
||||||
" \"first_name\": \"LookupFirst\",",
|
" \"first_name\": \"LookupFirst\",",
|
||||||
" \"last_name\": \"LookupLast\",",
|
" \"last_name\": \"LookupLast\",",
|
||||||
" \"date_of_birth\": \"{{timestamp}}\",",
|
" \"date_of_birth\": \"{{timestamp}}\",",
|
||||||
" \"pronouns\": \"they/them\",",
|
" \"pronouns\": \"they/them\",",
|
||||||
" \"contact_id\": \"abc-contact\",",
|
" \"contact_id\": \"abc-contact\",",
|
||||||
|
" \"id\": \"{{uuid:data.id}}\",",
|
||||||
|
" \"type\": \"person\",",
|
||||||
|
" \"created_by\": \"00000000-0000-0000-0000-000000000000\",",
|
||||||
|
" \"created_at\": \"{{timestamp}}\",",
|
||||||
" \"modified_by\": \"00000000-0000-0000-0000-000000000000\",",
|
" \"modified_by\": \"00000000-0000-0000-0000-000000000000\",",
|
||||||
" \"modified_at\": \"{{timestamp}}\"",
|
" \"modified_at\": \"{{timestamp}}\"",
|
||||||
" },",
|
" },",
|
||||||
" \"new\": {",
|
" \"new\": {",
|
||||||
|
" \"first_name\": \"LookupFirst\",",
|
||||||
|
" \"last_name\": \"LookupLast\",",
|
||||||
|
" \"date_of_birth\": \"{{timestamp}}\",",
|
||||||
|
" \"pronouns\": \"they/them\",",
|
||||||
" \"contact_id\": \"abc-contact\",",
|
" \"contact_id\": \"abc-contact\",",
|
||||||
" \"type\": \"person\"",
|
" \"type\": \"person\"",
|
||||||
" },",
|
" }",
|
||||||
" \"old\": {",
|
|
||||||
" \"contact_id\": \"old-contact\"",
|
|
||||||
" },",
|
|
||||||
" \"replaces\": \"{{uuid:data.id}}\"",
|
|
||||||
"}'))"
|
"}'))"
|
||||||
]
|
]
|
||||||
]
|
]
|
||||||
@ -1516,10 +1615,10 @@
|
|||||||
"sql": [
|
"sql": [
|
||||||
[
|
[
|
||||||
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*) || to_jsonb(t3.*) || to_jsonb(t4.*)",
|
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*) || to_jsonb(t3.*) || to_jsonb(t4.*)",
|
||||||
"FROM agreego.\"person\" t1",
|
"FROM agreego.\"entity\" t1",
|
||||||
"JOIN agreego.\"user\" t2 ON ",
|
"JOIN agreego.\"organization\" t2 ON ",
|
||||||
"JOIN agreego.\"organization\" t3 ON ",
|
"JOIN agreego.\"user\" t3 ON ",
|
||||||
"JOIN agreego.\"entity\" t4 ON ",
|
"JOIN agreego.\"person\" t4 ON ",
|
||||||
"WHERE",
|
"WHERE",
|
||||||
" t1.id = '{{uuid:data.id}}'",
|
" t1.id = '{{uuid:data.id}}'",
|
||||||
" OR (\"first_name\" = 'LookupFirst'",
|
" OR (\"first_name\" = 'LookupFirst'",
|
||||||
@ -1528,23 +1627,109 @@
|
|||||||
" AND \"pronouns\" = 'they/them'))"
|
" AND \"pronouns\" = 'they/them'))"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"(SELECT pg_notify('entity', '{",
|
"INSERT INTO agreego.\"entity\" (",
|
||||||
" \"kind\": \"replace\",",
|
" \"created_at\",",
|
||||||
" \"complete\": {",
|
" \"created_by\",",
|
||||||
" \"id\": \"{{uuid:mocks.0.id}}\",",
|
" \"id\",",
|
||||||
" \"type\": \"person\",",
|
" \"modified_at\",",
|
||||||
|
" \"modified_by\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" '{{timestamp}}',",
|
||||||
|
" '00000000-0000-0000-0000-000000000000',",
|
||||||
|
" '{{uuid:data.id}}',",
|
||||||
|
" '{{timestamp}}',",
|
||||||
|
" '00000000-0000-0000-0000-000000000000',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"INSERT INTO agreego.\"organization\" (",
|
||||||
|
" \"id\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" '{{uuid:data.id}}',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"INSERT INTO agreego.\"user\" (",
|
||||||
|
" \"id\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" '{{uuid:data.id}}',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"INSERT INTO agreego.\"person\" (",
|
||||||
|
" \"date_of_birth\",",
|
||||||
|
" \"first_name\",",
|
||||||
|
" \"id\",",
|
||||||
|
" \"last_name\",",
|
||||||
|
" \"pronouns\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" '{{timestamp}}',",
|
||||||
|
" 'LookupFirst',",
|
||||||
|
" '{{uuid:data.id}}',",
|
||||||
|
" 'LookupLast',",
|
||||||
|
" 'they/them',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"INSERT INTO agreego.change (",
|
||||||
|
" \"old\",",
|
||||||
|
" \"new\",",
|
||||||
|
" \"entity_id\",",
|
||||||
|
" \"id\",",
|
||||||
|
" \"kind\",",
|
||||||
|
" \"modified_at\",",
|
||||||
|
" \"modified_by\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" NULL,",
|
||||||
|
" '{",
|
||||||
" \"first_name\": \"LookupFirst\",",
|
" \"first_name\": \"LookupFirst\",",
|
||||||
" \"last_name\": \"LookupLast\",",
|
" \"last_name\": \"LookupLast\",",
|
||||||
" \"date_of_birth\": \"{{timestamp}}\",",
|
" \"date_of_birth\": \"{{timestamp}}\",",
|
||||||
" \"pronouns\": \"they/them\",",
|
" \"pronouns\": \"they/them\",",
|
||||||
" \"contact_id\": \"old-contact\",",
|
" \"type\": \"person\"",
|
||||||
|
" }',",
|
||||||
|
" '{{uuid:data.id}}',",
|
||||||
|
" '{{uuid:generated_0}}',",
|
||||||
|
" 'create',",
|
||||||
|
" '{{timestamp}}',",
|
||||||
|
" '00000000-0000-0000-0000-000000000000'",
|
||||||
|
")"
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"(SELECT pg_notify('entity', '{",
|
||||||
|
" \"kind\": \"create\",",
|
||||||
|
" \"complete\": {",
|
||||||
|
" \"first_name\": \"LookupFirst\",",
|
||||||
|
" \"last_name\": \"LookupLast\",",
|
||||||
|
" \"date_of_birth\": \"{{timestamp}}\",",
|
||||||
|
" \"pronouns\": \"they/them\",",
|
||||||
|
" \"id\": \"{{uuid:data.id}}\",",
|
||||||
|
" \"type\": \"person\",",
|
||||||
|
" \"created_by\": \"00000000-0000-0000-0000-000000000000\",",
|
||||||
|
" \"created_at\": \"{{timestamp}}\",",
|
||||||
" \"modified_by\": \"00000000-0000-0000-0000-000000000000\",",
|
" \"modified_by\": \"00000000-0000-0000-0000-000000000000\",",
|
||||||
" \"modified_at\": \"{{timestamp}}\"",
|
" \"modified_at\": \"{{timestamp}}\"",
|
||||||
" },",
|
" },",
|
||||||
" \"new\": {",
|
" \"new\": {",
|
||||||
|
" \"first_name\": \"LookupFirst\",",
|
||||||
|
" \"last_name\": \"LookupLast\",",
|
||||||
|
" \"date_of_birth\": \"{{timestamp}}\",",
|
||||||
|
" \"pronouns\": \"they/them\",",
|
||||||
" \"type\": \"person\"",
|
" \"type\": \"person\"",
|
||||||
" },",
|
" }",
|
||||||
" \"replaces\": \"{{uuid:data.id}}\"",
|
|
||||||
"}'))"
|
"}'))"
|
||||||
]
|
]
|
||||||
]
|
]
|
||||||
@ -1573,26 +1758,64 @@
|
|||||||
"sql": [
|
"sql": [
|
||||||
[
|
[
|
||||||
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*) || to_jsonb(t3.*) || to_jsonb(t4.*)",
|
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*) || to_jsonb(t3.*) || to_jsonb(t4.*)",
|
||||||
"FROM agreego.\"person\" t1",
|
"FROM agreego.\"entity\" t1",
|
||||||
"JOIN agreego.\"user\" t2 ON ",
|
"JOIN agreego.\"organization\" t2 ON ",
|
||||||
"JOIN agreego.\"organization\" t3 ON ",
|
"JOIN agreego.\"user\" t3 ON ",
|
||||||
"JOIN agreego.\"entity\" t4 ON ",
|
"JOIN agreego.\"person\" t4 ON ",
|
||||||
"WHERE",
|
"WHERE",
|
||||||
" t1.id = '{{uuid:mocks.0.id}}')"
|
" t1.id = '{{uuid:mocks.0.id}}')"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"UPDATE agreego.\"person\" SET",
|
"INSERT INTO agreego.\"entity\" (",
|
||||||
" first_name = 'NewFirst',",
|
" \"created_at\",",
|
||||||
" last_name = 'NewLast'",
|
" \"created_by\",",
|
||||||
"WHERE",
|
" \"id\",",
|
||||||
" id = '{{uuid:mocks.0.id}}'"
|
" \"modified_at\",",
|
||||||
|
" \"modified_by\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" '{{timestamp}}',",
|
||||||
|
" '00000000-0000-0000-0000-000000000000',",
|
||||||
|
" '{{uuid:mocks.0.id}}',",
|
||||||
|
" '{{timestamp}}',",
|
||||||
|
" '00000000-0000-0000-0000-000000000000',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"UPDATE agreego.\"entity\" SET",
|
"INSERT INTO agreego.\"organization\" (",
|
||||||
" modified_at = '{{timestamp}}',",
|
" \"id\",",
|
||||||
" modified_by = '00000000-0000-0000-0000-000000000000'",
|
" \"type\"",
|
||||||
"WHERE",
|
")",
|
||||||
" id = '{{uuid:mocks.0.id}}'"
|
"VALUES (",
|
||||||
|
" '{{uuid:mocks.0.id}}',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"INSERT INTO agreego.\"user\" (",
|
||||||
|
" \"id\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" '{{uuid:mocks.0.id}}',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"INSERT INTO agreego.\"person\" (",
|
||||||
|
" \"first_name\",",
|
||||||
|
" \"id\",",
|
||||||
|
" \"last_name\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" 'NewFirst',",
|
||||||
|
" '{{uuid:mocks.0.id}}',",
|
||||||
|
" 'NewLast',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"INSERT INTO agreego.change (",
|
"INSERT INTO agreego.change (",
|
||||||
@ -1605,10 +1828,7 @@
|
|||||||
" \"modified_by\"",
|
" \"modified_by\"",
|
||||||
")",
|
")",
|
||||||
"VALUES (",
|
"VALUES (",
|
||||||
" '{",
|
" NULL,",
|
||||||
" \"first_name\": \"OldFirst\",",
|
|
||||||
" \"last_name\": \"OldLast\"",
|
|
||||||
" }',",
|
|
||||||
" '{",
|
" '{",
|
||||||
" \"first_name\": \"NewFirst\",",
|
" \"first_name\": \"NewFirst\",",
|
||||||
" \"last_name\": \"NewLast\",",
|
" \"last_name\": \"NewLast\",",
|
||||||
@ -1616,19 +1836,21 @@
|
|||||||
" }',",
|
" }',",
|
||||||
" '{{uuid:mocks.0.id}}',",
|
" '{{uuid:mocks.0.id}}',",
|
||||||
" '{{uuid:generated_0}}',",
|
" '{{uuid:generated_0}}',",
|
||||||
" 'update',",
|
" 'create',",
|
||||||
" '{{timestamp}}',",
|
" '{{timestamp}}',",
|
||||||
" '00000000-0000-0000-0000-000000000000'",
|
" '00000000-0000-0000-0000-000000000000'",
|
||||||
")"
|
")"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"(SELECT pg_notify('entity', '{",
|
"(SELECT pg_notify('entity', '{",
|
||||||
" \"kind\": \"update\",",
|
" \"kind\": \"create\",",
|
||||||
" \"complete\": {",
|
" \"complete\": {",
|
||||||
" \"id\": \"{{uuid:mocks.0.id}}\",",
|
|
||||||
" \"type\": \"person\",",
|
|
||||||
" \"first_name\": \"NewFirst\",",
|
" \"first_name\": \"NewFirst\",",
|
||||||
" \"last_name\": \"NewLast\",",
|
" \"last_name\": \"NewLast\",",
|
||||||
|
" \"id\": \"{{uuid:mocks.0.id}}\",",
|
||||||
|
" \"type\": \"person\",",
|
||||||
|
" \"created_by\": \"00000000-0000-0000-0000-000000000000\",",
|
||||||
|
" \"created_at\": \"{{timestamp}}\",",
|
||||||
" \"modified_by\": \"00000000-0000-0000-0000-000000000000\",",
|
" \"modified_by\": \"00000000-0000-0000-0000-000000000000\",",
|
||||||
" \"modified_at\": \"{{timestamp}}\"",
|
" \"modified_at\": \"{{timestamp}}\"",
|
||||||
" },",
|
" },",
|
||||||
@ -1636,10 +1858,6 @@
|
|||||||
" \"first_name\": \"NewFirst\",",
|
" \"first_name\": \"NewFirst\",",
|
||||||
" \"last_name\": \"NewLast\",",
|
" \"last_name\": \"NewLast\",",
|
||||||
" \"type\": \"person\"",
|
" \"type\": \"person\"",
|
||||||
" },",
|
|
||||||
" \"old\": {",
|
|
||||||
" \"first_name\": \"OldFirst\",",
|
|
||||||
" \"last_name\": \"OldLast\"",
|
|
||||||
" }",
|
" }",
|
||||||
"}'))"
|
"}'))"
|
||||||
]
|
]
|
||||||
@ -1663,10 +1881,10 @@
|
|||||||
"sql": [
|
"sql": [
|
||||||
[
|
[
|
||||||
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*) || to_jsonb(t3.*) || to_jsonb(t4.*)",
|
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*) || to_jsonb(t3.*) || to_jsonb(t4.*)",
|
||||||
"FROM agreego.\"person\" t1",
|
"FROM agreego.\"entity\" t1",
|
||||||
"JOIN agreego.\"user\" t2 ON ",
|
"JOIN agreego.\"organization\" t2 ON ",
|
||||||
"JOIN agreego.\"organization\" t3 ON ",
|
"JOIN agreego.\"user\" t3 ON ",
|
||||||
"JOIN agreego.\"entity\" t4 ON ",
|
"JOIN agreego.\"person\" t4 ON ",
|
||||||
"WHERE",
|
"WHERE",
|
||||||
" t1.id = '123')"
|
" t1.id = '123')"
|
||||||
],
|
],
|
||||||
@ -2002,8 +2220,8 @@
|
|||||||
"sql": [
|
"sql": [
|
||||||
[
|
[
|
||||||
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*)",
|
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*)",
|
||||||
"FROM agreego.\"order\" t1",
|
"FROM agreego.\"entity\" t1",
|
||||||
"JOIN agreego.\"entity\" t2 ON ",
|
"JOIN agreego.\"order\" t2 ON ",
|
||||||
"WHERE",
|
"WHERE",
|
||||||
" t1.id = 'abc'",
|
" t1.id = 'abc'",
|
||||||
" OR (\"id\" = 'abc'))"
|
" OR (\"id\" = 'abc'))"
|
||||||
@ -2805,20 +3023,62 @@
|
|||||||
"sql": [
|
"sql": [
|
||||||
[
|
[
|
||||||
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*) || to_jsonb(t3.*) || to_jsonb(t4.*)",
|
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*) || to_jsonb(t3.*) || to_jsonb(t4.*)",
|
||||||
"FROM agreego.\"person\" t1",
|
"FROM agreego.\"entity\" t1",
|
||||||
"JOIN agreego.\"user\" t2 ON ",
|
"JOIN agreego.\"organization\" t2 ON ",
|
||||||
"JOIN agreego.\"organization\" t3 ON ",
|
"JOIN agreego.\"user\" t3 ON ",
|
||||||
"JOIN agreego.\"entity\" t4 ON ",
|
"JOIN agreego.\"person\" t4 ON ",
|
||||||
"WHERE",
|
"WHERE",
|
||||||
" t1.id = 'abc-archived')"
|
" t1.id = 'abc-archived')"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"UPDATE agreego.\"entity\" SET",
|
"INSERT INTO agreego.\"entity\" (",
|
||||||
" archived = true,",
|
" \"archived\",",
|
||||||
" modified_at = '{{timestamp}}',",
|
" \"created_at\",",
|
||||||
" modified_by = '00000000-0000-0000-0000-000000000000'",
|
" \"created_by\",",
|
||||||
"WHERE",
|
" \"id\",",
|
||||||
" id = 'abc-archived'"
|
" \"modified_at\",",
|
||||||
|
" \"modified_by\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" true,",
|
||||||
|
" '{{timestamp}}',",
|
||||||
|
" '00000000-0000-0000-0000-000000000000',",
|
||||||
|
" 'abc-archived',",
|
||||||
|
" '{{timestamp}}',",
|
||||||
|
" '00000000-0000-0000-0000-000000000000',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"INSERT INTO agreego.\"organization\" (",
|
||||||
|
" \"id\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" 'abc-archived',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"INSERT INTO agreego.\"user\" (",
|
||||||
|
" \"id\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" 'abc-archived',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
|
],
|
||||||
|
[
|
||||||
|
"INSERT INTO agreego.\"person\" (",
|
||||||
|
" \"id\",",
|
||||||
|
" \"type\"",
|
||||||
|
")",
|
||||||
|
"VALUES (",
|
||||||
|
" 'abc-archived',",
|
||||||
|
" 'person'",
|
||||||
|
")"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"INSERT INTO agreego.change (",
|
"INSERT INTO agreego.change (",
|
||||||
@ -2831,38 +3091,33 @@
|
|||||||
" \"modified_by\"",
|
" \"modified_by\"",
|
||||||
")",
|
")",
|
||||||
"VALUES (",
|
"VALUES (",
|
||||||
" '{",
|
" NULL,",
|
||||||
" \"archived\": false",
|
|
||||||
" }',",
|
|
||||||
" '{",
|
" '{",
|
||||||
" \"archived\": true,",
|
" \"archived\": true,",
|
||||||
" \"type\": \"person\"",
|
" \"type\": \"person\"",
|
||||||
" }',",
|
" }',",
|
||||||
" 'abc-archived',",
|
" 'abc-archived',",
|
||||||
" '{{uuid:generated_0}}',",
|
" '{{uuid:generated_0}}',",
|
||||||
" 'delete',",
|
" 'create',",
|
||||||
" '{{timestamp}}',",
|
" '{{timestamp}}',",
|
||||||
" '00000000-0000-0000-0000-000000000000'",
|
" '00000000-0000-0000-0000-000000000000'",
|
||||||
")"
|
")"
|
||||||
],
|
],
|
||||||
[
|
[
|
||||||
"(SELECT pg_notify('entity', '{",
|
"(SELECT pg_notify('entity', '{",
|
||||||
" \"kind\": \"delete\",",
|
" \"kind\": \"create\",",
|
||||||
" \"complete\": {",
|
" \"complete\": {",
|
||||||
|
" \"archived\": true,",
|
||||||
" \"id\": \"abc-archived\",",
|
" \"id\": \"abc-archived\",",
|
||||||
" \"type\": \"person\",",
|
" \"type\": \"person\",",
|
||||||
" \"first_name\": \"ArchivedFirst\",",
|
" \"created_by\": \"00000000-0000-0000-0000-000000000000\",",
|
||||||
" \"last_name\": \"ArchivedLast\",",
|
" \"created_at\": \"{{timestamp}}\",",
|
||||||
" \"archived\": true,",
|
|
||||||
" \"modified_by\": \"00000000-0000-0000-0000-000000000000\",",
|
" \"modified_by\": \"00000000-0000-0000-0000-000000000000\",",
|
||||||
" \"modified_at\": \"{{timestamp}}\"",
|
" \"modified_at\": \"{{timestamp}}\"",
|
||||||
" },",
|
" },",
|
||||||
" \"new\": {",
|
" \"new\": {",
|
||||||
" \"archived\": true,",
|
" \"archived\": true,",
|
||||||
" \"type\": \"person\"",
|
" \"type\": \"person\"",
|
||||||
" },",
|
|
||||||
" \"old\": {",
|
|
||||||
" \"archived\": false",
|
|
||||||
" }",
|
" }",
|
||||||
"}'))"
|
"}'))"
|
||||||
]
|
]
|
||||||
@ -3121,8 +3376,8 @@
|
|||||||
"sql": [
|
"sql": [
|
||||||
[
|
[
|
||||||
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*)",
|
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*)",
|
||||||
"FROM agreego.\"order_line\" t1",
|
"FROM agreego.\"entity\" t1",
|
||||||
"JOIN agreego.\"entity\" t2 ON ",
|
"JOIN agreego.\"order_line\" t2 ON ",
|
||||||
"WHERE",
|
"WHERE",
|
||||||
" t1.id = '{{uuid:data.lines.0.id}}')"
|
" t1.id = '{{uuid:data.lines.0.id}}')"
|
||||||
],
|
],
|
||||||
@ -3245,8 +3500,8 @@
|
|||||||
"sql": [
|
"sql": [
|
||||||
[
|
[
|
||||||
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*)",
|
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*)",
|
||||||
"FROM agreego.\"invoice\" t1",
|
"FROM agreego.\"entity\" t1",
|
||||||
"JOIN agreego.\"entity\" t2 ON ",
|
"JOIN agreego.\"invoice\" t2 ON ",
|
||||||
"WHERE",
|
"WHERE",
|
||||||
" t1.id = '{{uuid:data.id}}'",
|
" t1.id = '{{uuid:data.id}}'",
|
||||||
" OR (\"id\" = '{{uuid:data.id}}'))"
|
" OR (\"id\" = '{{uuid:data.id}}'))"
|
||||||
@ -3362,8 +3617,8 @@
|
|||||||
"sql": [
|
"sql": [
|
||||||
[
|
[
|
||||||
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*)",
|
"(SELECT to_jsonb(t1.*) || to_jsonb(t2.*)",
|
||||||
"FROM agreego.\"account\" t1",
|
"FROM agreego.\"entity\" t1",
|
||||||
"JOIN agreego.\"entity\" t2 ON ",
|
"JOIN agreego.\"account\" t2 ON ",
|
||||||
"WHERE",
|
"WHERE",
|
||||||
" t1.id = '{{uuid:data.id}}')"
|
" t1.id = '{{uuid:data.id}}')"
|
||||||
],
|
],
|
||||||
|
|||||||
File diff suppressed because it is too large
Load Diff
@ -791,13 +791,8 @@ impl Merger {
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
let mut execute_order: Vec<String> = entity_type.hierarchy.clone();
|
for table_name in &entity_type.hierarchy {
|
||||||
if change_kind == "create" {
|
let table_fields = match grouped_fields.get(table_name).and_then(|v| v.as_array()) {
|
||||||
execute_order.reverse();
|
|
||||||
}
|
|
||||||
|
|
||||||
for table_name in execute_order {
|
|
||||||
let table_fields = match grouped_fields.get(&table_name).and_then(|v| v.as_array()) {
|
|
||||||
Some(arr) => arr
|
Some(arr) => arr
|
||||||
.iter()
|
.iter()
|
||||||
.filter_map(|v| v.as_str().map(|s| s.to_string()))
|
.filter_map(|v| v.as_str().map(|s| s.to_string()))
|
||||||
|
|||||||
@ -44,7 +44,7 @@ fn test_library_api() {
|
|||||||
{
|
{
|
||||||
"name": "source_schema",
|
"name": "source_schema",
|
||||||
"variations": ["source_schema"],
|
"variations": ["source_schema"],
|
||||||
"hierarchy": ["source_schema", "entity"],
|
"hierarchy": ["entity", "source_schema"],
|
||||||
"schemas": {
|
"schemas": {
|
||||||
"source_schema": {
|
"source_schema": {
|
||||||
"type": "object",
|
"type": "object",
|
||||||
@ -60,7 +60,7 @@ fn test_library_api() {
|
|||||||
{
|
{
|
||||||
"name": "target_schema",
|
"name": "target_schema",
|
||||||
"variations": ["target_schema"],
|
"variations": ["target_schema"],
|
||||||
"hierarchy": ["target_schema", "entity"],
|
"hierarchy": ["entity", "target_schema"],
|
||||||
"schemas": {
|
"schemas": {
|
||||||
"target_schema": {
|
"target_schema": {
|
||||||
"type": "object",
|
"type": "object",
|
||||||
@ -109,7 +109,7 @@ fn test_library_api() {
|
|||||||
"field_types": null,
|
"field_types": null,
|
||||||
"fields": [],
|
"fields": [],
|
||||||
"grouped_fields": null,
|
"grouped_fields": null,
|
||||||
"hierarchy": ["source_schema", "entity"],
|
"hierarchy": ["entity", "source_schema"],
|
||||||
"historical": false,
|
"historical": false,
|
||||||
"id": "",
|
"id": "",
|
||||||
"longevity": null,
|
"longevity": null,
|
||||||
@ -174,7 +174,7 @@ fn test_library_api() {
|
|||||||
"field_types": null,
|
"field_types": null,
|
||||||
"fields": [],
|
"fields": [],
|
||||||
"grouped_fields": null,
|
"grouped_fields": null,
|
||||||
"hierarchy": ["target_schema", "entity"],
|
"hierarchy": ["entity", "target_schema"],
|
||||||
"historical": false,
|
"historical": false,
|
||||||
"id": "",
|
"id": "",
|
||||||
"longevity": null,
|
"longevity": null,
|
||||||
|
|||||||
Reference in New Issue
Block a user