Skip to content

Commit b03f899

Browse files
committed
code review changes
1 parent fe1208e commit b03f899

3 files changed

Lines changed: 9016 additions & 9001 deletions

File tree

api/src/org/labkey/api/dataiterator/MapDataIterator.java

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,15 @@ public interface MapDataIterator extends DataIterator
5151
if (null == row)
5252
return null;
5353

54-
Map<String, Object> rowClean = new CaseInsensitiveHashMap<>(row);
55-
rowClean.remove(ExistingRecordDataIterator.EXISTING_RECORD_COLUMN_NAME);
54+
if (!row.containsKey(ExistingRecordDataIterator.EXISTING_RECORD_COLUMN_NAME))
55+
return row;
56+
57+
Map<String, Object> rowClean = new CaseInsensitiveHashMap<>(row.size());
58+
row.forEach((k, v) -> {
59+
if (!ExistingRecordDataIterator.EXISTING_RECORD_COLUMN_NAME.equals(k))
60+
rowClean.put(k, v);
61+
});
62+
5663
return rowClean;
5764
}
5865

api/src/org/labkey/api/query/AbstractQueryImportAction.java

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@
3030
import org.labkey.api.action.SpringActionController;
3131
import org.labkey.api.attachments.FileAttachmentFile;
3232
import org.labkey.api.audit.TransactionAuditProvider;
33+
import org.labkey.api.collections.LabKeyCollectors;
3334
import org.labkey.api.data.Container;
3435
import org.labkey.api.data.DbSchema;
3536
import org.labkey.api.data.DbScope;
@@ -56,6 +57,7 @@
5657
import org.labkey.api.util.CPUTimer;
5758
import org.labkey.api.util.FileStream;
5859
import org.labkey.api.util.FileUtil;
60+
import org.labkey.api.util.JsonUtil;
5961
import org.labkey.api.util.PageFlowUtil;
6062
import org.labkey.api.util.Pair;
6163
import org.labkey.api.util.Path;
@@ -76,6 +78,7 @@
7678
import java.io.IOException;
7779
import java.sql.SQLException;
7880
import java.util.ArrayList;
81+
import java.util.Collection;
7982
import java.util.HashMap;
8083
import java.util.List;
8184
import java.util.Map;
@@ -761,6 +764,14 @@ protected JSONObject createSuccessResponse(int rowCount)
761764
return response;
762765
}
763766

767+
public static JSONArray prepareRowsResponse(@NotNull Collection<Map<String, Object>> rows)
768+
{
769+
return rows.stream()
770+
.map(JsonUtil::toMapPreserveNonFinite)
771+
.map(JsonUtil::toJsonPreserveNulls)
772+
.collect(LabKeyCollectors.toJSONArray());
773+
}
774+
764775
@Override
765776
protected ApiResponseWriter createResponseWriter() throws IOException
766777
{

0 commit comments

Comments
 (0)