- @Ignore
- public void Test4_pureZKUpdate() throws Exception {
- RestMusicBmAPI bmApi = new RestMusicBmAPI();
- bmApi.pureZkCreate("sample1");
- JsonInsert jsonInsert = new JsonInsert();
- Map<String, String> consistencyInfo = new HashMap<>();
- Map<String, Object> values = new HashMap<>();
- values.put("uuid", "cfd66ccc-d857-4e90-b1e5-df98a3d40cd6");
- values.put("emp_name", "testName_create");
- values.put("emp_salary", 500);
- consistencyInfo.put("type", "eventual");
- jsonInsert.setConsistencyInfo(consistencyInfo);
- jsonInsert.setKeyspaceName(keyspaceName);
- jsonInsert.setTableName(tableName);
- jsonInsert.setValues(values);
- bmApi.pureZkUpdate(jsonInsert, "sampleNode1");
- }
-
- @Ignore
- public void Test4_pureZKGet() throws Exception {
- RestMusicBmAPI bmApi = new RestMusicBmAPI();
- bmApi.pureZkGet("sample");
- }
-
- /*
- * @Test public void Test5_ZKAtomicPut_atomic() throws Exception {
- * RestMusicBmAPI bmApi = new RestMusicBmAPI(); JsonInsert jsonInsert = new
- * JsonInsert(); Map<String, String> consistencyInfo = new HashMap<>();
- * Map<String, Object> values = new HashMap<>(); values.put("uuid",
- * "cfd66ccc-d857-4e90-b1e5-df98a3d40cd6"); values.put("emp_name",
- * "testName_create"); values.put("emp_salary", 1500);
- * consistencyInfo.put("type", "atomic");
- * jsonInsert.setConsistencyInfo(consistencyInfo);
- * jsonInsert.setKeyspaceName(keyspaceName); jsonInsert.setTableName(tableName);
- * jsonInsert.setValues(values); bmApi.pureZkAtomicPut(jsonInsert, lockName,
- * "sampleNode1"); }
- */
- /*
- * @Test public void Test5_ZKAtomicPut_atomic_with_delete() throws Exception {
- * RestMusicBmAPI bmApi = new RestMusicBmAPI(); JsonInsert jsonInsert = new
- * JsonInsert(); Map<String, String> consistencyInfo = new HashMap<>();
- * Map<String, Object> values = new HashMap<>(); values.put("uuid",
- * "cfd66ccc-d857-4e90-b1e5-df98a3d40cd6"); values.put("emp_name",
- * "testName_create"); values.put("emp_salary", 1500);
- * consistencyInfo.put("type", "atomic_delete_lock");
- * jsonInsert.setConsistencyInfo(consistencyInfo);
- * jsonInsert.setKeyspaceName(keyspaceName); jsonInsert.setTableName(tableName);
- * jsonInsert.setValues(values); bmApi.pureZkAtomicPut(jsonInsert, lockName,
- * "sampleNode1"); }
- */
-
- /*
- * @Test public void Test5_ZKAtomicGet_atomic() throws Exception {
- * RestMusicBmAPI bmApi = new RestMusicBmAPI(); JsonInsert jsonInsert = new
- * JsonInsert(); Map<String, String> consistencyInfo = new HashMap<>();
- * Map<String, Object> values = new HashMap<>(); values.put("uuid",
- * "cfd66ccc-d857-4e90-b1e5-df98a3d40cd6"); values.put("emp_name",
- * "testName_create"); values.put("emp_salary", 1500);
- * consistencyInfo.put("type", "atomic_delete_lock");
- * jsonInsert.setConsistencyInfo(consistencyInfo);
- * jsonInsert.setKeyspaceName(keyspaceName); jsonInsert.setTableName(tableName);
- * jsonInsert.setValues(values); bmApi.pureZkAtomicGet(jsonInsert, lockName,
- * "sampleNode1"); }
- */
-
- /*
- * @Test public void Test5_ZKAtomicGet_atomic_with_delete() throws Exception {
- * RestMusicBmAPI bmApi = new RestMusicBmAPI(); JsonInsert jsonInsert = new
- * JsonInsert(); Map<String, String> consistencyInfo = new HashMap<>();
- * Map<String, Object> values = new HashMap<>(); values.put("uuid",
- * "cfd66ccc-d857-4e90-b1e5-df98a3d40cd6"); values.put("emp_name",
- * "testName_create"); values.put("emp_salary", 1500);
- * consistencyInfo.put("type", "atomic_delete_lock");
- * jsonInsert.setConsistencyInfo(consistencyInfo);
- * jsonInsert.setKeyspaceName(keyspaceName); jsonInsert.setTableName(tableName);
- * jsonInsert.setValues(values); bmApi.pureZkAtomicGet(jsonInsert, lockName,
- * "sampleNode1"); }
- */
-
- @Ignore
- @Test
- public void Test5_updateCassa() throws Exception {
- RestMusicBmAPI bmApi = new RestMusicBmAPI();
- JsonInsert jsonInsert = new JsonInsert();
- Map<String, String> consistencyInfo = new HashMap<>();
- Map<String, Object> values = new HashMap<>();
- values.put("emp_salary", 1500);
- consistencyInfo.put("type", "eventual");
- jsonInsert.setConsistencyInfo(consistencyInfo);
- jsonInsert.setKeyspaceName(keyspaceName);
- jsonInsert.setTableName(tableName);
- jsonInsert.setValues(values);
- MultivaluedMap<String, String> row = new MultivaluedMapImpl();
- row.add("emp_name", "testName_create");
- Mockito.when(info.getQueryParameters()).thenReturn(row);
- //bmApi.updateTableCassa(jsonInsert, keyspaceName, tableName, info);
- }
-
- // RestMusicConditional
- @Test
- public void Test5_createTable_conditional() throws Exception {
- JsonTable jsonTable = new JsonTable();
- Map<String, String> consistencyInfo = new HashMap<>();
- Map<String, String> fields = new HashMap<>();
- fields.put("id", "text");
- fields.put("plans", "Map<text,text>");
- fields.put("PRIMARY KEY", "(id)");
- consistencyInfo.put("type", "eventual");
- jsonTable.setConsistencyInfo(consistencyInfo);
- jsonTable.setKeyspaceName(keyspaceName);
- jsonTable.setPrimaryKey("id");
- jsonTable.setTableName(tableNameConditional);
- jsonTable.setFields(fields);
- Mockito.doNothing().when(http).addHeader(xLatestVersion, MusicUtil.getVersion());
- /*Response response = data.createTable("1", "1", "1",
- "abc66ccc-d857-4e90-b1e5-df98a3d40ce6",appName, authorization,
- jsonTable, keyspaceName, tableNameConditional);
- System.out.println("#######status is " + response.getStatus());
- System.out.println("Entity" + response.getEntity());
- //assertEquals(200, response.getStatus());
- assertEquals(401, response.getStatus());
- */
- }
-