以下是一个简单的Java代码示例,演示如何连接到MongoDB数据库:
首先,你需要添加MongoDB Java驱动到你的项目中。如果你使用Maven,你可以在pom.xml
文件中添加以下依赖:
<dependencies>
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongodb-driver-sync</artifactId>
<version>4.2.3</version> <!-- 请检查是否有更新的版本 -->
</dependency>
</dependencies>
然后,你可以使用以下代码连接到MongoDB数据库:
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import java.util.Arrays;
public class MongoConnectExample {
public static void main(String[] args) {
// MongoDB连接信息
String host = "localhost"; // MongoDB服务器地址
int port = 27017; // MongoDB服务器端口
String databaseName = "mydb"; // 要连接的数据库名称
String username = "myusername"; // MongoDB用户名(如果需要认证)
String password = "mypassword"; // MongoDB密码(如果需要认证)
// 创建MongoDB连接凭证(如果需要认证)
MongoCredential credential = MongoCredential.createCredential(username, databaseName, password.toCharArray());
// 创建MongoDB服务器地址
ServerAddress serverAddress = new ServerAddress(host, port);
// 创建MongoDB客户端
MongoClient mongoClient = new MongoClient(serverAddress, Arrays.asList(credential));
// 获取数据库对象
MongoDatabase database = mongoClient.getDatabase(databaseName);
// 连接到数据库并输出一个消息
System.out.println("Connected to database: " + databaseName);
// 创建一个文档并插入到数据库中
Document document = new Document("name", "MongoDB")
.append("type", "database")
.append("count", 1)
.append("versions", Arrays.asList("v3.2", "v3.0", "v2.6"))
.append("info", new Document("x", 203).append("y", 102));
database.getCollection("test").insertOne(document);
// 关闭MongoDB客户端连接
mongoClient.close();
}
}
这个示例代码连接到名为"mydb"的数据库,并在"test"集合中插入一个文档。你需要根据你的MongoDB服务器设置来修改连接信息(主机名、端口、数据库名称、用户名和密码)。
注意:在实际项目中,你可能需要处理各种异常,例如连接失败、认证失败等。此示例代码为了简洁明了,省略了异常处理部分。