(empty log message)
trunk/TestSock.java (diff) trunk/TestSock.class (diff)| @@ -440,6 +440,24 @@ | ||
| 440 | 440 | System.out.println((end - start) + "milli second"); |
| 441 | 441 | |
| 442 | 442 | okuyamaClient.close(); |
| 443 | + } else if (args[0].equals("3.2")) { | |
| 444 | + int port = Integer.parseInt(args[2]); | |
| 445 | + // OkuyamaClientを使用してデータを保存(Tagあり) | |
| 446 | + OkuyamaClient okuyamaClient = new OkuyamaClient(); | |
| 447 | + okuyamaClient.connect(args[1], port); | |
| 448 | + String[] setTag = args[3].split(" "); | |
| 449 | + | |
| 450 | + int counter = 0; | |
| 451 | + String keyStr = null; | |
| 452 | + | |
| 453 | + long start = new Date().getTime(); | |
| 454 | + for (int idx = 0; idx < Integer.parseInt(args[4]); idx++) { | |
| 455 | + okuyamaClient.setValue(new Integer(idx).toString(), setTag, new Integer(idx).toString()); | |
| 456 | + } | |
| 457 | + long end = new Date().getTime(); | |
| 458 | + System.out.println((end - start) + "milli second"); | |
| 459 | + | |
| 460 | + okuyamaClient.close(); | |
| 443 | 461 | } else if (args[0].equals("4")) { |
| 444 | 462 | |
| 445 | 463 | int port = Integer.parseInt(args[2]); |
| @@ -1120,6 +1138,26 @@ | ||
| 1120 | 1138 | System.out.println((end - start) + "milli second"); |
| 1121 | 1139 | |
| 1122 | 1140 | okuyamaClient.close(); |
| 1141 | + } else if (args[0].equals("24.2")) { | |
| 1142 | + | |
| 1143 | + // OkuyamaClientを使用してデータの加算を行う | |
| 1144 | + int port = Integer.parseInt(args[2]); | |
| 1145 | + | |
| 1146 | + OkuyamaClient okuyamaClient = new OkuyamaClient(); | |
| 1147 | + okuyamaClient.connect(args[1], port); | |
| 1148 | + | |
| 1149 | + long start = new Date().getTime(); | |
| 1150 | + Object[] ret = okuyamaClient.incrValue(args[3], Integer.parseInt(args[4])); | |
| 1151 | + long end = new Date().getTime(); | |
| 1152 | + if (ret[0].equals("true")) { | |
| 1153 | + System.out.println(ret[1]); | |
| 1154 | + } else { | |
| 1155 | + System.out.println(ret[0]); | |
| 1156 | + System.out.println(ret[1]); | |
| 1157 | + } | |
| 1158 | + System.out.println((end - start) + "milli second"); | |
| 1159 | + | |
| 1160 | + okuyamaClient.close(); | |
| 1123 | 1161 | } else if (args[0].equals("25")) { |
| 1124 | 1162 | |
| 1125 | 1163 | // OkuyamaClientを使用してデータの減算を行う |
| @@ -1665,6 +1703,35 @@ | ||
| 1665 | 1703 | System.out.println((end - start) + "milli second"); |
| 1666 | 1704 | |
| 1667 | 1705 | okuyamaClient.close(); |
| 1706 | + } else if (args[0].equals("34.2")) { | |
| 1707 | + | |
| 1708 | + int port = Integer.parseInt(args[2]); | |
| 1709 | + // OkuyamaClientを使用して複数Tag指定でKeyとValueのMapを取得 | |
| 1710 | + OkuyamaClient okuyamaClient = new OkuyamaClient(); | |
| 1711 | + okuyamaClient.connect(args[1], port); | |
| 1712 | + | |
| 1713 | + long start = new Date().getTime(); | |
| 1714 | + double[] rangeSet = {Double.parseDouble(args[4]), Double.parseDouble(args[5])}; | |
| 1715 | + OkuyamaResultSet okuyamaResultSet = okuyamaClient.getTagKeysResult(args[3], rangeSet, Integer.parseInt(args[6])); | |
| 1716 | + | |
| 1717 | + if (okuyamaResultSet == null) { | |
| 1718 | + System.out.println(okuyamaResultSet); | |
| 1719 | + } else { | |
| 1720 | + int counter = 0; | |
| 1721 | + while(okuyamaResultSet.next()) { | |
| 1722 | + counter++; | |
| 1723 | + //System.out.println("Key=" + (String)okuyamaResultSet.getKey()); | |
| 1724 | + //System.out.println("Value=" + (String)okuyamaResultSet.getValue()); | |
| 1725 | + } | |
| 1726 | + okuyamaResultSet.close(); | |
| 1727 | + | |
| 1728 | + System.out.println("ResultSize = [" + counter + "]"); | |
| 1729 | + } | |
| 1730 | + long end = new Date().getTime(); | |
| 1731 | + System.out.println((end - start) + "milli second"); | |
| 1732 | + | |
| 1733 | + okuyamaClient.close(); | |
| 1734 | + | |
| 1668 | 1735 | } else if (args[0].equals("35")) { |
| 1669 | 1736 | |
| 1670 | 1737 | int port = Integer.parseInt(args[2]); |
Fork