现在的位置: 首页 > 综合 > 正文

涉及sdu数据同步的代码

2013年09月09日 ⁄ 综合 ⁄ 共 2565字 ⁄ 字号 评论关闭

 List<Route> routList = null;
        Member member = new Member();
        routList = ROUTE_SERVICE.queryRouteListByTradeTypeAndNo(Constant.FULLNUMBER_SERVICE,
                tmpMember.getFullNumber());

        LDS_ADAPTER_SERVICE.setRoute(routList);

        List<String> paramList = new ArrayList<String>();
        List<Object> valueList = new ArrayList<Object>();

        // paramList中的值必须和naming-sql中的参数名称一致
        paramList.add(MemberConstants.FULL_NUMER);
        valueList.add(tmpMember.getFullNumber());

        try
        {
            QueryResultSet resultSet1 = LDS_ADAPTER_SERVICE.queryData(routList
                    .get(0).getSduid(), "QUERY_SEE_MEMBER_FULLINFO1", paramList,
                    valueList);

            if (resultSet1.next())
            {
                Iterator<Entry<String, String>> iter = MemberConstants.fieldsDBRefMemebr1
                        .entrySet().iterator();
                while (iter.hasNext())
                {
                    Map.Entry entry = (Map.Entry) iter.next();
                    Object key = entry.getKey();
                    Object val = entry.getValue();
                    Object value;
                    if ("resyncCounter".equalsIgnoreCase((String)key))
                    {
                        value = resultSet1.getInt(val + "");
                    }
                    else
                    {
                        value = resultSet1.getString(Integer.valueOf(val + ""));
                    }
                    setObjByDataSet((String) key, value, member);
                }
            }
           
            QueryResultSet resultSet2 = LDS_ADAPTER_SERVICE.queryData(routList
                    .get(0).getSduid(), "QUERY_SEE_MEMBER_FULLINFO2", paramList,
                    valueList);

            if (resultSet2.next())
            {
                Iterator<Entry<String, String>> iter = MemberConstants.fieldsDBRefMemebr2
                        .entrySet().iterator();
                while (iter.hasNext())
                {
                    Map.Entry entry = (Map.Entry) iter.next();
                    Object key = entry.getKey();
                    Object val = entry.getValue();
                    Object value;
                    if ("resyncCounter".equalsIgnoreCase((String)key))
                    {
                        value = resultSet2.getInt(val + "");
                    }
                    else
                    {
                        value = resultSet2.getString(Integer.valueOf(val + ""));
                    }
                    setObjByDataSet((String) key, value, member);
                }
            }
        }
        catch (Exception e)
        {
            LOGGER.error(e.getMessage());
        }

        return member;

抱歉!评论已关闭.