zoukankan      html  css  js  c++  java
  • Hibernate 一次查询分多次返回 避免内存溢出

        public void grpcGpioDevice(StreamObserver<NI_GetAllDeviceListResponse> responseObserver,
                Map<String, VsGrpc> vcuMap) {
            Session session = null;
            final StringBuffer sb = new StringBuffer("select name,vs_id,"
                    + "description,direction,device_id,vx_external_id from EMS_GPIO_DEVICE ");
            try {
                session = getSession();
                Query query = session.createSQLQuery(sb.toString()).setFetchSize(grpcRspNumber);
                ScrollableResults results =  query.scroll();
                List<GpioDevice> gpioList = new ArrayList<>();
                
                while(results.next()) {
                    Object[] obj = results.get();
                    GpioDevice gd = new GpioDevice();
                    gd.setName(obj[0] == null ?"":obj[0].toString());
                    gd.setVsId(obj[1] == null ?"":obj[1].toString());
                    gd.setDescription(obj[2] == null ?"":obj[2].toString());
                    gd.setDirection(obj[3] == null ?0:Integer.parseInt(obj[3].toString()));
                    gd.setDeviceId(obj[4] == null ?"":obj[4].toString());
                    gd.setVxExternalId(obj[5] == null ?"":obj[5].toString());
                    gpioList.add(gd);
                    if(gpioList.size()==grpcRspNumber) {
                        NI_GetAllDeviceListResponse.Builder response = NI_GetAllDeviceListResponse.newBuilder();
                        grpcFlowResult.getAiAoDiDoInfo(null, gpioList, vcuMap, "DIDO", response);
                        grpcFlowResult.result(response, responseObserver);
                        gpioList.clear();
                    }
                }
                if(gpioList.size()>0 && gpioList.size()<grpcRspNumber) {
                    NI_GetAllDeviceListResponse.Builder response = NI_GetAllDeviceListResponse.newBuilder();
                    grpcFlowResult.getAiAoDiDoInfo(null, gpioList, vcuMap, "DIDO", response);
                    grpcFlowResult.result(response, responseObserver);
                    gpioList.clear();
                }
            }catch (RuntimeException e) {
                e.printStackTrace();
              } catch (Exception ex) {
                ex.printStackTrace();
            } finally {
                releaseSession(session);
            }
        }
    View Code
  • 相关阅读:
    『水晶报表』实现打印
    C#水晶报表教程
    C#
    C# 跨线程调用控件
    SQL中DateTime转换成Varchar样式
    解决SQL Server 阻止了对组件 'Ad Hoc Distributed Queries' 的 STATEMENT'OpenRowset/OpenDatasource' 的访问的方法
    配置JAVA的环境变量
    lucene3.0_IndexSearcher排序
    tomcat如何配置环境变量
    无法启动DISTRIBUTED TRANSACTION COORDINATOR解决方法
  • 原文地址:https://www.cnblogs.com/acme6/p/10514918.html
Copyright © 2011-2022 走看看