20111006-1
trunk/TestSock.java (diff) trunk/TestSock.class (diff)| @@ -399,11 +399,6 @@ | ||
| 399 | 399 | String[] setTag = null; |
| 400 | 400 | int counter = 0; |
| 401 | 401 | |
| 402 | - String prefix = ""; | |
| 403 | - if (args.length > 4) { | |
| 404 | - prefix = "_" + args[4]; | |
| 405 | - } | |
| 406 | - | |
| 407 | 402 | long start = new Date().getTime(); |
| 408 | 403 | |
| 409 | 404 | for (int i = 0; i < Integer.parseInt(args[3]);i++) { |
| @@ -421,7 +416,7 @@ | ||
| 421 | 416 | counter = 0; |
| 422 | 417 | } |
| 423 | 418 | |
| 424 | - if (!okuyamaClient.setValue("tagsampledatakey_" + new Integer(i).toString() + prefix, setTag, "tagsamplesavedata_" + new Integer(i).toString() + prefix)) { | |
| 419 | + if (!okuyamaClient.setValue("tagsampledatakey_" + new Integer(i).toString(), setTag, "tagsamplesavedata_" + new Integer(i).toString())) { | |
| 425 | 420 | System.out.println("OkuyamaClient - error"); |
| 426 | 421 | } |
| 427 | 422 | } |
| @@ -1625,7 +1620,7 @@ | ||
| 1625 | 1620 | okuyamaClient.connect(args[1], port); |
| 1626 | 1621 | |
| 1627 | 1622 | long start = new Date().getTime(); |
| 1628 | - OkuyamaResultSet okuyamaResultSet = okuyamaClient.getTagKeyResult(args[3]); | |
| 1623 | + OkuyamaResultSet okuyamaResultSet = okuyamaClient.getTagKeysResult(args[3]); | |
| 1629 | 1624 | long end = new Date().getTime(); |
| 1630 | 1625 | if (okuyamaResultSet == null) { |
| 1631 | 1626 | System.out.println(okuyamaResultSet); |
| @@ -1651,7 +1646,7 @@ | ||
| 1651 | 1646 | okuyamaClient.connect(args[1], port); |
| 1652 | 1647 | |
| 1653 | 1648 | long start = new Date().getTime(); |
| 1654 | - OkuyamaResultSet okuyamaResultSet = okuyamaClient.getTagKeyResult(args[3]); | |
| 1649 | + OkuyamaResultSet okuyamaResultSet = okuyamaClient.getTagKeysResult(args[3]); | |
| 1655 | 1650 | |
| 1656 | 1651 | if (okuyamaResultSet == null) { |
| 1657 | 1652 | System.out.println(okuyamaResultSet); |
| @@ -1670,6 +1665,59 @@ | ||
| 1670 | 1665 | System.out.println((end - start) + "milli second"); |
| 1671 | 1666 | |
| 1672 | 1667 | okuyamaClient.close(); |
| 1668 | + } else if (args[0].equals("35")) { | |
| 1669 | + | |
| 1670 | + int port = Integer.parseInt(args[2]); | |
| 1671 | + // OkuyamaClientを使用して複数Tag指定でKeyとValueのMapを取得 | |
| 1672 | + OkuyamaClient okuyamaClient = new OkuyamaClient(); | |
| 1673 | + okuyamaClient.connect(args[1], port); | |
| 1674 | + | |
| 1675 | + long start = new Date().getTime(); | |
| 1676 | + OkuyamaResultSet okuyamaResultSet = okuyamaClient.getMultiTagKeysResult(args[3].split(","), new Boolean(args[4]).booleanValue()); | |
| 1677 | + long end = new Date().getTime(); | |
| 1678 | + if (okuyamaResultSet == null) { | |
| 1679 | + System.out.println(okuyamaResultSet); | |
| 1680 | + } else { | |
| 1681 | + int counter = 0; | |
| 1682 | + while(okuyamaResultSet.next()) { | |
| 1683 | + counter++; | |
| 1684 | + System.out.println("Key=" + (String)okuyamaResultSet.getKey()); | |
| 1685 | + System.out.println("Value=" + (String)okuyamaResultSet.getValue()); | |
| 1686 | + } | |
| 1687 | + okuyamaResultSet.close(); | |
| 1688 | + | |
| 1689 | + System.out.println("ResultSize = [" + counter + "]"); | |
| 1690 | + } | |
| 1691 | + System.out.println((end - start) + "milli second"); | |
| 1692 | + | |
| 1693 | + okuyamaClient.close(); | |
| 1694 | + } else if (args[0].equals("35.1")) { | |
| 1695 | + | |
| 1696 | + int port = Integer.parseInt(args[2]); | |
| 1697 | + // OkuyamaClientを使用して複数Tag指定でKeyとValueのMapを取得 | |
| 1698 | + OkuyamaClient okuyamaClient = new OkuyamaClient(); | |
| 1699 | + okuyamaClient.connect(args[1], port); | |
| 1700 | + | |
| 1701 | + long start = new Date().getTime(); | |
| 1702 | + OkuyamaResultSet okuyamaResultSet = okuyamaClient.getMultiTagKeysResult(args[3].split(","), new Boolean(args[4]).booleanValue()); | |
| 1703 | + | |
| 1704 | + if (okuyamaResultSet == null) { | |
| 1705 | + System.out.println(okuyamaResultSet); | |
| 1706 | + } else { | |
| 1707 | + int counter = 0; | |
| 1708 | + while(okuyamaResultSet.next()) { | |
| 1709 | + counter++; | |
| 1710 | + //System.out.println("Key=" + (String)okuyamaResultSet.getKey()); | |
| 1711 | + //System.out.println("Value=" + (String)okuyamaResultSet.getValue()); | |
| 1712 | + } | |
| 1713 | + okuyamaResultSet.close(); | |
| 1714 | + | |
| 1715 | + System.out.println("ResultSize = [" + counter + "]"); | |
| 1716 | + } | |
| 1717 | + long end = new Date().getTime(); | |
| 1718 | + System.out.println((end - start) + "milli second"); | |
| 1719 | + | |
| 1720 | + okuyamaClient.close(); | |
| 1673 | 1721 | } else if (args[0].equals("999")) { |
| 1674 | 1722 | |
| 1675 | 1723 | int port = Integer.parseInt(args[2]); |
Fork