@Grab(group='com.gmongo', module='gmongo', version='0.8') import com.mongodb.* import com.gmongo.* mongo = new GMongo("localhost", 27017) // 全DBの全collectionに対してvalidateコマンドを実行 mongo.getDatabaseNames().each { dbname -> db = mongo.getDB(dbname) db.getCollectionNames().each { colname -> println db.command(validate:colname, scandate:true, full:true) } }
@Grab(group='com.gmongo', module='gmongo', version='0.9') import com.mongodb.* import com.gmongo.* mongo = new GMongo("localhost", 27017) // 現在のmaster serverの最大オブジェクトサイズを取得する println "max BSON object size(MB):" + mongo.getMaxBsonObjectSize()/1024/1024
@Grab(group='com.gmongo', module='gmongo', version='0.8') @Grab(group='rome', module='rome', version='1.0') import com.mongodb.* import com.gmongo.* import com.sun.syndication.feed.synd.* import com.sun.syndication.io.* uri = "http://feeds.dzone.com/dzone/frontpage?format=xml" SyndFeed feed = new SyndFeedInput(false).build( new InputStreamReader(new URL(uri).openStream(), "UTF-8") ) mongo = new GMongo("localhost", 27017) db = mongo.getDB("local") col = db["entries"] // ユニークインデックスなければ作成する col.ensureIndex( new BasicDBObject([feedTitle:true, link:true]), new BasicDBObject([unique:true]) ) col.setWriteConcern(WriteConcern.NORMAL); // RSS/Atomのエントリーをコレクションに追加 for( entry in feed.entries ){ wr = col.insert([feedTitle:feed.title, link:entry.link, publishedDate:entry.publishedDate, title:entry.title]) println "error:" + wr.getError() }
@Grab(group='com.gmongo', module='gmongo', version='0.8') import com.mongodb.* import com.gmongo.* mongo = new GMongo("localhost", 27017) db = mongo.getDB("local") db["office_location"].drop() // コレクションにオブジェクトを挿入する col = db["office_location"] col.insert([office:"Tokyo", country:"Japan"]) col.insert([office:"Sanfrancisco", country:"United States"]) col.insert([office:"Chicago", country:"United States"]) // 重複を排除した形で全件検索 for(obj in col.find().snapshot()){ println obj }
@Grab(group='com.gmongo', module='gmongo', version='0.8') import com.mongodb.* import com.gmongo.* mongo = new GMongo("localhost", 27017) db = mongo.getDB("local") // 各コレクションのストレージサイズ・インデックスサイズを取得 for(col in db.getCollectionNames()){ println "collection name:" + col + ", storage size:" + db[col].getStats().storageSize + ", total index size:" + db[col].getStats().totalIndexSize }
@Grab(group='com.gmongo', module='gmongo', version='0.8') import com.mongodb.* import com.gmongo.* mongo = new GMongo("localhost", 27017) // DBが既に存在する場合は削除 dbname = "perftest" if( mongo.getDatabaseNames().contains(dbname) ){ mongo.dropDatabase(dbname) } db = mongo.getDB("perftest") st = System.currentTimeMillis() // コレクションにオブジェクトを挿入する col = db["stores"] (1..10000).each{ col.insert([country:"Japan", store:"store_${it}", sales:100]) } println "processed ${col.count()} rows in ${System.currentTimeMillis()-st}ms."bulk insertを使用したコード
@Grab(group='com.gmongo', module='gmongo', version='0.8') import com.mongodb.* import com.gmongo.* mongo = new GMongo("localhost", 27017) // DBが既に存在する場合は削除 dbname = "perftest" if( mongo.getDatabaseNames().contains(dbname) ){ mongo.dropDatabase(dbname) } db = mongo.getDB("perftest") st = System.currentTimeMillis() // コレクションにオブジェクトを挿入する col = db["stores"] (1..10000).step(2){ col.insert([ [country:"Japan", store:"store_${it}", sales:100], [country:"Japan", store:"store_${it+1}", sales:100] ]) } println "processed ${col.count()} rows in ${System.currentTimeMillis()-st}ms."実行速度計測結果
| 通常insert(ms) | bulk insert(x2)(ms) | |
|---|---|---|
| 1回目 | 3855 | 2961 |
| 2回目 | 4076 | 2980 |
| 3回目 | 3576 | 3314 |
| 平均 | 3835.67 | 3085 |
@Grab(group='com.gmongo', module='gmongo', version='0.8') import com.mongodb.* import com.gmongo.* mongo = new GMongo("localhost", 27017) db = mongo.getDB("local") db["stores"].drop() // コレクションにオブジェクトを挿入する col = db["stores"] col.insert([country:"Japan", store:"store_A", sales:100]) col.insert([country:"Japan", store:"store_B", sales:120]) col.insert([country:"Japan", store:"store_C", sales:170]) col.insert([country:"United States", store:"store_D", sales:80]) col.insert([country:"United States", store:"store_E", sales:200]) col.insert([country:"United States", store:"store_F", sales:190]) col.insert([country:"United States", store:"store_G", sales:100]) // 国ごとの最小値・最大値を取得 for(obj in col.group(/* key */new BasicDBObject([country:true]), /* condition */new BasicDBObject(), /* initial */new BasicDBObject([smin:0, smax:0, firstobj:true]), /* reduce */""" function(obj,prev){ if( prev.firstobj == true ){ prev.smin = obj.sales; prev.smax = obj.sales; prev.firstobj = false; } if( prev.smin > obj.sales ){prev.smin = obj.sales;} if( prev.smax < obj.sales ){prev.smax = obj.sales;} } """ )){ println obj["country"] + " min:${obj.smin} max:${obj.smax}" }動作環境
投稿
すべてのコメント
