需要的jar
mongo-java-driver
maven仓库里面,mongodb3.0的连接驱动
org.mongodb
mongo-java-driver
3.0.0
2.连接过程代码
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
/**
* 2016年8月5日下午3:19:44
*
* @author 3306 TODO 测试Mongo数据库连接
*
*/
public class TestMongo {
private static MongoClient mongoClient;
private static String host = "192.168.0.149";// mongo数据库服务器地址,本地为127.0.0.1
private static int port = 20000;// mongo默认为27017端口
/**
* 获取数据库集合
*
* @param databaseName
* 数据库名称
* @param collectionName
* 集合名称
* @return MongoCollection
*/
public static MongoCollectiongetMongoCollection(String databaseName, String collectionName) {
return getMongoDatabase(databaseName).getCollection(collectionName);
}
/**
* 获取mongo数据库
*
* @param databaseName
* 数据库名称
* @return MongoDatabase
*/
public static MongoDatabase getMongoDatabase(String databaseName) {
mongoClient = new MongoClient(host, port);
return mongoClient.getDatabase(databaseName);
}
/**
* 测试数据连接
*
* @param args
*/
public static void main(String[] args) {
String databaseName = "mojing";// 数据库
String collectionName = "user";// 集合名称
MongoCollectionuserCollection = getMongoCollection(databaseName, collectionName);
System.out.println(userCollection.count());
}
}
1、需要的jar
mongo-java-driver
2.连接过程代码
需要的jar
mongo-java-driver
maven仓库里面,mongodb3.0的连接驱动
2.连接过程代码
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
/**
* 2016年8月5日下午3:19:44
*
* @author 3306 TODO 测试Mongo数据库连接
*
*/
public class TestMongo {
private static MongoClient mongoClient;
private static String host = "192.168.0.149";// mongo数据库服务器地址,本地为127.0.0.1
private static int port = 20000;// mongo默认为27017端口
/**
* 获取数据库集合
*
* @param databaseName
* 数据库名称
* @param collectionName
* 集合名称
* @return MongoCollection
*/
public static MongoCollection
return getMongoDatabase(databaseName).getCollection(collectionName);
}
/**
* 获取mongo数据库
*
* @param databaseName
* 数据库名称
* @return MongoDatabase
*/
public static MongoDatabase getMongoDatabase(String databaseName) {
mongoClient = new MongoClient(host, port);
return mongoClient.getDatabase(databaseName);
}
/**
* 测试数据连接
*
* @param args
*/
public static void main(String[] args) {
String databaseName = "mojing";// 数据库
String collectionName = "user";// 集合名称
MongoCollection
System.out.println(userCollection.count());
}
}
mongodb.jar
mongo-java-driver-3.2.2.jar