本文整理汇总了Java中com.couchbase.client.java.document.RawJsonDocument类的典型用法代码示例。如果您正苦于以下问题：Java RawJsonDocument类的具体用法？Java RawJsonDocument怎么用？Java RawJsonDocument使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
RawJsonDocument类属于com.couchbase.client.java.document包，在下文中一共展示了RawJsonDocument类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: save
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public RegisteredService save(final RegisteredService service) {
logger.debug("Saving service {}", service);
if (service.getId() == AbstractRegisteredService.INITIAL_IDENTIFIER_VALUE) {
((AbstractRegisteredService) service).setId(service.hashCode());
}
final StringWriter stringWriter = new StringWriter();
registeredServiceJsonSerializer.toJson(stringWriter, service);
couchbase.bucket().upsert(
RawJsonDocument.create(
String.valueOf(service.getId()),
0, stringWriter.toString()));
return service;
}
开发者ID:hsj-xiaokang，项目名称:springboot-shiro-cas-mybatis，代码行数:18，代码来源:CouchbaseServiceRegistryDao.java
示例2: load
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public List<RegisteredService> load() {
try {
logger.debug("Loading services");
final Bucket bucket = couchbase.bucket();
final ViewResult allKeys = bucket.query(ViewQuery.from(UTIL_DOCUMENT, ALL_SERVICES_VIEW.name()));
final List<RegisteredService> services = new LinkedList<>();
for (final ViewRow row : allKeys) {
final RawJsonDocument document = row.document(RawJsonDocument.class);
if (document != null) {
final String json = document.content();
logger.debug("Found service: {}", json);
final StringReader stringReader = new StringReader(json);
services.add(registeredServiceJsonSerializer.fromJson(stringReader));
}
}
return services;
} catch (final RuntimeException e) {
logger.error(e.getMessage(), e);
return new LinkedList<>();
}
}
开发者ID:hsj-xiaokang，项目名称:springboot-shiro-cas-mybatis，代码行数:26，代码来源:CouchbaseServiceRegistryDao.java
示例3: save
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public RegisteredService save(final RegisteredService service) {
LOGGER.debug("Saving service [{}]", service);
if (service.getId() == AbstractRegisteredService.INITIAL_IDENTIFIER_VALUE) {
((AbstractRegisteredService) service).setId(service.hashCode());
}
final StringWriter stringWriter = new StringWriter();
this.registeredServiceJsonSerializer.to(stringWriter, service);
this.couchbase.bucket().upsert(
RawJsonDocument.create(
String.valueOf(service.getId()),
0, stringWriter.toString()));
return service;
}
开发者ID:mrluo735，项目名称:cas-5.1.0，代码行数:18，代码来源:CouchbaseServiceRegistryDao.java
示例4: load
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public List<RegisteredService> load() {
try {
LOGGER.debug("Loading services");
final ViewResult allKeys = executeViewQueryForAllServices();
final List<RegisteredService> services = new LinkedList<>();
for (final ViewRow row : allKeys) {
final RawJsonDocument document = row.document(RawJsonDocument.class);
if (document != null) {
final String json = document.content();
LOGGER.debug("Found service: [{}]", json);
final StringReader stringReader = new StringReader(json);
final RegisteredService service = this.registeredServiceJsonSerializer.from(stringReader);
services.add(service);
publishEvent(new CasRegisteredServiceLoadedEvent(this, service));
}
}
return services;
} catch (final RuntimeException e) {
LOGGER.error(e.getMessage(), e);
return new LinkedList<>();
}
}
开发者ID:mrluo735，项目名称:cas-5.1.0，代码行数:26，代码来源:CouchbaseServiceRegistryDao.java
示例5: save
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
public void save(List<Event> events) {
for(Event e: events) {
String es = null;
try {
es = mapper.writeValueAsString(e);
} catch (JsonProcessingException ex) {
ex.printStackTrace();
}
RawJsonDocument jsonDoc = RawJsonDocument.create(e.getEventId(), es);
db.getBucket().insert(jsonDoc);
}
}
开发者ID:ERS-HCL，项目名称:cart-cqrs-demo，代码行数:17，代码来源:EventStore.java
示例6: checkAndSave
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public E checkAndSave(String id, E entity) {
logger.trace("Check and save entity '{}' with id '{}'", entity, id);
try {
String content = getJsonMapper().writeValueAsString(entity);
RawJsonDocument insertedDocument;
insertedDocument = runAsync(bucket -> {
if (entity.getCas() != null) {
return bucket.replace(RawJsonDocument.create(id, content, entity.getCas()));
}
return bucket.insert(RawJsonDocument.create(id, content));
});
entity.setCas(insertedDocument.cas());
return entity;
} catch (JsonProcessingException e) {
throw new CouchmoveException("Unable to save document with id " + id, e);
}
}
开发者ID:differentway，项目名称:couchmove，代码行数:19，代码来源:CouchbaseRepositoryImpl.java
示例7: testJsonDocumentWrite
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
/**
* Test that a single Json document can be written successfully
* @throws IOException
* @throws DataConversionException
* @throws ExecutionException
* @throws InterruptedException
*/
@Test(groups={"timeout"})
public void testJsonDocumentWrite()
throws IOException, DataConversionException, ExecutionException, InterruptedException {
CouchbaseWriter writer = new CouchbaseWriter(_couchbaseEnvironment, ConfigFactory.empty());
try {
String key = "hello";
String testContent = "hello world";
HashMap<String, String> contentMap = new HashMap<>();
contentMap.put("value", testContent);
Gson gson = new Gson();
String jsonString = gson.toJson(contentMap);
RawJsonDocument jsonDocument = RawJsonDocument.create(key, jsonString);
writer.write(jsonDocument, null).get();
RawJsonDocument returnDoc = writer.getBucket().get(key, RawJsonDocument.class);
Map<String, String> returnedMap = gson.fromJson(returnDoc.content(), Map.class);
Assert.assertEquals(testContent, returnedMap.get("value"));
} finally {
writer.close();
}
}
开发者ID:apache，项目名称:incubator-gobblin，代码行数:30，代码来源:CouchbaseWriterTest.java
示例8: findServiceById
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public RegisteredService findServiceById(final long id) {
try {
logger.debug("Lookup for service {}", id);
final RawJsonDocument document = couchbase.bucket().get(String.valueOf(id), RawJsonDocument.class);
if (document != null) {
final String json = document.content();
final StringReader stringReader = new StringReader(json);
return registeredServiceJsonSerializer.fromJson(stringReader);
}
} catch (final Exception e) {
logger.error(e.getMessage(), e);
}
return null;
}
开发者ID:hsj-xiaokang，项目名称:springboot-shiro-cas-mybatis，代码行数:16，代码来源:CouchbaseServiceRegistryDao.java
示例9: findServiceById
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public RegisteredService findServiceById(final long id) {
try {
LOGGER.debug("Lookup for service [{}]", id);
final RawJsonDocument document = this.couchbase.bucket().get(String.valueOf(id), RawJsonDocument.class);
if (document != null) {
final String json = document.content();
final StringReader stringReader = new StringReader(json);
return this.registeredServiceJsonSerializer.from(stringReader);
}
} catch (final Exception e) {
LOGGER.error(e.getMessage(), e);
}
return null;
}
开发者ID:mrluo735，项目名称:cas-5.1.0，代码行数:16，代码来源:CouchbaseServiceRegistryDao.java
示例10: save
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
public void save(Cart cart) {
String json = null;
try {
json = mapper.writeValueAsString(cart);
} catch (JsonProcessingException ex) {
ex.printStackTrace();
}
RawJsonDocument jsonDoc = RawJsonDocument.create(cart.getId(), json);
db.getBucket().upsert(jsonDoc);
}
开发者ID:ERS-HCL，项目名称:cart-cqrs-demo，代码行数:12，代码来源:CartStore.java
示例11: save
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public E save(String id, E entity) {
logger.trace("Save entity '{}' with id '{}'", entity, id);
try {
String json = getJsonMapper().writeValueAsString(entity);
RawJsonDocument insertedDocument = runAsync(bucket -> bucket.upsert(RawJsonDocument.create(id, json)));
entity.setCas(insertedDocument.cas());
return entity;
} catch (JsonProcessingException e) {
throw new CouchmoveException("Unable to save document with id " + id, e);
}
}
开发者ID:differentway，项目名称:couchmove，代码行数:13，代码来源:CouchbaseRepositoryImpl.java
示例12: findOne
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public E findOne(String id) {
logger.trace("Find entity with id '{}'", id);
RawJsonDocument document = runAsync(bucket -> bucket.get(id, RawJsonDocument.class));
if (document == null) {
return null;
}
try {
E entity = getJsonMapper().readValue(document.content(), entityClass);
entity.setCas(document.cas());
return entity;
} catch (IOException e) {
throw new CouchmoveException("Unable to read document with id " + id, e);
}
}
开发者ID:differentway，项目名称:couchmove，代码行数:16，代码来源:CouchbaseRepositoryImpl.java
示例13: findAll
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public Observable<T> findAll(final Iterable<String> ids) {
return Observable.from(ids)
.flatMap(id -> bucket.get(id, RawJsonDocument.class))
.map(deserializer)
.timeout(timeout, unit);
}
开发者ID:jloisel，项目名称:reactive-couchbase，代码行数:8，代码来源:CBAsyncRepository.java
示例14: queryView
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public Observable<T> queryView(final ViewQuery query) {
return Observable.just(query)
.flatMap(bucket::query)
.flatMap(AsyncViewResult::rows)
.flatMap(row -> row.document(RawJsonDocument.class))
.map(deserializer)
.timeout(timeout, unit);
}
开发者ID:jloisel，项目名称:reactive-couchbase，代码行数:10，代码来源:CBAsyncRepository.java
示例15: delete
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public Observable<String> delete(final T entity) {
return Observable.just(entity)
.map(serializer)
.flatMap(bucket::remove)
.map(RawJsonDocument::id)
.timeout(timeout, unit);
}
开发者ID:jloisel，项目名称:reactive-couchbase，代码行数:9，代码来源:CBAsyncRepository.java
示例16: call
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public T call(final RawJsonDocument document) {
try {
final String wrapped = join(START_OBJECT, document.content(), END_OBJECT);
final BeanWrapper<T> bean = mapper.reader(reference).readValue(wrapped);
return bean.getEntity();
} catch (final IOException e) {
throw new JacksonConversionException("Error while deserializing document id=" + document.id(), e);
}
}
开发者ID:jloisel，项目名称:reactive-couchbase，代码行数:11，代码来源:JacksonDeserializer.java
示例17: call
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public RawJsonDocument call(final T bean) {
try {
final ObjectWriter writer = mapper.writerFor(reference);
final String json = writer.writeValueAsString(new BeanWrapper<T>(bean));
final String unwrapped =
json.substring(START_OBJECT.length(), json.length() - END_OBJECT.length());
return RawJsonDocument.create(bean.getId(), unwrapped);
} catch (final IOException e) {
throw new JacksonConversionException("Error while serializing bean=" + bean, e);
}
}
开发者ID:jloisel，项目名称:reactive-couchbase，代码行数:13，代码来源:JacksonSerializer.java
示例18: shouldSerialize
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Test
public void shouldSerialize() throws IOException {
final RawJsonDocument serialized = serializer.call(entity);
assertEquals(RawJsonDocument.class, serialized.getClass());
verify(mapper).writerFor(reference);
verify(writer).writeValueAsString(any());
}
开发者ID:jloisel，项目名称:reactive-couchbase，代码行数:8，代码来源:JacksonSerializerTest.java
示例19: startImport
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
@Override
public Observable<Document> startImport() {
MongoClient client = MongoClients.create(connectionString);
MongoDatabase db = client.getDatabase(dbName);
return db.getCollection(collectionName).find().toObservable()
.map(new Func1<org.bson.Document, Document>() {
public Document call(org.bson.Document mongoDoc) {
mongoDoc.put(typeField, type);
RawJsonDocument d = RawJsonDocument.create(mongoDoc
.getObjectId("_id").toHexString(), mongoDoc
.toJson());
return d;
};
});
}
开发者ID:ldoguin，项目名称:couchbase-java-importer，代码行数:16，代码来源:MongoDBConfig.java
示例20: createNode
import com.couchbase.client.java.document.RawJsonDocument; //导入依赖的package包/类
public Observable<Document> createNode(String[] line) {
ObjectNode node = objectMapper.createObjectNode();
for (int i = 0; i < getTotalColumn(); i++) {
String columnType = getColumType().get(i);
RowType.valueOf(columnType).addField(node, columName.get(i),
line[i], getSimpleDateFormat());
}
String kc = getKeyColum();
String key = getKeyPrefix() + node.get(kc).asText();
RawJsonDocument rjd = RawJsonDocument.create(key, node.toString());
return Observable.just(rjd);
}
开发者ID:ldoguin，项目名称:couchbase-java-importer，代码行数:13，代码来源:CSVConfig.java
注：本文中的com.couchbase.client.java.document.RawJsonDocument类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论