@@ -106,25 +106,25 @@ insert into certificate (certificate_id,
106
106
initiated_at,
107
107
sealed_at)
108
108
select
109
- c.value->> '$.hash' as certificate_id,
109
+ json_extract( c.value, '$.hash') as certificate_id,
110
110
case
111
- when c.value->> '$.multi_signature' <> '' then c.value->> '$.previous_hash'
111
+ when json_extract( c.value, '$.multi_signature') <> '' then json_extract( c.value, '$.previous_hash')
112
112
else NULL
113
113
end as parent_certificate_id,
114
- c.value->> '$.signed_message' as message,
114
+ json_extract( c.value, '$.signed_message') as message,
115
115
case
116
- when c.value->> '$.multi_signature' <> '' then c.value->> '$.multi_signature'
117
- else c.value->> '$.genesis_signature'
116
+ when json_extract( c.value, '$.multi_signature') <> '' then json_extract( c.value, '$.multi_signature')
117
+ else json_extract( c.value, '$.genesis_signature')
118
118
end as signature,
119
- c.value->> '$.aggregate_verification_key' as aggregate_verification_key,
120
- c.value->> '$.beacon.epoch' as epoch,
121
- c.value-> '$.beacon' as beacon,
122
- c.value->> '$.metadata.version' as protocol_version,
123
- c.value-> '$.metadata.parameters' as protocol_parameters,
124
- c.value-> '$.protocol_message' as protocol_message,
125
- c.value-> '$.metadata.signers' as signers,
126
- c.value->> '$.metadata.initiated_at' as initiated_at,
127
- c.value->> '$.metadata.sealed_at' as sealed_at
119
+ json_extract( c.value, '$.aggregate_verification_key') as aggregate_verification_key,
120
+ json_extract( c.value, '$.beacon.epoch') as epoch,
121
+ json(json_extract( c.value, '$.beacon')) as beacon,
122
+ json_extract( c.value, '$.metadata.version') as protocol_version,
123
+ json(json_extract( c.value, '$.metadata.parameters')) as protocol_parameters,
124
+ json(json_extract( c.value, '$.protocol_message')) as protocol_message,
125
+ json(json_extract( c.value, '$.metadata.signers')) as signers,
126
+ json_extract( c.value, '$.metadata.initiated_at') as initiated_at,
127
+ json_extract( c.value, '$.metadata.sealed_at') as sealed_at
128
128
from certificate_temp as c;
129
129
create index epoch_index ON certificate(epoch);
130
130
drop table certificate_temp;
0 commit comments