public IndexModule(MongoDatabase db)
        {
            var collection = db.GetCollection<Person>(typeof(Person).Name.ToLower() + "s");

            Get["/"] = parameters =>
                {
                    var value = new Random().Next(0, 999);
                    //SqlConnection connection = new SqlConnection("Data Source=10.0.122.14;Initial Catalog=srm4000;User ID=developers;Password=chicago");
                    //connection.Open();
                    //SqlCommand command = new SqlCommand("SELECT * FROM [TABLE] WHERE BATCHNO = " + value, connection);
                    //SqlDataReader reader = command.ExecuteReader();
                    //List<Person> people = new List<Person>();

                    //while (reader.Read())
                    //{
                    //    var person = new Person { BatchNo = (int)reader["BATCHNO"], Name = (string)reader["NAME"] };
                    //    people.Add(person);
                    //}
                    //reader.Close();
                    //connection.Close();
                    var foundit = collection.AsQueryable<Person>().Where(x => x.BatchNo == value).ToList();

                    return 200;
                };
        }

        public GridFsBlobStore(MongoDatabase database, ICounterService counterService)
        {
            _database = database;
            _counterService = counterService;

            LoadFormatsFromDatabase();
        }

        public static void CoverDB(MongoDatabase oldDB, MongoDatabase newDB, string collName, params string[] files)
        {
            MongoCollection oldColl = oldDB.GetCollection(collName);
            MongoCollection newColl = newDB.GetCollection(collName);
            int count = 0;

            var players = oldColl.FindAllAs<BsonDocument>();
            foreach (var doc in players)
            {
                foreach (string filed in files)
                {
                    Change(doc, filed);
                }
                //分离Box中的一点券购买
                if (collName == "PlayerEx")
                {
                    BoxToBuy(doc);
                }
                else if (collName == "Pet")
                {
                    RemovePlayerName(doc);
                }

                newColl.Save(doc);
                count++;
            }
            Console.WriteLine(collName + "转换完成" + count);
        }

        public static void Test2(MongoDatabase db)
        {
            var d = new Dictionary<string, object>();
            var pp = new PortalPage { Title = "This is my test", Id = "test1" };
            var pc = new PortalPageColumn();
            pp.Columns.Add(pc);
            pc.Config["width"] = 200;
            d["open"] = "open listener";
            d["close"] = "close listener";
            d["interval"] = 500;
            pc.Config["listeners"] = d;

            d = new Dictionary<string, object>();
            d["open"] = "open listener";
            d["close"] = "close listener";
            d["interval"] = 500;
            pc.Config["listeners"] = d;

            var pt = new Portlet { Title = "test portlet 1", PortletClass = "GraphImage" };
            pt.Config["width"] = 200;
            pt.Config["height"] = 300;
            pt.Config["listeners"] = d;
            pc.Portlets.Add(pt);

            db.GetCollection<PortalPage>().Save(pp);

            var pp2 = db.GetCollection<PortalPage>().FindOneById(pp.Id);
            Console.WriteLine("p2: {0}", pp2.Title);
        }

 public AutoIncrementIdImplementation(long capacity, MongoDatabase mongo)
 {
     _currentHi = 0;
     _capacity = capacity;
     _mongo = mongo;
     _currentLo = capacity + 1;
 }

        private void ConnectLocal(string dbName)
        {
            var client = new MongoClient(ConnStringLocal);
            var server = client.GetServer();

            this.Database = server.GetDatabase(dbName);
        }

 public HugRepository(string connectionString, string databaseName, IUserProfileRepository userProfileRepository)
 {
     _userProfileRepository = userProfileRepository;
     _server = MongoServer.Create(connectionString);
     _database = _server.GetDatabase(databaseName);
     _mongoCollection = _database.GetCollection<PenedatingMongoUser>("users");
 }

 public void Setup()
 {
     _server = Configuration.TestServer;
     _primary = Configuration.TestServer.Primary;
     _database = Configuration.TestDatabase;
     _database.Drop();
 }

 public void Setup()
 {
     _server = Configuration.TestServer;
     _primary = Configuration.TestServer.Primary;
     _database = Configuration.TestDatabase;
     _collection = Configuration.TestCollection;
 }

        public void Connect(string name = DefaultDbName)
        {
            var client = new MongoClient(DefaultConnectionString);
            var server = client.GetServer();

            this.Database = server.GetDatabase(name);
        }

 public void TestFixtureSetUp()
 {
     _server = MongoServer.Create(ConnStr);
     if (_server.DatabaseExists(PropSetCollectionsDb))
         _server.DropDatabase(PropSetCollectionsDb);
     _testDb = _server.GetDatabase(PropSetCollectionsDb);
 }

 public void Setup()
 {
     _server = Configuration.TestServer;
     _server.Connect();
     _database = Configuration.TestDatabase;
     _database.Drop();
 }

 public void Setup()
 {
     _server = Configuration.TestServer;
     _primary = _server.Instances.First(x => ReadPreference.Primary.MatchesInstance(x));
     _database = Configuration.TestDatabase;
     _collection = Configuration.TestCollection;
 }

 public static void EstablishConnection()
 {
     client = new MongoClient(connectionString);
     server = client.GetServer();
     database = server.GetDatabase(DbName);
     entries = database.GetCollection<JSonReport>(collectionName);
 }

 public void Setup()
 {
     _server = LegacyTestConfiguration.Server;
     _primary = _server.Instances.First(x => x.IsPrimary);
     _database = LegacyTestConfiguration.Database;
     _collection = LegacyTestConfiguration.Collection;
 }

        public UseCaseUpdateTask(IAppConfig appConfig, IDataList<UseCase> useCases)
        {
            var url = new MongoUrl(appConfig.ProxyDbConnectionString);
            _db = new MongoClient(url).GetServer().GetDatabase(url.DatabaseName);

            _useCases = useCases;
        }

 public MdbAccount()
 {
     m_Client = new MongoClient(Configuration.Database.Url);
     m_Server = m_Client.GetServer();
     m_Database = m_Server.GetDatabase(Configuration.Database.Name);
     m_Collection = m_Database.GetCollection<Account>(MDBAccountTable);
 }

 public void TestFixtureSetup()
 {
     server = MongoServer.Create("mongodb://localhost/?safe=true");
     database = server["onlinetests"];
     collection = database["testcollection"];
     collection.Drop();
 }

 public void TestFixtureSetup()
 {
     _database = Configuration.TestDatabase;
     var collectionSettings = new MongoCollectionSettings() { GuidRepresentation = GuidRepresentation.Standard };
     _collection = _database.GetCollection<C>("csharp714", collectionSettings);
     _collection.Drop();
 }

 public PersonRepository()
 {
     string connectionString = "mongodb://localhost";
     _server = MongoServer.Create(connectionString);
     _peopleDb = _server.GetDatabase("Mono");
     _people = _peopleDb.GetCollection<Person>("Person");
 }