데브포유

1. 데이터베이스명 => 변경하는 방법이 없는 것으로 보임. copyDatabase 통해서 구현하는데 비효율적임으로 데이터베이스명을 정할때는 신중하게 해야함. 2. 컬렉션명 => db.collection.renameCollection("컬렉션명"); ex) emp -> nemp db.emp.renameCollection("nemp"); 3. 필드명 변경 (ename -> name) db.emp.updateMany( {}, {$rename:{"ename":"name"}})

DBQuery.shellBatchSize = 10;batchSize는 RDBMS에서 Fetch Count와 같은 것입니다. 한번에 리턴되는 Document의 갯수라고 보시면 됩니다. 응답을 빠르게 하려면 줄이면 되고, 대량의 데이터를 빠르게 가져오고 싶으면 늘리면 됩니다. 기본값은 20 입니다.

첫번째 예제) 하나의 도큐먼트를 sizes의 배열 요소로 분리함{ "_id" : 1, "item" : "ABC1", sizes: [ "S", "M", "L"] } db.inventory.aggregate( [ { $unwind : "$sizes" } ] ) { "_id" : 1, "item" : "ABC1", "sizes" : "S" } { "_id" : 1, "item" : "ABC1", "sizes" : "M" } { "_id" : 1, "item" : "ABC1", "sizes" : "L" }_id:1인 다큐먼트를 sizes 배열의 요소 갯수만큼 document로 분리함. RDBMS의 데카르트곱(카데시안곱)과 같은 동작을 함. 두번째 예제) sizes 배열의 요소의 순번 표시하기{ "_id" : 1..

db.orders.aggregate([ { $match: { status: "A" } }, { $group: { _id: "$cust_id", total: { $sum: "$amount" } } }, { $sort: { total: -1 } } ], { explain: true } )explain: true를 주면 실행 계획을 볼 수 있음

db.stocks.aggregate( [ { $project : { cusip: 1, date: 1, price: 1, _id: 0 } }, { $sort : { cusip : 1, date: 1 } } ], { allowDiskUse: true } )allowDiskUse: true 는 sort시 메모리가 모자라면 임시 파일을 이용해서 정렬을 수행함. 큰 데이터를 다룰 때 이용하면 좋음.

db.orders.aggregate( [ { $match: { status: "A" } }, { $group: { _id: "$cust_id", total: { $sum: "$amount" } } }, { $sort: { total: -1 } }, { $limit: 2 } ], { cursor: { batchSize: 0 } } )batchSize:0 이면 데이터가 조회되는 즉시 리턴됨. 빠르게 첫번째 데이터를 가져올 수 있음

Aggregate 예제1보다 몽고쉘에서 수행하는 형태로 작성해 보기....new Document 방식 보다는 아래 방식이 더 비슷해 보입니다. MongoClient mongo = ~~~ 생략... MongoDatabase db = mongo.getDatabase("test"); // test db MongoCollection coll_trd = db.getCollection("tn_trade"); AggregateIterable res_doc = coll_trd.aggregate ( Arrays.asList( Aggregates.match( Filters.gte("price", 50000) ), Aggregates.group("$prdt_nm", sum("tot_sum", "$price") ) )); f..

MongoClient mongo = ~~~ 생략... MongoDatabase db = mongo.getDatabase("test"); // test db MongoCollection coll_trd = db.getCollection("tn_trade"); AggregateIterable res_doc = coll_trd.aggregate ( Arrays.asList( new Document("$match", new Document("price", new Document("$gte", 50000))), new Document("$group", new Document("_id", "$prdt_nm") .append("trd_sum", new Document("$sum", "$price")) )); for(..