当我写一个java程序连接到mongodb时,我找不到任何检查mongodb连接状态的java api,比如"isConnected“方法。我使用以下代码来设置连接:
Mongo mongo = new Mongo("localhost", 27017);
DB db = mongo.getDB("database");
DBCollection col = db.getCollection("collection");
但是如果它无法建立连接(例如mongodb服务没有运行),而我想重新连接到mongodb,直到连接可用,该怎么办?
w
我想知道,是否有一种方法可以检查mongoDB服务器是否正在使用mongoDB的java驱动程序运行?
根据本教程,我可以
Mongo m = new Mongo();
// or
Mongo m = new Mongo( "localhost" , 27017 );
// and
DB db = m.getDB( "mydb" );
但是如何检查我是否可以使用这些Mongo和DB呢?我在API中看不到isConnected()方法。
db.getConnector().isOpen()
返回true
我找到的唯一方法是调用db.getDatabaseName
我正在尝试编写一个自定义流分组,它将写入Mongodb。我现在正在运行一个本地集群。我有一个自定义流类和一个mongo对象。我在准备()和chooseTask()中写入mongodb。它写入mongodb,但监事无法启动。我在主管日志中看到了这个错误:
b.s.d.worker [ERROR] Error on initialization of server mk-worker
java.lang.NoClassDefFoundError: com/mongodb/MongoClient
at storm.starter.MongoMonitorObject.<init>(Mo
很抱歉打扰您关于Cshare驱动程序(Samus)的MongoDb问题,您能帮我看一下吗?
using (Mongo mongo = new Mongo(config.BuildConfiguration()))
{
mongo.Connect();
try
{
var db = mongo.GetDatabase("MyCollection");//Collection 's count > 500,000,000
访问和创建数据库的Nodejs mongoDb驱动程序代码
var mongo = require("mongodb");
var db = new mongo.Db("myapp", new mongo.Server("localhost", 27017));
var people = db.collection("people");
and查询
people.find()
有没有办法在nodeJs mongoDb驱动程序中访问mongoDb控制台,以便在那里测试我的查询
我解析文件并检索它们所包含的文件,然后尝试将它们存储在我的数据库中,但我有以下错误:
INFO: LoggerImplFactory set to org.mongodb.morphia.logging.jdk.JDKLoggerFactory
Exception in thread "main" java.lang.NoClassDefFoundError: com/mongodb/client/model/geojson/codecs/GeoJsonCodecProvider
这是我的主要:
finally {
Morphia m
我正在尝试从mongo DB迁移到AWS documentDB on rails。我更改了mongoid.yml的配置,使其指向记录的实例(在hosts下)
运行rake:db:mongoid:create_indexes时,我得到以下错误:
rake aborted!
Mongo::Error::NoServerAvailable: No server is available matching preference: #<Mongo::ServerSelector::Primary:0x139580660 tag_sets=[] max_staleness=nil> using
根据“时间”字段,将系统日志存储在mongodb中,并设置索引。现在mongodb中大约有190k个日志。当我试图使用Java中的DBCollection.find()方法获取所有日志时,它花费了将近10秒的时间来遍历集合中的所有文档。我想可能有什么东西我错过了,因为表现不佳?
下面是我使用的代码:
mongo = new Mongo();
DB db = mongo.getDB("Log");
DBCollection coll = db.getCollection("SystemLog");
int count = 0;
long findStart =
嗨,我在mongodb上尝试了一个连接到mongohq的程序,但是我得到了以下错误:
Exception in thread "main" java.lang.StringIndexOutOfBoundsException: String index out of range: -1
at java.lang.String.substring(String.java:1958)
at com.mongodb.MongoClientURI.<init>(MongoClientURI.java:186)
at com.mongodb.MongoC
我需要使用CollectionNames()方法来列出数据库的所有集合。
我必须在中创建一个mongoDB会话:
sess := ... // obtain session
db := sess.DB("") // Get db, use db name if not given in connection url
names, err := db.CollectionNames()
在哪里可以找到在MongoDB中获取会话的示例?
我一直在与下一种方式的DB连接:
cliente_local, err := mongo.NewClient(options.Client().
尝试从scala插入到mongodb数据库。下面的代码不会创建db或集合。也尝试使用默认的测试数据库。如何执行CRUD操作?
object Store {
def main(args: Array[String]) = {
def addMongo(): Unit = {
var mongo = new Mongo()
var db = mongo.getDB("mybd")
var coll = db.getCollection("somecollection")
我使用的是mongodb-java-driver,除此之外别无他法。我创建了与Mongo连接的单例EJB。
@Singleton
public class MongoConnection {
private DB db = null;
private MongoClient mongoClient = null;
@PostConstruct
public void init() {
try {
mongoClient = new MongoClient("localhost", 27017);
db = mongoClient.getDB("m
当我使用grid.put()将文件写入GridFS时,第一个文件将被覆盖。同一个文件名在数据库中只能存在一次,这是真的吗?还是我做错了什么?
我的代码如下所示:
var mongo = require('mongodb'),
Server = mongo.Server,
Db = mongo.Db,
Grid = mongo.Grid;
server = new Server('localhost', 27017, {auto_reconnect: true});
db = new Db('mydb', server);
d
我目前正在学习一个教程( ),他使用的是java db连接(conn)。
50 try {
51 //Fill the report with parameter, connection and the stream reader
52 JasperPrint jp = JasperFillManager.fillReport(is, null, conn);
在这里怎么连接mongo呢?因为在mongo上我有:
Mongo m = new Mongo( "localhost" , 27017 );
DB db
在MongoDB2.10.0java驱动程序中,下面的代码示例为我工作。
DB db = mongo.getDB("testdb");
DBCollection eventCollection = db.getCollection("event");
DBObject query = new QueryBuilder().start().and(new QueryBuilder().start().put("event_type").is("deploy").get()).get();
DBCursor cursor = even
我使用一个java程序来插入mongo,试图为一个字段创建一个唯一的索引。product_src是我的集合中的一个字段,我希望将它设置为避免重复插入的唯一索引。我正在尝试下面的代码,但显示语法错误,这是什么问题。
DB db;
try {
sample = new MongoClient("myIP",PORT);
db = sample.getDB("client_mahout");
t = db.getCollection("data_flipkart_in_avoid_duplicate_ch