import java.util.UUID;

import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.ServerAddress;
import com.mongodb.WriteConcern;

public class foo {

    foo() 
        throws Exception {
        Mongo mongo = new Mongo();
        _db = mongo.getDB( "test" );
        _collection = _db.getCollection("test");
        _collection.drop();

        _repairer = new Repairer();
    }

    void run() {
        _repairer.start();

        final int start = 0;
        final int max = start + 5000;
        while (true) {

            System.out.println("Inserting");
            for (int i = start; i<max; i++) {
                try {

                    BasicDBObject dbObject = new BasicDBObject();
                    dbObject.append("_id", i);
                    _collection.insert(dbObject, WriteConcern.SAFE);
                }
                catch (Exception e) {
                    e.printStackTrace();

                }
            }


            System.out.println("Deleting");

            for (int i = start; i<max; i++ ) {
                try {
                    DBObject q = new BasicDBObject().append("_id", i);
                    _collection.remove( q , WriteConcern.SAFE );
                }
                catch (Exception e) {
                    e.printStackTrace();
                }
            }
            System.out.println("Number of records left " + _collection.getCount());
        }

    }
    
    class Repairer extends Thread {
        public void run() {
            while ( true ) {
                try {
                    Thread.sleep( 5 * 1000 );
                    System.out.println( _db.command( new BasicDBObject( "repairDatabase" , 1 ) ) );
                }
                catch ( Exception e ) { 
                    e.printStackTrace();
                }
            }
        }
    }
    
    final DB _db;
    final DBCollection _collection;
    
    final Repairer _repairer;
    
    public static void main(String[] args) throws Exception {
        foo test = new foo();
        test.run();
    }

}