MySQL实现分库分表代码实战(Mango中间件)
warning:
这篇文章距离上次修改已过190天,其中的内容可能已经有所变动。
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
// 连接MongoDB并进行数据插入
public class MongoDbInsertExample {
public static void main(String[] args) {
// MongoDB连接字符串
String connectionString = "mongodb://username:password@localhost:27017";
// 数据库名
String databaseName = "mydb";
// 集合名
String collectionName = "mycollection";
try {
// 连接到MongoDB
MongoDatabase mongoDatabase = MongoClients.create(connectionString).getDatabase(databaseName);
MongoCollection<Document> collection = mongoDatabase.getCollection(collectionName);
// 创建文档
Document doc = new Document("name", "John Doe")
.append("age", 30)
.append("address", new Document("street", "123 Fake St")
.append("city", "Faketown")
.append("zip", 12345));
// 插入文档
collection.insertOne(doc);
System.out.println("文档插入成功!");
} catch (Exception e) {
System.err.println("文档插入失败:" + e.getMessage());
}
}
}
这段代码展示了如何使用MongoDB的Java驱动程序连接到MongoDB实例,并向指定的数据库和集合中插入一个包含复杂结构的文档。这是分库分表实践中常用的一种数据访问方式。
评论已关闭