云数据库 MongoDB 版

Java 连接示例

Maven配置

<dependencies>
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
<version>3.0.4</version>
</dependency>
</dependencies>

Java代码:

import java.util.ArrayList;
import java.util.List;
import java.util.UUID;
import org.bson.BsonDocument;
import org.bson.BsonString;
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.MongoClientURI;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
public class Main {
public static ServerAddress seed1 = new ServerAddress("demotest-1.mongodb.tbc3.newtest.rdstest.aliyun-inc.com", 27017);
public static ServerAddress seed2 = new ServerAddress("demotest-2.mongodb.tbc3.newtest.rdstest.aliyun-inc.com", 27017);
public static String username = "demouser";
public static String password = "123456";
public static String ReplSetName = "mgset-1441984463";
public static String DEFAULT_DB = "admin";
public static String DEMO_DB = "test";
public static String DEMO_COLL = "testColl";
public static MongoClient createMongoDBClient() {
// 构建Seed列表
List<ServerAddress> seedList = new ArrayList<ServerAddress>();
seedList.add(seed1);
seedList.add(seed2);
// 构建鉴权信息
List<MongoCredential> credentials = new ArrayList<MongoCredential>();
credentials.add(MongoCredential.createScramSha1Credential(username,
DEFAULT_DB, password.toCharArray()));
// 构建操作选项，requiredReplicaSetName属性外的选项根据自己的实际需求配置，默认参数满足大多数场景
MongoClientOptions options = MongoClientOptions.builder()
.requiredReplicaSetName(ReplSetName).socketTimeout(2000)
.connectionsPerHost(1).build();
return new MongoClient(seedList, credentials, options);
}
public static MongoClient createMongoDBClientWithURI() {
//另一种通过URI初始化
//mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]
MongoClientURI connectionString = new MongoClientURI("mongodb://" + username + ":" + password + "@" +
seed1 + "," + seed2 + "/" +
DEFAULT_DB +
"?replicaSet=" + ReplSetName);
return new MongoClient(connectionString);
}
public static void main(String args[]) {
MongoClient client = createMongoDBClient();
//or
//MongoClient client = createMongoDBClientWithURI();
try {
// 取得Collecton句柄
MongoDatabase database = client.getDatabase(DEMO_DB);
MongoCollection<Document> collection = database.getCollection(DEMO_COLL);
// 插入数据
Document doc = new Document();
String demoname = "JAVA:" + UUID.randomUUID();
doc.append("DEMO", demoname);
doc.append("MESG", "Hello AliCoudDB For MongoDB");
collection.insertOne(doc);
System.out.println("insert document: " + doc);
// 读取数据
BsonDocument filter = new BsonDocument();
filter.append("DEMO", new BsonString(demoname));
MongoCursor<Document> cursor = collection.find(filter).iterator();
while (cursor.hasNext()) {
System.out.println("find document: " + cursor.next());
}
} finally {
//关闭Client，释放资源
client.close();
}
return ;
}
}