Move blob searching in Replicator to new method

Author: Artyom Abakumov

src/jrd/replication/Replicator.cpp

@@ -306,21 +306,7 @@ void Replicator::insertRecord(CheckStatusWrapper* status,
 {
 	try
 	{
-		for (unsigned id = 0; id < record->getCount(); id++)
-		{
-			IReplicatedField* field = record->getField(id);
-			if (field != nullptr)
-			{
-				auto type = field->getType();
-				if (type == SQL_ARRAY || type == SQL_BLOB)
-				{
-					const auto blobId = (ISC_QUAD*) field->getData();
-
-					if (blobId && !BlobWrapper::blobIsNull(*blobId))
-						storeBlob(transaction, *blobId);
-				}
-			}
-		}
+		storeBlobs(transaction, record);
 
 		const auto length = record->getRawLength();
 		const auto data = record->getRawData();
@@ -353,21 +339,7 @@ void Replicator::updateRecord(CheckStatusWrapper* status,
 {
 	try
 	{
-		for (unsigned id = 0; id < newRecord->getCount(); id++)
-		{
-			IReplicatedField* field = newRecord->getField(id);
-			if (field != nullptr)
-			{
-				auto type = field->getType();
-				if (type == SQL_ARRAY || type == SQL_BLOB)
-				{
-					const auto blobId = (ISC_QUAD*) field->getData();
-
-					if (blobId && !BlobWrapper::blobIsNull(*blobId))
-						storeBlob(transaction, *blobId);
-				}
-			}
-		}
+		storeBlobs(transaction, newRecord);
 
 		const auto orgLength = orgRecord->getRawLength();
 		const auto orgData = orgRecord->getRawData();
@@ -454,6 +426,25 @@ void Replicator::executeSqlIntl(CheckStatusWrapper* status,
 	}
 }
 
+void Replicator::storeBlobs(Transaction* transaction, Firebird::IReplicatedRecord* record)
+{
+	for (unsigned id = 0; id < record->getCount(); id++)
+	{
+		IReplicatedField* field = record->getField(id);
+		if (field == nullptr)
+			continue;
+
+		auto type = field->getType();
+		if (type == SQL_ARRAY || type == SQL_BLOB)
+		{
+			const auto blobId = (ISC_QUAD*) field->getData();
+
+			if (blobId && !BlobWrapper::blobIsNull(*blobId))
+				storeBlob(transaction, *blobId);
+		}
+	}
+}
+
 void Replicator::cleanupTransaction(CheckStatusWrapper* status,
 									SINT64 number)
 {

src/jrd/replication/Replicator.h

@@ -341,6 +341,8 @@ namespace Replication
 							unsigned charset,
 							const char* schemaSearchPath,
 							const char* sql);
+
+		void storeBlobs(Transaction* transaction, Firebird::IReplicatedRecord* record);
 };
 
 } // namespace