def _dequeuing_merge_conflict_buffer(cursor, current_id, transfersession_id):
# transfer buffer serialized into conflicting store
merge_conflict_store = """REPLACE INTO {store} (id, serialized, deleted, last_saved_instance, last_saved_counter, model_name,
profile, partition, source_id, conflicting_serialized_data, dirty_bit, _self_ref_fk)
SELECT store.id, store.serialized, store.deleted OR buffer.deleted, '{current_instance_id}',
{current_instance_counter}, store.model_name, store.profile, store.partition, store.source_id,
buffer.serialized || '\n' || store.conflicting_serialized_data, 1, store._self_ref_fk
FROM {buffer} AS buffer, {store} AS store
/*Scope to a single record.*/
WHERE store.id = buffer.model_uuid
AND buffer.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,
rmcb=RecordMaxCounterBuffer._meta.db_table,
store=Store._meta.db_table,
rmc=RecordMaxCounter._meta.db_table,
transfer_session_id=transfersession_id,
current_instance_id=current_id.id,
current_instance_counter=current_id.counter)
cursor.execute(merge_conflict_store)
评论列表
文章目录
