MongoDB之Java连接MongoDB

下面介绍在Java中配置MongoDB环境连接MongoDB进行操作

前置条件：

• Java环境

• MongoDB JDBC驱动

  • 下载mongo jar包

  • 导入依赖

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

使用Java连接MongoDB

public class MongoDBJDBC{
    
        /*配置属性*/
    private static final String MONGO_HOST = "localhost";
    private static final Integer MONGO_PORT = 27017;
    private static final String MONGO_USER = "admin";
    private static final String MONGO_PASSWORD = "r123456";
​
    public void getConnection(){
        try{
            
        }
    }
}

package mongodbtest;
​
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoDatabase;
​
import java.util.ArrayList;
import java.util.List;
​
/**
 * 使用MongoDB连接到服务器环境上
 * @since JDK 1.8
 * @date 0221/6/29
 * @author Lucifer
 */
public class mongoconnection {
​
    /*配置属性*/
    private static final String MONGO_HOST = "xxx.xxx.x.xx";
    private static final Integer MONGO_PORT = 27037;
    private static final String MONGO_USER = "admin";
    private static final String MONGO_PASSWORD = "r123456";
    private static final String MONGO_DB_NAME = "xxxxxx";
​
    public static void getConnection(){
        /*用事务连接到远程的MongoDB服务器上*/
        try {
            /*使用java包下的类构造一个连接对象*/
            ServerAddress serverAddress = new ServerAddress(MONGO_HOST, MONGO_PORT);
​
            /*集群连接方法--->构造列表*/
            List<ServerAddress> addresses = new ArrayList<ServerAddress>();
            addresses.add(serverAddress);
​
            /*使用Mongo包下的类MongoCredential建立连接对象*/
            //三个参数：用户名、数据库名称、密码
            MongoCredential credential = MongoCredential.createScramSha1Credential(MONGO_USER,
                    MONGO_DB_NAME,
                    MONGO_PASSWORD.toCharArray()); //最后一个形参需要转换成字符类型而不是字符串类型,使用toCharArray方法
            /*集群连接方法--->构造列表*/
            List<MongoCredential> credentials = new ArrayList<MongoCredential>();
            credentials.add(credential);
​
            /*通过连接认证MongoDB连接--->使用MongoDBClient类下的方法*/
            MongoClient mongoClient = new MongoClient(addresses, credentials); //放入列表对象
​
            /*连接到数据库*/
            MongoDatabase mongoDatabase = mongoClient.getDatabase(MONGO_DB_NAME);
            System.out.println("Connect to database successfully!");
        }catch (Exception e){
            System.err.println(e.getClass().getName() + ":" + e.getMessage());
        }
    }
    /*
    步骤概括：
    1、利用ServerAddress类访问到地址和端口
    2、使用MongoDB的jar包下封装好的证书类(Credential)验证身份信息--->构造器：用户名、数据库名称、密码
    3、使用Mongo客户端类封装好的方法验证是否连接成功--->构造器：Address类的列表、Credential类的列表
    4、use指定的数据库--->使用mongoDatabase类下的方法连接到数据库
     */
​
    public static void main(String[] args) {
        getConnection();
    }
}
​