Skip to content

Commit f12cc8e

Browse files
authored
Null values replaced with string "NULL" and 0 for disturbance code for potentially better/less buggy aggregation in ClickHouse tables. (#45)
1 parent fa6adbe commit f12cc8e

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

Source/moja.modules.cbm/src/flatrecord.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ namespace cbm {
3939

4040
valueStr += (boost::format("%1%%2%%3%") % quote % currentValue % quote).str();
4141
} else {
42-
valueStr += "NULL";
42+
valueStr += "'NULL'";
4343
}
4444

4545
classifierStr += valueStr;
@@ -130,8 +130,8 @@ namespace cbm {
130130
} else {
131131
return (boost::format(dbRecord)
132132
% _year % classifierStr % _landClass % _ageClass % previousClassifierStr % _previousLandClass
133-
% _previousAgeClass % (_disturbanceType.isNull() || _disturbanceType == "" ? "NULL" : ((boost::format("'%1%'") % _disturbanceType.value()).str()))
134-
% (_disturbanceCode.isNull() ? "NULL" : pqxx::to_string(_disturbanceCode.value()))
133+
% _previousAgeClass % (_disturbanceType.isNull() || _disturbanceType == "" ? "'NULL'" : ((boost::format("'%1%'") % _disturbanceType.value()).str()))
134+
% (_disturbanceCode.isNull() ? "0" : pqxx::to_string(_disturbanceCode.value()))
135135
% _srcPool % _dstPool % _flux).str();
136136
}
137137
}

0 commit comments

Comments
 (0)