mongod --dbpath=d:\xampp\mongodb\data\shard1 --port 28017mongod --dbpath=d:\xampp\mongodb\data\shard2 --port 28018mongod --dbpath=d:\xampp\mongodb\data\shard3 --port 28019
mongod --configsvr --port 28099 --dbpath=d:\xampp\mongodb\data\config
mongos --configdb localhost:28099 --port 28100 --chunkSize 3
D:\xampp\mongodb\bin>mongo localhost:28100/admin
MongoDB shell version: 2.0.3
connecting to: localhost:28100/admin
mongos> db.runCommand({addshard:"localhost:28017"});
{ "shardAdded" : "shard0000", "ok" : 1 }
mongos> db.runCommand({addshard:"localhost:28018"});
{ "shardAdded" : "shard0001", "ok" : 1 }
mongos> db.runCommand({addshard:"localhost:28019"});
{ "shardAdded" : "shard0002", "ok" : 1 }
mongos> db.rintShardingStatus();
--- Sharding Status ---
sharding version: { "_id" : 1, "version" : 3 }
shards:
{ "_id" : "shard0000", "host" : "localhost:28017" }
{ "_id" : "shard0001", "host" : "localhost:28018" }
{ "_id" : "shard0002", "host" : "localhost:28019" }
databases:
{ "_id" : "admin", "partitioned" : false, "primary" : "config" }
mongos>
mongos> db.runCommand({shardcollection:"test.test",key:{userid:1}});
{ "ok" : 0, "errmsg" : "sharding not enabled for db" }
mongos> db.runCommand({enablesharding:"test"});
{ "ok" : 1 }
mongos> db.runCommand({shardcollection:"test.test",key:{userid:1}});
{ "collectionsharded" : "testdb.test", "ok" : 1 }
D:\xampp\mongodb\bin>mongo localhost:28100
MongoDB shell version: 2.0.3
connecting to: localhost:28100/test
mongos>
mongos> for(var i =0; i<1000000; i++) {
... var doc = {userid:i, name:"user"+i};
... db.test.save(doc);
... }
mongos> db.runCommand({addshard:"localhost:28017"});db.printShardingStatus();
--- Sharding Status ---
sharding version: { "_id" : 1, "version" : 3 }
shards:
{ "_id" : "shard0000", "host" : "localhost:28017" }
{ "_id" : "shard0001", "host" : "localhost:28018" }
{ "_id" : "shard0002", "host" : "localhost:28019" }
databases:
{ "_id" : "admin", "partitioned" : false, "primary" : "config" }
{ "_id" : "testdb", "partitioned" : true, "primary" : "shard0000" }
{ "_id" : "test", "partitioned" : true, "primary" : "shard0000" }
test.test chunks:
shard0000 8
shard0001 7
shard0002 14
too many chunks to print, use verbose if you want to force print
mongos> db.test.count();
1000000
D:\xampp\mongodb\bin>mongo localhost:28017
MongoDB shell version: 2.0.4
connecting to: localhost:28017/test
> db.test.count();
162515
D:\xampp\mongodb\bin>mongo localhost:28018
MongoDB shell version: 2.0.4
connecting to: localhost:28018/test
> db.test.count();
171400
D:\xampp\mongodb\bin>mongo localhost:28019
MongoDB shell version: 2.0.4
connecting to: localhost:28019/test
> db.test.count();
666085
D:\xampp\mongodb\data ┗rep1 ┗rep2 ┗rep3
mongod --replSet rep_test --port 27017 --dbpath ../data/rep1
mongod --replSet rep_test --port 27018 --dbpath ../data/rep2
mongod --replSet rep_test --port 27019 --dbpath ../data/rep3
Wed Mar 28 07:48:44 [rsStart] replSet can't get local.system.replset config from self or any seed (EMPTYCONFIG)
D:\xampp\mongodb\bin>mongo
MongoDB shell version: 2.0.3
connecting to: test
> config = {_id: 'rep_test', members: [
{_id: 0, host: '127.0.0.1:27017'},
{_id: 1, host: '127.0.0.1:27018'},
{_id: 2, host: '127.0.0.1:27019'}]
};
rs.initiate(config);
{
"info" : "Config now saved locally. Should come online in about a minute.",
"ok" : 1
}
>
[rsStart] replSet STARTUP2 [rsSync] ****** [rsSync] creating replication oplog of size: 47MB... [rsSync] ****** [rsSync] replSet initial sync pending [rsSync] replSet initial sync need a member to be primary or second initial sync [rsHealthPoll] replSet member 127.0.0.1:27017 is up [rsHealthPoll] replSet member 127.0.0.1:27017 is now in state SECONDARY [rsHealthPoll] replSet member 127.0.0.1:27018 is up [rsHealthPoll] replSet member 127.0.0.1:27018 is now in state SECONDARY [rsSync] replSet initial sync finishing up
PRIMARY> rs.status()
{
"set" : "rep_test",
"date" : ISODate("2012-03-27T23:03:25Z"),
"myState" : 1,
"syncingTo" : "127.0.0.1:27019",
"members" : [
{
"_id" : 0,
"name" : "127.0.0.1:27017",
"health" : 1,
"state" : 1,
"stateStr" : "SECONDARY",
"optime" : {
"t" : 1332888980000,
"i" : 1
},
"optimeDate" : ISODate("2012-03-27T22:56:20Z"),
"self" : true
},
{
"_id" : 1,
"name" : "127.0.0.1:27018",
"health" : 1,
"state" : 2,
"stateStr" : "SECONDARY",
"uptime" : 422,
"optime" : {
"t" : 1332888980000,
"i" : 1
},
"optimeDate" : ISODate("2012-03-27T22:56:20Z"),
"lastHeartbeat" : ISODate("2012-03-27T23:03:25Z"),
"pingMs" : 0
},
{
"_id" : 2,
"name" : "127.0.0.1:27019",
"health" : 1,
"state" : 2,
"stateStr" : "PRIMARY",
"uptime" : 159,
"optime" : {
"t" : 1332888980000,
"i" : 1
},
"optimeDate" : ISODate("2012-03-27T22:56:20Z"),
"lastHeartbeat" : ISODate("2012-03-27T23:03:24Z"),
"pingMs" : 0
}
],
"ok" : 1
}
[rsHealthPoll] replSet member 127.0.0.1:27019 is now in state DOWN
PRIMARY> rs.status()
{
（略）
"members" : [
{
"_id" : 0,
"name" : "127.0.0.1:27017",
"health" : 1,
"state" : 1,
"stateStr" : "PRIMARY",
（略）
},
{
"_id" : 1,
"name" : "127.0.0.1:27018",
"health" : 1,
"state" : 2,
"stateStr" : "SECONDARY",
（略）
},
{
"_id" : 2,
"name" : "127.0.0.1:27019",
"health" : 0,
"state" : 8,
"stateStr" : "(not reachable/healthy)",
（略）
}
],
"ok" : 1
}
mongod --replSet rep_test --port 27019 --dbpath ../data/rep3
PRIMARY> rs.status()
{
（略）
"members" : [
{
"_id" : 0,
"name" : "127.0.0.1:27017",
"health" : 1,
"state" : 1,
"stateStr" : "PRIMARY",
（略）
},
{
"_id" : 1,
"name" : "127.0.0.1:27018",
"health" : 1,
"state" : 2,
"stateStr" : "SECONDARY",
（略）
},
{
"_id" : 2,
"name" : "127.0.0.1:27019",
"health" : 1,
"state" : 2,
"stateStr" : "SECONDARY",
（略）
}
],
"ok" : 1
}
> db.example.remove()
> for(var i =0; i<6; i++) {
... var doc = {name:'user'+i, point: i*1000};
... db.example.save(doc);
... }
>
> db.example.find()
{"_id":ObjectId("4f69766ea84ad157af92c6ab"),"name":"user0","point":0}
{"_id":ObjectId("4f69766ea84ad157af92c6ac"),"name":"user1","point":1000}
{"_id":ObjectId("4f69766ea84ad157af92c6ad"),"name":"user2","point":2000}
{"_id":ObjectId("4f69766ea84ad157af92c6ae"),"name":"user3","point":3000}
{"_id":ObjectId("4f69766ea84ad157af92c6af"),"name":"user4","point":4000}
{"_id":ObjectId("4f69766ea84ad157af92c6b0"),"name":"user5","point":5000}
> db.example.find({point:2000})
{ "_id" : ObjectId("4f69766ea84ad157af92c6ad"), "name" : "user2", "point" : 2000 }
> db.example.find().sort({point:1})
{ "_id" : ObjectId("4f69766ea84ad157af92c6ab"), "name" : "user0", "point" : 0 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6ac"), "name" : "user1", "point" : 1000 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6ad"), "name" : "user2", "point" : 2000 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6ae"), "name" : "user3", "point" : 3000 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6af"), "name" : "user4", "point" : 4000 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6b0"), "name" : "user5", "point" : 5000 }
> db.example.find().sort({point:-1})
{ "_id" : ObjectId("4f69766ea84ad157af92c6b0"), "name" : "user5", "point" : 5000 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6af"), "name" : "user4", "point" : 4000 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6ae"), "name" : "user3", "point" : 3000 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6ad"), "name" : "user2", "point" : 2000 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6ac"), "name" : "user1", "point" : 1000 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6ab"), "name" : "user0", "point" : 0 }
>db.example.find().limit(2)
{ "_id" : ObjectId("4f69766ea84ad157af92c6ab"), "name" : "user0", "point" : 0 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6ac"), "name" : "user1", "point" : 1000 }
> db.example.find().skip(4)
{ "_id" : ObjectId("4f69766ea84ad157af92c6af"), "name" : "user4", "point" : 4000 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6b0"), "name" : "user5", "point" : 5000 }
> db.example.find().skip(2).limit(2)
{ "_id" : ObjectId("4f69766ea84ad157af92c6ad"), "name" : "user2", "point" : 2000 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6ae"), "name" : "user3", "point" : 3000 }
> db.example.find({point:{$gte:3000}})
{ "_id" : ObjectId("4f69766ea84ad157af92c6ae"), "name" : "user3", "point" : 3000 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6af"), "name" : "user4", "point" : 4000 }
{ "_id" : ObjectId("4f69766ea84ad157af92c6b0"), "name" : "user5", "point" : 5000 }
> var cursor = db.example.find();
> cursor.hasNext()
true
> cursor.next()
{
"_id" : ObjectId("4f69766ea84ad157af92c6ab"),
"name" : "user0",
"point" : 0
}
>while (cursor.hasNext()){printjson(cursor.next());}
{
"_id" : ObjectId("4f69766ea84ad157af92c6ac"),
"name" : "user1",
"point" : 1000
}
{
"_id" : ObjectId("4f69766ea84ad157af92c6ad"),
"name" : "user2",
"point" : 2000
}
{
"_id" : ObjectId("4f69766ea84ad157af92c6ae"),
"name" : "user3",
"point" : 3000
}
{
"_id" : ObjectId("4f69766ea84ad157af92c6af"),
"name" : "user4",
"point" : 4000
}
{
"_id" : ObjectId("4f69766ea84ad157af92c6b0"),
"name" : "user5",
"point" : 5000
}
> mongo MongoDB shell version: 2.0.3 connecting to: test >
> help db.help() help on db methods db.mycoll.help() help on collection methods rs.help() help on replica set methods help admin administrative help help connect connecting to a db help help keys key shortcuts help misc misc things to know help mr mapreduce show dbs show database names show collections show collections in current database show users show users in current database show profile show most recent system.profile .... show logs show the accessible logger names show log [name] prints out the last segment of log in .... useset current database db.foo.find() list objects in collection foo db.foo.find( { a : 1 } ) list objects in foo where a == 1 it result of the last line evaluated; use to further iterate DBQuery.shellBatchSize = x set default number of items to.... exit quit the mongo shell
>db.mycoll.help()
DBCollection help
db.mycoll.find().help() - show DBCursor help
db.mycoll.count()
db.mycoll.dataSize()
db.mycoll.distinct( key ) - eg. db.mycoll.distinct( 'x' )
db.mycoll.drop() drop the collection
db.mycoll.dropIndex(name)
db.mycoll.dropIndexes()
db.mycoll.ensureIndex(keypattern[,options]) - options is an object withthese ....
db.mycoll.reIndex()
db.mycoll.find([query],[fields]) - query is an optional query filter. fields is op....
db.mycoll.find(...).count()
db.mycoll.find(...).limit(n)
db.mycoll.find(...).skip(n)
db.mycoll.find(...).sort(...)
db.mycoll.findOne([query])
db.mycoll.findAndModify( { update : ... , remove : bool [, query: {}, sort: {}, 'new': false] } )
db.mycoll.getDB() get DB object associated with collection
db.mycoll.getIndexes()
db.mycoll.group( { key : ..., initial: ..., reduce : ...[, cond: ...] })
db.mycoll.mapReduce( mapFunction , reduceFunction , )
db.mycoll.remove(query)
db.mycoll.renameCollection( newName , ) renames the collection.
db.mycoll.runCommand( name , ) runs a db command with the gi....
db.mycoll.save(obj)
db.mycoll.stats()
db.mycoll.storageSize() - includes free space allocated to this collection
db.mycoll.totalIndexSize() - size in bytes of all the indexes
db.mycoll.totalSize() - storage allocated for all data and indexes
db.mycoll.update(query, object[, upsert_bool, multi_bool])
db.mycoll.validate( ) - SLOW
db.mycoll.getShardVersion() - only for use with sharding
db.mycoll.getShardDistribution() - prints statistics about data distribution in the cluster
>db.example.save({name:'myname'})
>db.example.find();
{ "_id" : ObjectId("4f69656db3855bee2fdca9f2"), "name" : "myname" }
>db.example.save({age: 50})
>db.example.find()
{ "_id" : ObjectId("4f69656db3855bee2fdca9f2"), "name" : "myname" }
{ "_id" : ObjectId("4f696610b3855bee2fdca9f3"), "age" : 50 }
> db.example.find({age: 50})
{ "_id" : ObjectId("4f696610b3855bee2fdca9f3"), "age" : 50 }
D:\xampp\mongodb ┗bin ┗data ┗log
D:\xampp\mongodb\bin>mongod --logpath=D:\xampp\mongodb\log\mongodb_log.txt --dbpath=D:\xampp\mongodb\data
Mon Mar 19 17:18:58
Mon Mar 19 17:18:58 warning: 32-bit servers don't have journaling enabled by default. Please use --journal if you want durability.
Mon Mar 19 17:18:58
Mon Mar 19 17:18:58 [initandlisten] MongoDB starting : pid=4688 port=27017 dbpath=D:\xampp\mongodb\data 32-bit host=e2info9
Mon Mar 19 17:18:58 [initandlisten]
Mon Mar 19 17:18:58 [initandlisten] ** NOTE: when using MongoDB 32 bit, you are limited to about 2 gigabytes of data
Mon Mar 19 17:18:58 [initandlisten] ** see http://blog.mongodb.org/post/137788967/32-bit-limitations
Mon Mar 19 17:18:58 [initandlisten] ** with --journal, the limit is lower
Mon Mar 19 17:18:58 [initandlisten]
Mon Mar 19 17:18:58 [initandlisten] db version v2.0.3, pdfile version 4.5
Mon Mar 19 17:18:58 [initandlisten] git version: 05bb8aa793660af8fce7e36b510ad48c27439697
Mon Mar 19 17:18:58 [initandlisten] build info: windows sys.getwindowsversion(major=6, minor=0, build=6002, platform=2, service_pack='Service Pack 2') BOOST_LIB_VERSION=1_42
Mon Mar 19 17:18:58 [initandlisten] options: { dbpath: "D:\xampp\mongodb\data", logpath: "D:\xampp\mongodb\log\mongodb_log.txt" }
Mon Mar 19 17:18:59 [initandlisten] waiting for connections on port 27017
Mon Mar 19 17:18:59 [websvr] admin web console waiting for connections on port 28017
Mon Mar 19 17:19:59 [clientcursormon] mem (MB) res:14 virt:44 mapped:0
Mon Mar 19 17:19:59 [PeriodicTask::Runner] task: WriteBackManager::cleaner took: 31ms
D:\xampp\mongodb\bin>mongod --install --logpath=D:\xampp\mongodb\log\mongodb_log.txt --dbpath=D:\xampp\mongodb\data
extension=php_mongo.dll
以上。
MongoDBドライバの導入も超簡単。