package com.xctl.util import com.mongodb.MongoClient import com.mongodb.MongoCredential import com.mongodb.ServerAddress import org.bson.Document import java.util.* object MongoDBJDBCandUsernameAndpassword { @JvmStatic fun main(args: Array<String>) { try { //连接到MongoDB服务 如果是远程连接可以替换“localhost”为服务器所在IP地址 //ServerAddress()两个参数分别为 服务器地址 和 端口 val serverAddress = ServerAddress("39.106.196.5", 27017) val addrs = ArrayList<ServerAddress>() addrs.add(serverAddress) //MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码 val credential = MongoCredential.createScramSha1Credential("house_keeper", "house_keeper", "house_keeper".toCharArray()) val credentials = ArrayList<MongoCredential>() credentials.add(credential) //通过连接认证获取MongoDB连接 val mongoClient = MongoClient(addrs, credentials) //连接到数据库 val mongoDatabase = mongoClient.getDatabase("house_keeper") val collection=mongoDatabase.getCollection("HotelRoomInformation") val document = Document("title", "MongoDB").append("description", "database").append("likes", 100).append("by", "Fly") val documents = ArrayList<Document>() documents.add(document) collection.insertMany(documents) } catch (e: Exception) { System.err.println(e.javaClass.name + ": " + e.message) } }
}
//在mongodb的可视化工具显示如下结果