</dependency>
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<Document> */ public static MongoCollection<Document> getMongoCollection(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" ; // 集合名称 MongoCollection<Document> userCollection = getMongoCollection(databaseName, collectionName); System.out.println(userCollection.count()); } }