def _dequeuing_merge_conflict_rmcb(cursor, transfersession_id):
# transfer record max counters for records with merge conflicts + perform max
merge_conflict_rmc = """REPLACE INTO {rmc} (instance_id, counter, store_model_id)
SELECT rmcb.instance_id, rmcb.counter, rmcb.model_uuid
FROM {rmcb} AS rmcb, {store} AS store, {rmc} AS rmc, {buffer} AS buffer
/*Scope to a single record.*/
WHERE store.id = rmcb.model_uuid
AND store.id = rmc.store_model_id
AND store.id = buffer.model_uuid
/*Where buffer rmc is greater than store rmc*/
AND rmcb.instance_id = rmc.instance_id
AND rmcb.counter > rmc.counter
AND rmcb.transfer_session_id = '{transfer_session_id}'
/*Exclude fast-forwards*/
AND NOT EXISTS (SELECT 1 FROM {rmcb} AS rmcb2 WHERE store.id = rmcb2.model_uuid
AND store.last_saved_instance = rmcb2.instance_id
AND store.last_saved_counter <= rmcb2.counter
AND rmcb2.transfer_session_id = '{transfer_session_id}')
""".format(buffer=Buffer._meta.db_table,
store=Store._meta.db_table,
rmc=RecordMaxCounter._meta.db_table,
rmcb=RecordMaxCounterBuffer._meta.db_table,
transfer_session_id=transfersession_id)
cursor.execute(merge_conflict_rmc)
评论列表
文章目录
