我正在使用spark和mongo。我可以使用以下代码连接到mongo:
val sc = new SparkContext("local", "Hello from scala")
val config = new Configuration()
config.set("mongo.input.uri", "mongodb://127.0.0.1:27017/dbName.collectionName")
val mongoRDD = sc.newAPIHadoopRDD(config, classOf[com.mongodb.
最近我开始学习ktor,这样我就可以创建我自己的api了,我设置了我的服务器,一切都很好,但是现在我想应用这种将数据保存到db中的逻辑,然后简单地从db加载数据并将其发送到我的服务器。
,,我现在就是这样做的,,
private fun insertDetails(user : ArrayList<userCredentials>){
val client = KMongo.createClient()
var database = client.getDatabase("test")
var collection = database
我有一个MongoDB查询:
db.Certificates.countDocuments(
{"vaccination.somministration_date":ISODate("2021-08-04")}
)
我也想在我的java应用程序中执行它,所以我尝试了以下代码:
Date date = new SimpleDateFormat("yyyy-MM-dd").parse("2021-08-04");
Bson query = eq("vaccination.somministration_date",