io.vertx.ext.mongo.MongoClient.findOne()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(7.5k)|赞(0)|评价(0)|浏览(130)

本文整理了Java中io.vertx.ext.mongo.MongoClient.findOne()方法的一些代码示例，展示了MongoClient.findOne()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。MongoClient.findOne()方法的具体详情如下：
包路径：io.vertx.ext.mongo.MongoClient
类名称：MongoClient
方法名：findOne

MongoClient.findOne介绍

暂无

代码示例

代码示例来源：origin: vert-x3/vertx-examples

mongo.findOne("users", new JsonObject().put("_id", ctx.request().getParam("id")), null, lookup -> {
JsonObject newUser = ctx.getBodyAsJson();
mongo.findOne("users", new JsonObject().put("username", newUser.getString("username")), null, lookup -> {
mongo.findOne("users", new JsonObject().put("_id", ctx.request().getParam("id")), null, lookup -> {
mongo.findOne("users", new JsonObject().put("_id", ctx.request().getParam("id")), null, lookup -> {

代码示例来源：origin: silentbalanceyh/vertx-zero

static Future<JsonObject> findOneAndReplace(final String collection, final JsonObject filter,
                      final JsonObject updated) {
  // Find first for field update
  return Ux.thenGeneric(future -> CLIENT.findOne(collection, filter, null, handler -> {
    if (handler.succeeded()) {
      final JsonObject data = handler.result().mergeIn(updated);
      CLIENT.findOneAndReplace(collection, filter, data, result -> {
        LOGGER.debug(Info.MONGO_UPDATE, collection, filter, data);
        future.complete(data);
      });
    } else {
      future.complete(updated);
    }
  }));
}

代码示例来源：origin: io.vertx/vertx-mongo-service

@Override
public MongoService findOne(String collection, JsonObject query, JsonObject fields,
  Handler<AsyncResult<JsonObject>> resultHandler) {
 client.findOne(collection, query, fields, resultHandler);
 return this;
}

代码示例来源：origin: cn.vertxup/vertx-up

static Future<JsonObject> findOneAndReplace(final String collection, final JsonObject filter,
                      final JsonObject updated) {
  // Find first for field update
  return Ux.thenGeneric(future -> CLIENT.findOne(collection, filter, null, handler -> {
    if (handler.succeeded()) {
      final JsonObject data = handler.result().mergeIn(updated);
      CLIENT.findOneAndReplace(collection, filter, data, result -> {
        LOGGER.debug(Info.MONGO_UPDATE, collection, filter, data);
        future.complete(data);
      });
    } else {
      future.complete(updated);
    }
  }));
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Find a single matching document in the specified collection
 * <p>
 * This operation might change <i>_id</i> field of <i>query</i> parameter
 * @param collection the collection
 * @param query the query used to match the document
 * @param fields the fields
 * @param resultHandler will be provided with the document, if any
 * @return 
 */
public io.vertx.rxjava.ext.mongo.MongoClient findOne(String collection, JsonObject query, JsonObject fields, Handler<AsyncResult<JsonObject>> resultHandler) { 
 delegate.findOne(collection, query, fields, resultHandler);
 return this;
}

代码示例来源：origin: vert-x3/vertx-rx

/**
 * Find a single matching document in the specified collection
 * <p>
 * This operation might change <i>_id</i> field of <i>query</i> parameter
 * @param collection the collection
 * @param query the query used to match the document
 * @param fields the fields
 * @param resultHandler will be provided with the document, if any
 * @return 
 */
public io.vertx.rxjava.ext.mongo.MongoClient findOne(String collection, JsonObject query, JsonObject fields, Handler<AsyncResult<JsonObject>> resultHandler) { 
 delegate.findOne(collection, query, fields, resultHandler);
 return this;
}

代码示例来源：origin: sczyh30/vertx-blueprint-microservice

@Override
public void retrieveStore(String sellerId, Handler<AsyncResult<Store>> resultHandler) {
 JsonObject query = new JsonObject().put("_id", sellerId);
 client.findOne(COLLECTION, query, null, ar -> {
  if (ar.succeeded()) {
   if (ar.result() == null) {
    resultHandler.handle(Future.succeededFuture());
   } else {
    Store store = new Store(ar.result().put("sellerId", ar.result().getString("_id")));
    resultHandler.handle(Future.succeededFuture(store));
   }
  } else {
   resultHandler.handle(Future.failedFuture(ar.cause()));
  }
 });
}

代码示例来源：origin: cn.vertxup/vertx-up

static Future<Boolean> existing(final String collection, final JsonObject filter) {
  return Ux.thenGeneric(future -> CLIENT.findOne(collection, filter, null, res -> {
    LOGGER.debug(Info.MONGO_FILTER, collection, filter, res.result());
    future.complete(null != res.result());
  }));
}

代码示例来源：origin: cn.vertxup/vertx-up

static Future<JsonObject> findOne(final String collection, final JsonObject filter) {
  return Ux.thenGeneric(future -> CLIENT.findOne(collection, filter, null, res -> {
    LOGGER.debug(Info.MONGO_FILTER, collection, filter, res.result());
    future.complete(res.result());
  }));
}

代码示例来源：origin: silentbalanceyh/vertx-zero

static Future<Boolean> existing(final String collection, final JsonObject filter) {
  return Ux.thenGeneric(future -> CLIENT.findOne(collection, filter, null, res -> {
    LOGGER.debug(Info.MONGO_FILTER, collection, filter, res.result());
    future.complete(null != res.result());
  }));
}

代码示例来源：origin: silentbalanceyh/vertx-zero

static Future<JsonObject> findOne(final String collection, final JsonObject filter) {
  return Ux.thenGeneric(future -> CLIENT.findOne(collection, filter, null, res -> {
    LOGGER.debug(Info.MONGO_FILTER, collection, filter, res.result());
    future.complete(res.result());
  }));
}

代码示例来源：origin: silentbalanceyh/vertx-zero

static Future<Boolean> missing(final String collection, final JsonObject filter) {
  return Ux.thenGeneric(future -> CLIENT.findOne(collection, filter, null, res -> {
    LOGGER.debug(Info.MONGO_FILTER, collection, filter, res.result());
    future.complete(null == res.result());
  }));
}

代码示例来源：origin: cn.vertxup/vertx-up

static Future<Boolean> missing(final String collection, final JsonObject filter) {
  return Ux.thenGeneric(future -> CLIENT.findOne(collection, filter, null, res -> {
    LOGGER.debug(Info.MONGO_FILTER, collection, filter, res.result());
    future.complete(null == res.result());
  }));
}

代码示例来源：origin: io.vertx/vertx-lang-groovy

public static io.vertx.ext.mongo.MongoClient findOne(io.vertx.ext.mongo.MongoClient j_receiver, java.lang.String collection, java.util.Map<String, Object> query, java.util.Map<String, Object> fields, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<String, Object>>> resultHandler) {
 io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.findOne(collection,
  query != null ? io.vertx.core.impl.ConversionHelper.toJsonObject(query) : null,
  fields != null ? io.vertx.core.impl.ConversionHelper.toJsonObject(fields) : null,
  resultHandler != null ? new io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonObject>>() {
  public void handle(io.vertx.core.AsyncResult<io.vertx.core.json.JsonObject> ar) {
   resultHandler.handle(ar.map(event -> io.vertx.core.impl.ConversionHelper.fromJsonObject(event)));
  }
 } : null));
 return j_receiver;
}
public static io.vertx.ext.mongo.MongoClient findOneAndUpdate(io.vertx.ext.mongo.MongoClient j_receiver, java.lang.String collection, java.util.Map<String, Object> query, java.util.Map<String, Object> update, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<String, Object>>> resultHandler) {

代码示例来源：origin: cescoffier/my-vertx-first-app

private void getOne(RoutingContext routingContext) {
 final String id = routingContext.request().getParam("id");
 if (id == null) {
  routingContext.response().setStatusCode(400).end();
 } else {
  mongo.findOne(COLLECTION, new JsonObject().put("_id", id), null, ar -> {
   if (ar.succeeded()) {
    if (ar.result() == null) {
     routingContext.response().setStatusCode(404).end();
     return;
    }
    Whisky whisky = new Whisky(ar.result());
    routingContext.response()
      .setStatusCode(200)
      .putHeader("content-type", "application/json; charset=utf-8")
      .end(Json.encodePrettily(whisky));
   } else {
    routingContext.response().setStatusCode(404).end();
   }
  });
 }
}

内容来源于网络，如有侵权，请联系作者删除！

MongoClient

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    MongoClient类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com