MongoDB에 데이터 쓰기

1
import com.mongodb.ConnectionString
2
import com.mongodb.MongoClientSettings
3
import com.mongodb.client.model.*
4
import com.mongodb.kotlin.client.*
5
import org.bson.Document
6
7
fun main() {
8
    val uri = "<connection string URI>"
9
    
10
    val settings = MongoClientSettings.builder()
11
        .applyConnectionString(ConnectionString(uri))
12
        .retryWrites(true)
13
        .build()
14
15
    // Create a new client and connect to the server
16
    val mongoClient = MongoClient.create(settings)
17
    val database = mongoClient.getDatabase("<database name>")
18
    val collection = database.getCollection<Document>("<collection name>")
19
20
    // Start example code here
21
22
    // End example code here
23
}

val result = collection.insertOne(Document("<field name>", "<value>"))
print(result.insertedId)

val docList = listOf(
    Document("<field name>", "<value>"),
    Document("<field name>", "<value>")
)
val result = collection.insertMany(docList)
print(result.insertedIds)

val query = Filters.eq("<field to match>", "<value to match>")
val update = Updates.set("<field name>", "<value>")
val result = collection.updateOne(query, update)
print(result.modifiedCount)

val query = Filters.eq("<field to match>", "<value to match>")
val update = Updates.set("<field name>", "<value>")
val result = collection.updateMany(query, update)
print(result.modifiedCount)

val query = Filters.eq("<field to match>", "<value to match>")
val replacement = Document("<new document field name>", "<new document value>")
val result = collection.replaceOne(query, replacement)
print(result.modifiedCount)

val query = Filters.eq("<field to match>", "<value to match>")
val result = collection.deleteOne(query)
print(result.deletedCount)

val query = Filters.eq("<field to match>", "<value to match>")
val result = collection.deleteMany(query)
print(result.deletedCount)

val bulkOps = listOf(
    InsertOneModel(Document("<field name>", "<value>")),
    UpdateOneModel(
        Filters.eq("<field to match>", "<value to match>"),
        Updates.set("<field name>", "<value>")),
    DeleteOneModel(Filters.eq("<field to match>", "<value to match>"))
)
val result = collection.bulkWrite(bulkOps)
print(result)