1.首先 你的清楚你的MongoDB的版本是多少 就下载对应的架包
下载地址如下:
http://mongodb.github.io/mongo-java-driver/
2.新建一个项目 把架包扔进去,并Build path到你的项目下【如果用于测试,请如下 多用一个架包】
3.新建一个MongoConnection类 用来获取MongoDB的连接对象:
1 package com.mongo.util; 2 3 import java.util.ArrayList; 4 import java.util.List; 5 6 import com.mongodb.MongoClient; 7 import com.mongodb.MongoCredential; 8 import com.mongodb.ServerAddress; 9 import com.mongodb.client.MongoDatabase; 10 11 public class MongoConnection { 12 13 /** 14 * 需要验证用户名 密码的 MongoDB的连接方式 com.mongodb.MongoClient.getDatabase("数据库名") 15 * @return 16 */ 17 public MongoDatabase getConnection() { 18 try { 19 //连接到MongoDB服务 如果是远程连接可以替换“localhost”为服务器所在IP地址 20 //ServerAddress()两个参数分别为 服务器地址 和 端口 21 ServerAddress serverAddress = new ServerAddress("localhost",27017); 22 List<ServerAddress> addrs = new ArrayList<ServerAddress>(); 23 addrs.add(serverAddress); 24 25 //MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码 26 MongoCredential credential = MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray()); 27 List<MongoCredential> credentials = new ArrayList<MongoCredential>(); 28 credentials.add(credential); 29 30 //通过连接认证获取MongoDB连接 31 MongoClient mongoClient = new MongoClient(addrs,credentials); 32 33 //连接到数据库 34 MongoDatabase mongoDatabase = mongoClient.getDatabase("databaseName"); 35 System.out.println("连接成功"); 36 return mongoDatabase; 37 } catch (Exception e) { 38 System.err.println( e.getClass().getName() + ": " + e.getMessage() ); 39 } 40 return null; 41 } 42 43 /** 44 * 不需要验证 用户名+密码 的获取连接的方式 com.mongodb.MongoClient.getDatabase("数据库名") 45 * @return 46 */ 47 public MongoDatabase getConnectionBasis(){ 48 try { 49 //连接到mongodb服务 50 MongoClient mongoClient = new MongoClient("localhost",27017); 51 MongoDatabase mongoDatabase = mongoClient.getDatabase("databaseName"); 52 System.out.println("连接成功"); 53 return mongoDatabase; 54 } catch (Exception e) { 55 System.out.println(e.getClass().getName()+":"+e.getMessage()); 56 } 57 return null; 58 } 59 60 }