本文整理了Java中org.springframework.data.mongodb.core.query.Update.set()
方法的一些代码示例,展示了Update.set()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Update.set()
方法的具体详情如下:
包路径:org.springframework.data.mongodb.core.query.Update
类名称:Update
方法名:set
[英]Update using the $set update modifier
[中]使用$set Update修饰符更新
代码示例来源:origin: spring-projects/spring-data-mongodb
/**
* Static factory method to create an Update using the provided key
*
* @param key
* @return
*/
public static Update update(String key, Object value) {
return new Update().set(key, value);
}
代码示例来源:origin: yu199195/myth
@Override
public void updateFailTransaction(final MythTransaction mythTransaction) throws MythRuntimeException {
Query query = new Query();
query.addCriteria(new Criteria("transId").is(mythTransaction.getTransId()));
Update update = new Update();
update.set("status", mythTransaction.getStatus());
update.set("errorMsg", mythTransaction.getErrorMsg());
update.set("lastTime", new Date());
update.set("retriedCount", mythTransaction.getRetriedCount());
final WriteResult writeResult = template.updateFirst(query, update, MongoAdapter.class, collectionName);
if (writeResult.getN() <= 0) {
throw new MythRuntimeException(ERROR);
}
}
代码示例来源:origin: yu199195/myth
@Override
public Boolean updateRetry(final String id, final Integer retry, final String appName) {
if (StringUtils.isBlank(id) || StringUtils.isBlank(appName) || Objects.isNull(retry)) {
return Boolean.FALSE;
}
final String mongoTableName = RepositoryPathUtils.buildMongoTableName(appName);
Query query = new Query();
query.addCriteria(new Criteria("transId").is(id));
Update update = new Update();
update.set("lastTime", DateUtils.getCurrentDateTime());
update.set("retriedCount", retry);
final WriteResult writeResult = mongoTemplate.updateFirst(query, update,
MongoAdapter.class, mongoTableName);
if (writeResult.getN() <= 0) {
throw new RuntimeException("更新数据异常!");
}
return Boolean.TRUE;
}
代码示例来源:origin: roncoo/spring-boot-demo
public void updateById(RoncooUser roncooUser) {
Criteria criteria = Criteria.where("id").in(roncooUser.getId());
Query query = new Query(criteria);
Update update = new Update();
update.set("name", roncooUser.getName());
update.set("createTime", roncooUser.getCreateTime());
mongoTemplate.updateMulti(query, update, RoncooUser.class);
}
代码示例来源:origin: roncoo/spring-boot-demo
public void updateById(RoncooUser roncooUser) {
Criteria criteria = Criteria.where("id").in(roncooUser.getId());
Query query = new Query(criteria);
Update update = new Update();
update.set("name", roncooUser.getName());
update.set("createTime", roncooUser.getCreateTime());
mongoTemplate.updateMulti(query, update, RoncooUser.class);
}
代码示例来源:origin: yu199195/hmily
@Override
public Boolean updateRetry(final String id, final Integer retry, final String appName) {
if (StringUtils.isBlank(id) || StringUtils.isBlank(appName) || Objects.isNull(retry)) {
return Boolean.FALSE;
}
final String mongoTableName = RepositoryPathUtils.buildMongoTableName(appName);
Query query = new Query();
query.addCriteria(new Criteria("transId").is(id));
Update update = new Update();
update.set("lastTime", DateUtils.getCurrentDateTime());
update.set("retriedCount", retry);
final UpdateResult updateResult = mongoTemplate.updateFirst(query, update,
MongoAdapter.class, mongoTableName);
if (updateResult.getModifiedCount() <= 0) {
throw new HmilyRuntimeException("更新数据异常!");
}
return Boolean.TRUE;
}
代码示例来源:origin: ityouknow/spring-boot-examples
/**
* 更新对象
* @param user
*/
@Override
public int updateUser(UserEntity user) {
Query query=new Query(Criteria.where("id").is(user.getId()));
Update update= new Update().set("userName", user.getUserName()).set("passWord", user.getPassWord());
//更新查询返回结果集的第一条
WriteResult result =mongoTemplate.updateFirst(query,update,UserEntity.class);
//更新查询返回结果集的所有
// mongoTemplate.updateMulti(query,update,UserEntity.class);
if(result!=null)
return result.getN();
else
return 0;
}
代码示例来源:origin: roncoo/spring-boot-demo
public void updateById(RoncooUser roncooUser) {
Criteria criteria = Criteria.where("id").in(roncooUser.getId());
Query query = new Query(criteria);
Update update = new Update();
update.set("name", roncooUser.getName());
update.set("createTime", roncooUser.getCreateTime());
mongoTemplate.updateMulti(query, update, RoncooUser.class);
}
代码示例来源:origin: roncoo/spring-boot-demo
public void updateById(RoncooUser roncooUser) {
Criteria criteria = Criteria.where("id").in(roncooUser.getId());
Query query = new Query(criteria);
Update update = new Update();
update.set("name", roncooUser.getName());
update.set("createTime", roncooUser.getCreateTime());
mongoTemplate.updateMulti(query, update, RoncooUser.class);
}
代码示例来源:origin: roncoo/spring-boot-demo
public void updateById(RoncooUser roncooUser) {
Criteria criteria = Criteria.where("id").in(roncooUser.getId());
Query query = new Query(criteria);
Update update = new Update();
update.set("name", roncooUser.getName());
update.set("createTime", roncooUser.getCreateTime());
mongoTemplate.updateMulti(query, update, RoncooUser.class);
}
代码示例来源:origin: roncoo/spring-boot-demo
public void updateById(RoncooUser roncooUser) {
Criteria criteria = Criteria.where("id").in(roncooUser.getId());
Query query = new Query(criteria);
Update update = new Update();
update.set("name", roncooUser.getName());
update.set("createTime", roncooUser.getCreateTime());
mongoTemplate.updateMulti(query, update, RoncooUser.class);
}
代码示例来源:origin: roncoo/spring-boot-demo
public void updateById(RoncooUser roncooUser) {
Criteria criteria = Criteria.where("id").in(roncooUser.getId());
Query query = new Query(criteria);
Update update = new Update();
update.set("name", roncooUser.getName());
update.set("createTime", roncooUser.getCreateTime());
mongoTemplate.updateMulti(query, update, RoncooUser.class);
}
代码示例来源:origin: roncoo/spring-boot-demo
public void updateById(RoncooUser roncooUser) {
Criteria criteria = Criteria.where("id").in(roncooUser.getId());
Query query = new Query(criteria);
Update update = new Update();
update.set("name", roncooUser.getName());
update.set("createTime", roncooUser.getCreateTime());
mongoTemplate.updateMulti(query, update, RoncooUser.class);
}
代码示例来源:origin: roncoo/spring-boot-demo
public void updateById(RoncooUser roncooUser) {
Criteria criteria = Criteria.where("id").in(roncooUser.getId());
Query query = new Query(criteria);
Update update = new Update();
update.set("name", roncooUser.getName());
update.set("createTime", roncooUser.getCreateTime());
mongoTemplate.updateMulti(query, update, RoncooUser.class);
}
代码示例来源:origin: yu199195/Raincat
@Override
public int update(final TransactionRecover transactionRecover) throws TransactionRuntimeException {
Query query = new Query();
query.addCriteria(new Criteria("transId").is(transactionRecover.getId()));
Update update = new Update();
if (CompensationOperationTypeEnum.TASK_EXECUTE.getCode() == transactionRecover.getOperation()) {
update.set("completeFlag",CommonConstant.TX_TRANSACTION_COMPLETE_FLAG_OK);
} else if (CompensationOperationTypeEnum.COMPENSATION.getCode() == transactionRecover.getOperation()) {
update.set("lastTime", new Date());
update.set("retriedCount", transactionRecover.getRetriedCount() + 1);
update.set("version", transactionRecover.getVersion() + 1);
}
final WriteResult writeResult = template.updateFirst(query, update, MongoAdapter.class, collectionName);
if (writeResult.getN() <= 0) {
throw new TransactionRuntimeException(UPDATE_EX);
}
return ROWS;
}
代码示例来源:origin: kaaproject/kaa
@Override
public MongoEndpointProfile updateServerProfile(byte[] keyHash,
int version,
String serverProfile) {
LOG.debug("Update server endpoint profile for endpoint with key hash {}, "
+ "schema version is {}",
keyHash, version);
updateFirst(
query(where(EP_ENDPOINT_KEY_HASH).is(keyHash)),
update(
EP_SERVER_PROFILE_PROPERTY,
MongoDaoUtil.encodeReservedCharacteres((DBObject) JSON.parse(serverProfile)))
.set(EP_SERVER_PROFILE_VERSION_PROPERTY, version));
return findById(ByteBuffer.wrap(keyHash));
}
}
代码示例来源:origin: yu199195/hmily
@Override
public int updateStatus(final String id, final Integer status) {
Query query = new Query();
query.addCriteria(new Criteria("transId").is(id));
Update update = new Update();
update.set("status", status);
final UpdateResult updateResult = template.updateFirst(query, update, MongoAdapter.class, collectionName);
if (updateResult.getModifiedCount() <= 0) {
throw new HmilyRuntimeException("update data exception!");
}
return ROWS;
}
代码示例来源:origin: yu199195/myth
@Override
public int updateStatus(final String id, final Integer status) throws MythRuntimeException {
Query query = new Query();
query.addCriteria(new Criteria("transId").is(id));
Update update = new Update();
update.set("status", status);
final WriteResult writeResult = template.updateFirst(query, update, MongoAdapter.class, collectionName);
if (writeResult.getN() <= 0) {
throw new MythRuntimeException(ERROR);
}
return CommonConstant.SUCCESS;
}
代码示例来源:origin: yu199195/hmily
@Override
public int updateParticipant(final HmilyTransaction hmilyTransaction) {
Query query = new Query();
query.addCriteria(new Criteria("transId").is(hmilyTransaction.getTransId()));
Update update = new Update();
try {
update.set("contents", objectSerializer.serialize(hmilyTransaction.getHmilyParticipants()));
} catch (HmilyException e) {
e.printStackTrace();
}
final UpdateResult updateResult = template.updateFirst(query, update, MongoAdapter.class, collectionName);
if (updateResult.getModifiedCount() <= 0) {
throw new HmilyRuntimeException("update data exception!");
}
return ROWS;
}
代码示例来源:origin: yu199195/myth
@Override
public void updateParticipant(final MythTransaction mythTransaction) throws MythRuntimeException {
Query query = new Query();
query.addCriteria(new Criteria("transId").is(mythTransaction.getTransId()));
Update update = new Update();
try {
update.set("contents", objectSerializer.serialize(mythTransaction.getMythParticipants()));
} catch (MythException e) {
e.printStackTrace();
}
final WriteResult writeResult = template.updateFirst(query, update, MongoAdapter.class, collectionName);
if (writeResult.getN() <= 0) {
throw new MythRuntimeException(ERROR);
}
}
内容来源于网络,如有侵权,请联系作者删除!