Function compareDecompressedData

inline_verifier.go:657–720

(source, target map[string]map[string][]byte)

}

func compareDecompressedData(source, target map[string]map[string][]byte) map[string]InlineVerifierMismatches {
	mismatchSet := map[string]InlineVerifierMismatches{}

	for paginationKey, targetDecompressedColumns := range target {
		sourceDecompressedColumns, exists := source[paginationKey]
		if !exists {
			// row missing on source
			mismatchSet[paginationKey] = InlineVerifierMismatches{
				Pk:           paginationKey,
				MismatchType: MismatchRowMissingOnSource,
			}
			continue
		}

		for colName, targetData := range targetDecompressedColumns {
			sourceData, exists := sourceDecompressedColumns[colName]
			if !exists {
				mismatchSet[paginationKey] = InlineVerifierMismatches{
					Pk:             paginationKey,
					MismatchType:   MismatchColumnMissingOnSource,
					MismatchColumn: colName,
				}
				break // no need to compare other columns
			} else if !bytes.Equal(sourceData, targetData) {
				sourceChecksum := md5.Sum(sourceData)
				targetChecksum := md5.Sum(targetData)

				mismatchSet[paginationKey] = InlineVerifierMismatches{
					Pk:             paginationKey,
					MismatchType:   MismatchColumnValueDifference,
					MismatchColumn: colName,
					SourceChecksum: hex.EncodeToString(sourceChecksum[:]),
					TargetChecksum: hex.EncodeToString(targetChecksum[:]),
				}
				break // no need to compare other columns
			}
		}
	}

	for paginationKey, sourceDecompressedColumns := range source {
		targetDecompressedColumns, exists := target[paginationKey]
		if !exists {
			// row missing on target
			mismatchSet[paginationKey] = InlineVerifierMismatches{
				Pk:           paginationKey,
				MismatchType: MismatchRowMissingOnTarget,
			}
			continue
		}

		for colName := range sourceDecompressedColumns {
			_, exists := targetDecompressedColumns[colName]
			if !exists {
				mismatchSet[paginationKey] = InlineVerifierMismatches{
					Pk:             paginationKey,
					MismatchColumn: colName,
					MismatchType:   MismatchColumnMissingOnTarget,
				}