linux安装MongoDB(https://blog.csdn.net/eyeofeagle/article/details/96428363 ), 使用java api测试数据库语法
1,maven依赖
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
<version>3.6.1</version>
</dependency>
2,MongoDB的Java API
import com.mongodb.*;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.Set;
public class MongodbCRUD_insert {
public static void main(String[] args) {
// insertMany();
insertOne();
}
public static void insertOne() {
String user = "test"; //用户名
String database = "test"; //数据库
char[] password = "123456".toCharArray(); //密码
MongoCredential credential = MongoCredential.createCredential(user,database,password); //验证对象
MongoClientOptions options = MongoClientOptions.builder().sslEnabled(false).build(); //连接操作对象
MongoClient mongoClient = new MongoClient(new ServerAddress("218.245.1.135",27017),credential,options); //连接对象
//插入1条
MongoDatabase db = mongoClient.getDatabase("test");
MongoCollection<Document> t1 = db.getCollection("t1");
Document doc = new Document("id", Double.valueOf(10)).append("name", "lisi10").append("age", Double.valueOf(30));
t1.insertOne(doc);
//查询结果
t1.find().forEach((Block<Document>) document -> {
System.out.println( document.getString("name") );
});
}
public static void insertMany() {
String user = "test"; //用户名
String database = "test"; //数据库
char[] password = "123456".toCharArray(); //密码
MongoCredential credential = MongoCredential.createCredential(user,database,password); //验证对象
MongoClientOptions options = MongoClientOptions.builder().sslEnabled(false).build(); //连接操作对象
MongoClient mongoClient = new MongoClient(new ServerAddress("218.245.1.135",27017),credential,options); //连接对象
//插入1条
MongoDatabase db = mongoClient.getDatabase("test");
MongoCollection<Document> t1 = db.getCollection("t1");
Document doc = new Document("id", Double.valueOf(11)).append("name", "lisi11").append("age", Double.valueOf(20));
Document doc2 = new Document("id", Double.valueOf(12)).append("name", "lisi12").append("age", Double.valueOf(30));
ArrayList<Document> list = new ArrayList<Document>();
list.add(doc);
list.add(doc2);
t1.insertMany(list);
}
public static void truncate() {
String user = "test"; //用户名
String database = "test"; //数据库
char[] password = "123456".toCharArray(); //密码
MongoCredential credential = MongoCredential.createCredential(user,database,password); //验证对象
MongoClientOptions options = MongoClientOptions.builder().sslEnabled(false).build(); //连接操作对象
MongoClient mongoClient = new MongoClient(new ServerAddress("218.245.1.135",27017),credential,options); //连接对象
//插入1条
MongoDatabase db = mongoClient.getDatabase("test");
MongoCollection<Document> t1 = db.getCollection("t1");
Document doc = new Document("id", Double.valueOf(11)).append("name", "lisi11").append("age", Double.valueOf(20));
Document doc2 = new Document("id", Double.valueOf(12)).append("name", "lisi12").append("age", Double.valueOf(30));
ArrayList<Document> list = new ArrayList<Document>();
list.add(doc);
list.add(doc2);
t1.insertMany(list);
}
}