本文整理汇总了Java中org.lightcouch.Response类的典型用法代码示例。如果您正苦于以下问题：Java Response类的具体用法？Java Response怎么用？Java Response使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Response类属于org.lightcouch包，在下文中一共展示了Response类的19个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: process
import org.lightcouch.Response; //导入依赖的package包/类
@Override
public void process(Exchange exchange) throws Exception {
JsonElement json = getBodyAsJsonElement(exchange);
Response save = saveJsonElement(json);
if (save == null) {
throw new CouchDbException("Could not save document [unknown reason]", exchange);
}
if (log.isTraceEnabled()) {
log.trace("Document saved [_id={}, _rev={}]", save.getId(), save.getRev());
}
exchange.getIn().setHeader(CouchDbConstants.HEADER_DOC_REV, save.getRev());
exchange.getIn().setHeader(CouchDbConstants.HEADER_DOC_ID, save.getId());
}
开发者ID:HydAu，项目名称:Camel，代码行数:15，代码来源:CouchDbProducer.java
示例2: saveJsonElement
import org.lightcouch.Response; //导入依赖的package包/类
private Response saveJsonElement(JsonElement json) {
Response save;
if (json instanceof JsonObject) {
JsonObject obj = (JsonObject) json;
if (obj.get("_rev") == null) {
save = couchClient.save(json);
} else {
save = couchClient.update(json);
}
} else {
save = couchClient.save(json);
}
return save;
}
开发者ID:HydAu，项目名称:Camel，代码行数:15，代码来源:CouchDbProducer.java
示例3: testStringBodyIsConvertedToJsonTree
import org.lightcouch.Response; //导入依赖的package包/类
@Test
public void testStringBodyIsConvertedToJsonTree() throws Exception {
when(msg.getMandatoryBody()).thenReturn("{ \"name\" : \"coldplay\" }");
when(client.save(anyObject())).thenAnswer(new Answer<Response>() {
@Override
public Response answer(InvocationOnMock invocation) throws Throwable {
assertTrue(invocation.getArguments()[0].getClass() + " but wanted " + JsonElement.class,
invocation.getArguments()[0] instanceof JsonElement);
return new Response();
}
});
producer.process(exchange);
verify(client).save(any(JsonObject.class));
}
开发者ID:HydAu，项目名称:Camel，代码行数:16，代码来源:CouchDbProducerTest.java
示例4: testInsertsOnly
import org.lightcouch.Response; //导入依赖的package包/类
@Test
public void testInsertsOnly() throws InterruptedException {
to.expectedHeaderReceived(CouchDbConstants.HEADER_METHOD, "UPDATE");
to.expectedMessageCount(1);
JsonElement obj = new Gson().toJsonTree("{ \"randomString\" : \"" + UUID.randomUUID() + "\" }");
Response resp = client.save(obj);
client.remove(resp.getId(), resp.getRev());
to.assertIsSatisfied();
}
开发者ID:HydAu，项目名称:Camel，代码行数:12，代码来源:CouchDbConsumerIntegrationTest.java
示例5: testDeletesOnly
import org.lightcouch.Response; //导入依赖的package包/类
@Test
public void testDeletesOnly() throws InterruptedException {
to.expectedHeaderReceived(CouchDbConstants.HEADER_METHOD, "UPDATE");
to.expectedMessageCount(1);
JsonElement obj = new Gson().toJsonTree("{ \"randomString\" : \"" + UUID.randomUUID() + "\" }");
Response resp = client.save(obj);
client.remove(resp.getId(), resp.getRev());
to.assertIsSatisfied();
}
开发者ID:HydAu，项目名称:Camel，代码行数:12，代码来源:CouchDbConsumerUpdatesIntegrationTest.java
示例6: testDeletesOnly
import org.lightcouch.Response; //导入依赖的package包/类
@Test
public void testDeletesOnly() throws InterruptedException {
to.expectedHeaderReceived(CouchDbConstants.HEADER_METHOD, "DELETE");
to.expectedMessageCount(1);
JsonElement obj = new Gson().toJsonTree("{ \"randomString\" : \"" + UUID.randomUUID() + "\" }");
Response resp = client.save(obj);
client.remove(resp.getId(), resp.getRev());
to.assertIsSatisfied();
}
开发者ID:HydAu，项目名称:Camel，代码行数:12，代码来源:CouchDbConsumerDeletesIntegrationTest.java
示例7: remove
import org.lightcouch.Response; //导入依赖的package包/类
public boolean remove(E entity, String path, String revision) {
if (entity == null)
return false;
CouchDbClient dbClient = connectionProvider.getDBClient(
CouchDbClient.class, path);
Response resp = dbClient.remove(entity.get_id(), revision);
resp = dbClient.purge(path, entity.get_id(), new String[]{revision});
System.out.println("remove object revision: " + entity.get_id() + ", repsonse: " + resp);
return true;
}
开发者ID:cplutte，项目名称:bts，代码行数:13，代码来源:CouchDBDao.java
示例8: removeDBLease
import org.lightcouch.Response; //导入依赖的package包/类
@Override
public boolean removeDBLease(DBLease lease, String path)
{
CouchDbClient dbClient = connectionProvider.getDBClient(
CouchDbClient.class, path);
Response resp = null;
if (lease.get_rev() != null)
{
try {
resp = dbClient.remove(lease.get_id(), lease.get_rev());
} catch (Exception e) {
DBLease entity2 = reload(lease.get_id(), path);
if (entity2 != null)
{
lease = entity2;
resp = dbClient.remove(lease.get_id(), lease.get_rev());
}
}
}
String rev = null;
if (resp != null)
{
rev = resp.getRev();
}
else
{
rev = lease.get_rev();
}
dbClient.purge(path, lease.get_id(), new String[]{rev});
return true;
}
开发者ID:cplutte，项目名称:bts，代码行数:32，代码来源:DBLeaseDaoImpl.java
示例9: persist
import org.lightcouch.Response; //导入依赖的package包/类
public <T extends DocumentBase> void persist(List<T> objects) {
List<Response> resp = dbClient.bulk(objects, false);
for (int i = 0; i < objects.size(); i++) {
Response r = resp.get(i);
T obj = objects.get(i);
obj.setId(r.getId());
obj.setRevision(r.getRev());
}
}
开发者ID:dawg6，项目名称:dhcalc，代码行数:11，代码来源:CouchDBDHCalcDatabase.java
示例10: save
import org.lightcouch.Response; //导入依赖的package包/类
public <S extends T> S save(S entity) {
Assert.notNull(entity, "The given entity must not be null.");
Response response;
if (ei.isNew(entity)) {
response = couchDbClient.save(entity);
} else {
response = couchDbClient.update(entity);
}
handleResponse(response, entity);
return entity;
}
开发者ID:rwitzel，项目名称:CouchRepository，代码行数:16，代码来源:LightCouchCrudRepository.java
示例11: delete
import org.lightcouch.Response; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
public void delete(ID id) {
Assert.notNull(id, "The given ID must not be null.");
View view = couchDbClient.view(designDocument() + "by_id");
List<Map> results = view.key(ei.toCouchId(id)).reduce(false).includeDocs(false).query(Map.class);
if (results.size() != 0) {
Map result = (Map) results.get(0).get("value");
Response response = couchDbClient.remove((String) result.get("_id"), (String) result.get("_rev"));
handleResponse(response, null);
}
}
开发者ID:rwitzel，项目名称:CouchRepository，代码行数:14，代码来源:LightCouchCrudRepository.java
示例12: handleResponse
import org.lightcouch.Response; //导入依赖的package包/类
/**
* @param response the response
* @param entity Null if the entity shall not be updated
*/
protected void handleResponse(Response response, T entity) {
if (response.getError() != null) {
throw new RuntimeException(String.format("error: %s, reason: %s, entity id: %s, rev: %s",
response.getError(), response.getReason(), response.getId(), response.getRev()));
} else if (entity != null) {
if (ei.isNew(entity)) {
ei.setId(entity, response.getId());
}
ei.setRev(entity, response.getRev());
}
}
开发者ID:rwitzel，项目名称:CouchRepository，代码行数:16，代码来源:LightCouchCrudRepository.java
示例13: executeBulk
import org.lightcouch.Response; //导入依赖的package包/类
@SuppressWarnings("unchecked")
protected void executeBulk(List<?> list, boolean updateEntities) {
List<Response> responses = couchDbClient.bulk(list, allOrNothing);
// handle errors
List<BulkOperationError> errors = new ArrayList<BulkOperationError>();
List<String> messages = new ArrayList<String>();
int index = 0;
for (Response response : responses) {
if (response.getError() != null) {
errors.add(new BulkOperationError(response.getId(), response.getRev(), response.getError(), response
.getReason()));
messages.add(response.toString());
} else if (updateEntities) {
T entity = (T) list.get(index);
if (ei.isNew(entity)) {
ei.setId(entity, response.getId());
}
ei.setRev(entity, response.getRev());
}
index++;
}
if (errors.size() > 0) {
throw new BulkOperationException(StringUtils.join(messages, ","), errors);
} else {
logger.debug("All documents have been processed.");
}
}
开发者ID:rwitzel，项目名称:CouchRepository，代码行数:29，代码来源:LightCouchCrudRepository.java
示例14: insertObject
import org.lightcouch.Response; //导入依赖的package包/类
@Override
public void insertObject(final NoSQLObject<Map<String, Object>> object) {
try {
final Response response = this.client.save(object.unwrap());
if (response.getError() != null && response.getError().length() > 0) {
throw new AppenderLoggingException("Failed to write log event to CouchDB due to error: " +
response.getError() + ".");
}
} catch (final Exception e) {
throw new AppenderLoggingException("Failed to write log event to CouchDB due to error: " + e.getMessage(),
e);
}
}
开发者ID:OuZhencong，项目名称:log4j2，代码行数:14，代码来源:CouchDBConnection.java
示例15: insertObject
import org.lightcouch.Response; //导入依赖的package包/类
@Override
public void insertObject(final NoSqlObject<Map<String, Object>> object) {
try {
final Response response = this.client.save(object.unwrap());
if (Strings.isNotEmpty(response.getError())) {
throw new AppenderLoggingException(
"Failed to write log event to CouchDB due to error: " + response.getError() + '.');
}
} catch (final Exception e) {
throw new AppenderLoggingException("Failed to write log event to CouchDB due to error: " + e.getMessage(),
e);
}
}
开发者ID:apache，项目名称:logging-log4j2，代码行数:14，代码来源:CouchDbConnection.java
示例16: update
import org.lightcouch.Response; //导入依赖的package包/类
public Response update(Object doc) {
return client.update(doc);
}
开发者ID:HydAu，项目名称:Camel，代码行数:4，代码来源:CouchDbClientWrapper.java
示例17: save
import org.lightcouch.Response; //导入依赖的package包/类
public Response save(Object doc) {
return client.save(doc);
}
开发者ID:HydAu，项目名称:Camel，代码行数:4，代码来源:CouchDbClientWrapper.java
示例18: purge
import org.lightcouch.Response; //导入依赖的package包/类
public void purge(E entity, String path) {
if (entity == null)
return;
if (entity.get_rev() == null) {
E entity2 = reload((K) entity.get_id(), path);
if (entity2 != null) {
entity = entity2;
}
}
CouchDbClient dbClient = connectionProvider.getDBClient(
CouchDbClient.class, path);
String[] revs = new String[1];
revs[0] = entity.get_rev();
Response resp = dbClient.purge(path, entity.get_id(), revs);
System.out.println("purged object : " + entity.get_id() + ", repsonse: " + resp);
// HttpClient client = new DefaultHttpClient();
// HttpPost post = new HttpPost(connectionProvider.getLocalDBURL() + "/"
// + path + "/_purge");
//
// post.setHeader("Content-Type", "application/json");
//
// try {
//
// List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>(1);
//
// String string = "{\"" + entity.get_id() + "\" : [\""
// + entity.get_rev() + "\" ]}";
// HttpEntity body = new ByteArrayEntity(string.getBytes("UTF-8"));
// System.out.println(string);
// // nameValuePairs.add(new BasicNameValuePair("i", "youremail"));
// // nameValuePairs
// // .add(new BasicNameValuePair("Passwd", "yourpassword"));
// // nameValuePairs.add(new BasicNameValuePair("accountType",
// // "GOOGLE"));
// // nameValuePairs.add(new BasicNameValuePair("source",
// // "Google-cURL-Example"));
// // nameValuePairs.add(new BasicNameValuePair("service", "ac2dm"));
//
// post.setEntity(body);
// HttpResponse response = client.execute(post);
// BufferedReader rd = new BufferedReader(new InputStreamReader(
// response.getEntity().getContent()));
//
// String line = "";
// while ((line = rd.readLine()) != null) {
// System.out.println(line);
// if (line.startsWith("Auth=")) {
// String key = line.substring(5);
// // do something with the key
// }
//
// }
// } catch (IOException e) {
// e.printStackTrace();
// }
}
开发者ID:cplutte，项目名称:bts，代码行数:60，代码来源:CouchDBDao.java
示例19: add
import org.lightcouch.Response; //导入依赖的package包/类
@Override
public BTSUser add(BTSUser entity, String path) {
BTSUser user = super.add(entity, path);
//FIXME check update _users
CouchDbClient dbClient = connectionProvider.getDBClient(CouchDbClient.class, _USERS);
InputStream is = null;
JsonObject jso = null;
try {
is = dbClient.find(COUCHDB_USERS_PREFIX + entity.getUserName());
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
boolean valid = false;
if (is != null)
{
jso = EmfModelHelper.load(is, JsonObject.class);
System.out.println(jso.toString());
valid = checkDBUserBTSUser(jso, entity);
}
if (valid)
{
return user;
}
jso = updateOrMakeNewDBUser(jso, entity, dbClient);
Response response = null;
if (is != null)
{
response = dbClient.update(jso);
}
else
{
System.out.println("USER JSON: " + jso.toString());
response = dbClient.save(jso);
}
user.set_rev(response.getRev());
return user;
}
开发者ID:cplutte，项目名称:bts，代码行数:43，代码来源:BTSUserDaoImpl.java
注：本文中的org.lightcouch.Response类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论