4

mongodb の bd MyDB に 200 の要素を含む MyCollection というコレクションがあります

> use MyDB
switched to db MyDB 
> db.MyCollection.count()
200

カーソルをロードして反復するために使用したさまざまな方法でも、非常にまれな動作が発生します。これが私のコードです。

DBCollection collection = getCollection("MyBD", "MyCollection");
DBCursor cursor = collection.find();
//DBCursor cursor = collection.find().limit(200); 
System.out.println("Cursor length: "+cursor.length());
Iterator<DBObject> itrc = cursor.iterator();
//while(cursor.hasNext()){
while (itrc.hasNext()) {
    //DBObject obj = (DBObject)cursor.next();
    DBObject obj = (DBObject)itrc.next();
    //BSONObject obj2 = (BSONObject)obj.get("scores");
    Integer intg = (Integer) obj.get("_id");
    System.out.println("_id:"+intg.toString());

    // operations remove and insert  on the collection
    // that affect the cursor behavior
    BasicDBList bl = (BasicDBList) obj.get("fieldArray");
    BasicDBObject bdo = new BasicDBObject();
    bdo.put("fieldArray", bl);
    Integer intid = (Integer) obj.get("_id");
    bdo.put("_id", intid);
    String str = (String) obj.get("fieldString");
    bdo.put("fieldString", str);
    collection.remove(obj);
    obj=null;
    collection.insert(bdo);

    if(intg.intValue()==199){
        System.out.println("Reached: "+intg.intValue());
    }   
}

これは出力です：

Cursor length: 200
_id:0 _id:1 _id:2 _id:3 _id:4 _id:5 _id:6 _id:7 _id:8 _id:9 _id:10 _id:11 _id:12 _id:13 _id:14 _id:15 _id:16 _id:17 _id:18 _id:19 _id:20 _id:21 _id:22 _id:23 _id:24 _id:25 _id:26 _id:27 _id:28 _id:29 _id:30 _id:31 _id:32 _id:33 _id:34 _id:35 _id:36 _id:37 _id:38 _id:39 _id:40 _id:41 _id:42 _id:43 _id:44 _id:45 _id:46 _id:47 _id:48 _id:49 _id:50 _id:51 _id:52 _id:53 _id:54 _id:55 _id:56 _id:57 _id:58 _id:59 _id:60 _id:61 _id:62 _id:63 _id:64 _id:65 _id:66 _id:67 _id:68 _id:69 _id:113 _id:101 _id:102 _id:103 _id:104 _id:105 _id:106 _id:107 _id:108 _id:109 _id:110 _id:111 _id:112 _id:114 _id:115 _id:116 _id:117 _id:118 _id:119 _id:120 _id:121 _id:122 _id:123 _id:124 _id:125 _id:126 _id:127 _id:128 _id:129 _id:130 _id:131 _id:132 _id:133 _id:134 _id:135 _id:136 _id:137 _id:138 _id:139 _id:140 _id:141 _id:142 _id:143 _id:144 _id:145 _id:146 _id:147 _id:148 _id:149 _id:150 _id:151 _id:152 _id:153 _id:154 _id:155 _id:156 _id:157 _id:158 _id:159 _id:160 _id:161 _id:162 _id:163 _id:164 _id:165 _id:166 _id:167 _id:168 _id:169 _id:170 _id:171 _id:172 _id:173 _id:174 _id:175 _id:176 _id:177 _id:178 _id:179 _id:180 _id:181 _id:182 _id:183 _id:184 _id:185 _id:186 _id:187 _id:188 _id:189 _id:190 _id:191 _id:192 _id:193 _id:194 _id:195 _id:196 _id:197 _id:198 _id:199
***************************
Reached: 199
***************************
 _id:70 _id:71 _id:72 _id:73 _id:74 _id:75 _id:76 _id:77 _id:78 _id:79 _id:80 _id:81 _id:82 _id:83 _id:84 _id:85 _id:86 _id:87 _id:88 _id:89 _id:90 _id:91 _id:92 _id:93 _id:94 _id:95 _id:96 _id:97 _id:98 _id:99 _id:100_id:96 _id:97 _id:98 _id:99 _id:100

ご覧のとおり、200 個の要素の制限 (要素 _id:199) に達すると、_id:70 の要素にジャンプし、要素 _id:100 に達するまで 31 回の反復を繰り返します。 200回の反復である適切な時期。

代替手段: 1 つはコード内でコメント化され (カーソルのメソッド: hasNext() を使用)、実行中のもう 1 つは (Iterator を使用して) 両方とも同じ出力を持ちます。

コレクションの操作部分を削除すると (私の場合は削除/挿入)、まれな動作は発生しません。

これは期待される出力です:

Cursor length: 200
_id:0 _id:1 _id:2 _id:3 _id:4 _id:5 _id:6 _id:7 _id:8 _id:9 _id:10 _id:11 _id:12 _id:13 _id:14 _id:15 _id:16 _id:17 _id:18 _id:19 _id:20 _id:21 _id:22 _id:23 _id:24 _id:25 _id:26 _id:27 _id:28 _id:29 _id:30 _id:31 _id:32 _id:33 _id:34 _id:35 _id:36 _id:37 _id:38 _id:39 _id:40 _id:41 _id:42 _id:43 _id:44 _id:45 _id:46 _id:47 _id:48 _id:49 _id:50 _id:51 _id:52 _id:53 _id:54 _id:55 _id:56 _id:57 _id:58 _id:59 _id:60 _id:61 _id:62 _id:63 _id:64 _id:65 _id:66 _id:67 _id:68 _id:69 _id:113 _id:101 _id:102 _id:103 _id:104 _id:105 _id:106 _id:107 _id:108 _id:109 _id:110 _id:111 _id:112 _id:114 _id:115 _id:116 _id:117 _id:118 _id:119 _id:120 _id:121 _id:122 _id:123 _id:124 _id:125 _id:126 _id:127 _id:128 _id:129 _id:130 _id:131 _id:132 _id:133 _id:134 _id:135 _id:136 _id:137 _id:138 _id:139 _id:140 _id:141 _id:142 _id:143 _id:144 _id:145 _id:146 _id:147 _id:148 _id:149 _id:150 _id:151 _id:152 _id:153 _id:154 _id:155 _id:156 _id:157 _id:158 _id:159 _id:160 _id:161 _id:162 _id:163 _id:164 _id:165 _id:166 _id:167 _id:168 _id:169 _id:170 _id:171 _id:172 _id:173 _id:174 _id:175 _id:176 _id:177 _id:178 _id:179 _id:180 _id:181 _id:182 _id:183 _id:184 _id:185 _id:186 _id:187 _id:188 _id:189 _id:190 _id:191 _id:192 _id:193 _id:194 _id:195 _id:196 _id:197 _id:198 _id:199
***************************
Reached: 199
***************************

私は同様の SO questionを見つけましたが、私には明確ではありません:

  • 操作の削除/挿入は、以前に公開した方法でカーソルの動作にどのように影響しますか?
  • スナップショット オプションを使用するにはどうすればよいですか?
  • 先のことを考えて、順序付けられたコレクションを操作する必要がある場合はどうしますか?

ところで、イテレータなしでオプションを使用すると、次のようになります。

while(cursor.hasNext()){
    DBObject obj = (DBObject)cursor.next();

  • 次の行を削除する必要があるのはなぜですか?

    System.out.println("カーソルの長さ: "+cursor.length());

次の例外を回避するには:

Exception in thread "main" java.lang.IllegalArgumentException: can't switch cursor access methods
    at com.mongodb.DBCursor._checkType(DBCursor.java:412)
    at com.mongodb.DBCursor.hasNext(DBCursor.java:483)
    at tasks.UpdateRemoveHW.main(Test.java:56)
4

2 に答える 2

3

例外 IllegalArgumentException をスローするだけで、DBCursor.length() を使用すると、すでにカーソルが配列に変換されていることがわかります。hasext() または next() を使用する場合は、反復の前に length() を削除することをお勧めします。

于 2014-09-15T04:47:21.193 に答える
2

質問の最初の部分でのまれな動作で何が起こっているのかわかりませんが、一般に、 Iterator.remove() メソッドを使用する場合を除いて、反復処理中にデータ構造を変更することは安全ではありません。

質問の最後の部分は、DBCursorの API ドキュメントの上部にある次の警告によって間接的に回答されます。

警告: DBCursor で toArray または length を呼び出すと、元に戻すことができないように配列に変換されます。これは、カーソルが (データベースから遅延フェッチしていた) 1000 万を超える結果を繰り返していた場合、メモリ内に突然 1000 万の要素配列が存在することを意味します。配列に変換する前に、skip() と limit() を使用して妥当な数の結果があることを確認してください。

IllegalArgumentExceptionをスローしているDBCursor のソース コード (483 行目)を読むと、DBCursor.length() を呼び出すとカーソルが配列に変わり、その後 DBCursor.next() または DBCursor をすべて呼び出すことがわかります。 .hasNext() は Illegal になります。

私は、この行動は確実に最小の驚きの原則に違反していると思います。配列は引き続き Iterator を持つことができるので、内部データ構造を非表示にして、Iterator メソッドが引き続き機能するようにした方がよいでしょう。また、DBCursor.length() を呼び出しても DB からレコードをフェッチする必要はありません。DBCursor.count() と同様に動作するはずですが、何らかの方法で limit() と skip() を考慮して結果をキャッシュします。

于 2013-03-26T01:37:30.063 に答える