Fixed bug #8350 : Missed records in replicated database

hvlad · hvlad · commit 668fcdb603a1 · 2024-12-11T18:18:32.000+02:00
diff --git a/src/jrd/replication/Replicator.cpp b/src/jrd/replication/Replicator.cpp
@@ -314,7 +314,7 @@ void Replicator::insertRecord(CheckStatusWrapper* status,
 				{
 					const auto blobId = (ISC_QUAD*) field->getData();
 
-					if (blobId)
+					if (blobId && !BlobWrapper::blobIsNull(*blobId))
 						storeBlob(transaction, *blobId);
 				}
 			}
@@ -359,7 +359,7 @@ void Replicator::updateRecord(CheckStatusWrapper* status,
 				{
 					const auto blobId = (ISC_QUAD*) field->getData();
 
-					if (blobId)
+					if (blobId && !BlobWrapper::blobIsNull(*blobId))
 						storeBlob(transaction, *blobId);
 				}
 			}

Original file line number	Diff line number	Diff line change
`@@ -314,7 +314,7 @@ void Replicator::insertRecord(CheckStatusWrapper* status,`
`314`	`314`	`{`
`315`	`315`	`const auto blobId = (ISC_QUAD*) field->getData();`
`316`	`316`
`317`		`- if (blobId)`
	`317`	`+ if (blobId && !BlobWrapper::blobIsNull(*blobId))`
`318`	`318`	`storeBlob(transaction, *blobId);`
`319`	`319`	`}`
`320`	`320`	`}`
`@@ -359,7 +359,7 @@ void Replicator::updateRecord(CheckStatusWrapper* status,`
`359`	`359`	`{`
`360`	`360`	`const auto blobId = (ISC_QUAD*) field->getData();`
`361`	`361`
`362`		`- if (blobId)`
	`362`	`+ if (blobId && !BlobWrapper::blobIsNull(*blobId))`
`363`	`363`	`storeBlob(transaction, *blobId);`
`364`	`364`	`}`
`365`	`365`	`}`