Skip to content

Commit 09e1d94

Browse files
committed
Correctly use view_name override if provided.
1 parent b475c74 commit 09e1d94

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

crates/core/src/schema_management.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -205,7 +205,7 @@ delete_trigger_sql = gen.delete_trigger_sql,
205205
insert_trigger_sql = gen.insert_trigger_sql,
206206
update_trigger_sql = gen.update_trigger_sql
207207
FROM (SELECT
208-
json_extract(json_each.value, '$.name') as name,
208+
ifnull(json_extract(json_each.value, '$.view_name'), json_extract(json_each.value, '$.name')) as name,
209209
powersync_view_sql(json_each.value) as sql,
210210
powersync_trigger_delete_sql(json_each.value) as delete_trigger_sql,
211211
powersync_trigger_insert_sql(json_each.value) as insert_trigger_sql,
@@ -229,7 +229,7 @@ INSERT INTO powersync_views(
229229
update_trigger_sql
230230
)
231231
SELECT
232-
json_extract(json_each.value, '$.name') as name,
232+
ifnull(json_extract(json_each.value, '$.view_name'), json_extract(json_each.value, '$.name')) as name,
233233
powersync_view_sql(json_each.value) as sql,
234234
powersync_trigger_delete_sql(json_each.value) as delete_trigger_sql,
235235
powersync_trigger_insert_sql(json_each.value) as insert_trigger_sql,
@@ -241,7 +241,7 @@ json_extract(json_each.value, '$.name') as name,
241241
// language=SQLite
242242
db.exec_text("\
243243
DELETE FROM powersync_views WHERE name NOT IN (
244-
SELECT json_extract(json_each.value, '$.name')
244+
SELECT ifnull(json_extract(json_each.value, '$.view_name'), json_extract(json_each.value, '$.name'))
245245
FROM json_each(json_extract(?, '$.tables'))
246246
)", schema).into_db_result(db)?;
247247

0 commit comments

Comments
 (0)