Тупик при обработке результатов - PullRequest
0 голосов
/ 14 января 2020

Я обрабатываю около 300 тыс. Записей, извлеченных в наборе результатов.

ResultSetMetaData md = resultSet.getMetaData();
List<Map<String, String>> list = new ArrayList<Map<String, String>>();

    while (resultSet.next()) {
        String prodIda2a2 = "";
        String skuIda2a2 = "";
        String pslIda2a2 = "";
        String sslIda2a2 = "";
        String csIda2a2 = "";
        int dataColumns = md.getColumnCount();
        Map<String, String> row = new ConcurrentHashMap<String, String>();
        for (int i = 1; i <= dataColumns; ++i) {
            String columnName = md.getColumnName(i);
            String value = String.valueOf(resultSet.getObject(i));
            if (columnName.equals("productidA2A2"))
                prodIda2a2 = value;
            else if (columnName.equals("skuidA2A2"))
                skuIda2a2 = value;
            else if (columnName.equals("productseasonlinkidA2A2"))
                pslIda2a2 = value;
            else if (columnName.equals("skuseasonlinkidA2A2"))
                sslIda2a2 = value;
            else if (columnName.equals("skucostsheetidA2A2"))
                csIda2a2 = value;

            row.put(columnName, value);
        }
        list.add(row);

Я захожу в тупик в следующих двух строках.

String value = String.valueOf(resultSet.getObject(i));
row.put(columnName, value);

Буду признателен за любую помощь. Ниже приводится исключение:

"Соединение RMI TCP (8) -10.13.16.6" Id = 30 демон prio = 5 RUNNABLE Заблокировано (cnt): 400; Ожидание (cnt): 391 наночастиц CPU: 40859375000; Нанос пользователя: 39515625000; Выделено байтов: 23685333312 Контекст метода: q3ixzpr; k5d8myjr; 13996; h2ex9v; 1; Сеанс БД: 72% от 1 ЦП, используемого контекстом: 10.185872840911994 (40859375000/401137689800); Байты, выделенные контекстом: 23684723280
в java .util.concurrent.ConcurrentHashMap.putVal (ConcurrentHashMap. java: 1019) в java .util.concurrent.ConcurrentHashMap.put (ConcurrentHashMap. * 1019: 1009: ) на com.integration.common.initialload.loader.pushData (Loader. java: 255) на com.integration.common.initialload.loader.initloader (Loader. java: 71)
в sun.reflect .NativeMethodAccessorImpl.invoke0 (собственный метод) в sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl. java: 62) в sun.reflect.DelegatingMethodAccessorIccessl.inl * 43.mpl * 10ho. .Method.invoke (Method. java: 498) в wt.method.MethodResultWriter.writeExternal (MethodResultWriter. java: 165) в wt.method.MethodResult.writeExternal (MethodResult. java: 226) в java .io.ObjectOutputStream.writeExternalData (ObjectOutputStream. java: 1456) в java .io.ObjectOutputStream.writeOrdinaryObject (ObjectOutputStream. java: 1430) в java .io.ObjectOutputStream.writeOw ject0 (ObjectOutputStream. java: 1178) в java .io.ObjectOutputStream.writeObject (ObjectOutputStream. java: 348) в sun.rmi.server.UnicastRef.marshalValue (UnicastRef. java: 290) в ВС .rmi.server.UnicastServerRef.dispatch (UnicastServerRef. java: 367)
в sun.rmi.transport.Transport $ 1.run (Транспорт. java: 200) в sun.rmi.transport.Transport $ 1. запустите (Transport. java: 197) в java .security.AccessController.doPrivileged (собственный метод) в sun.rmi.transport.Transport.serviceCall (Transport. java: 196) в sun.rmi.transport. tcp.TCPTransport.handleMessages (TCPTransport. java: 573) в sun.rmi.transport.tcp.TCPTransport $ ConnectionHandler.run0 (TCPTransport. java: 834) в sun.rmi.transport.tcp.TCPTransport $ ConnectionHandler. lambda $ run $ 0 (TCPTransport. java: 688) в sun.rmi.transport.tcp.TCPTransport $ ConnectionHandler $$ Lambda $ 46 / 1748043306.run (неизвестный источник) в java .security.AccessController.doPrivileged (собственный метод) ) at sun.rmi.transport.tcp.TCPTransport $ ConnectionHandler.run (TCPTransport. * 10 46 *: 687) в java .util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor. java: 1149) в java .util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor. java: 624) java .lang.Thread.run (Thread. java: 748) Заблокированные синхронизаторы: - java .util.concurrent. ThreadPoolExecutor$Worker@5c5239fa

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...