()
| 145 | } |
| 146 | |
| 147 | @Test |
| 148 | public void add() throws Exception { |
| 149 | PutRequest put1 = new PutRequest(TABLE, KEY, FAMILY, QUALIFIER, VALUE); |
| 150 | put1.region = region; |
| 151 | PutRequest put2 = new PutRequest(TABLE, KEY, FAMILY, "myqual".getBytes(), VALUE); |
| 152 | put2.region = region; |
| 153 | DeleteRequest delete = new DeleteRequest(TABLE, KEY, FAMILY, QUALIFIER); |
| 154 | delete.region = region; |
| 155 | AppendRequest append = new AppendRequest(TABLE, KEY, FAMILY, QUALIFIER, VALUE); |
| 156 | append.region = region; |
| 157 | |
| 158 | // same type, different qualifiers |
| 159 | MultiAction multi = new MultiAction(); |
| 160 | assertEquals(0, multi.size()); // make sure it's empty |
| 161 | |
| 162 | multi.add(put1); |
| 163 | multi.add(put2); |
| 164 | assertEquals(2, multi.size()); |
| 165 | |
| 166 | // all kinds of types |
| 167 | multi = new MultiAction(); |
| 168 | multi.add(put1); |
| 169 | multi.add(put2); |
| 170 | multi.add(delete); |
| 171 | multi.add(append); |
| 172 | assertEquals(4, multi.size()); |
| 173 | |
| 174 | // double up on the same RPC as this is allowed |
| 175 | multi = new MultiAction(); |
| 176 | multi.add(put1); |
| 177 | multi.add(put1); |
| 178 | assertEquals(2, multi.size()); |
| 179 | } |
| 180 | |
| 181 | @Test |
| 182 | public void addErrors() throws Exception { |
no test coverage detected