mongodbçsaveåinsertå½æ°é½å¯ä»¥åcollectionéæå
¥æ°æ®ï¼ä½ä¸¤è
æ¯æ两个åºå«ï¼
ä¸ã使ç¨saveå½æ°éï¼å¦æåæ¥ç对象ä¸åå¨ï¼é£ä»ä»¬é½å¯ä»¥åcollectionéæå
¥æ°æ®ï¼å¦æå·²ç»åå¨ï¼saveä¼è°ç¨updateæ´æ°éé¢çè®°å½ï¼èinsertåä¼å¿½ç¥æä½
äºãinsertå¯ä»¥ä¸æ¬¡æ§æå
¥ä¸ä¸ªå表ï¼èä¸ç¨éåï¼æçé«ï¼ saveåéè¦éåå表ï¼ä¸ä¸ªä¸ªæå
¥ã
çä¸è¿ä¸¤ä¸ªå½æ°çååå°±æ¸
æ¥äºï¼ç´æ¥è¾å
¥å½æ°å便å¯ä»¥æ¥çååï¼ä¸é¢æ 红çé¨åå°±æ¯å®ç°äºå¾ªç¯ï¼å¯¹äºè¿ç¨è°ç¨æ¥è¯´ï¼æ¯ä¸æ§æ¬¡å°æ´ä¸ªå表postè¿æ¥è®©mongodbå»èªå·±å¤çï¼æçä¼é«äº
> db.user.insert
function (obj, _allow_dot) {
if (!obj) {
throw "no object passed to insert!";
}
if (!_allow_dot) {
this._validateForStorage(obj);
}
if (typeof obj._id == "undefined" && !Array.isArray(obj)) {
var tmp = obj;
obj = {_id:new ObjectId};
for (var key in tmp) {
obj[key] = tmp[key];
}
}
this._db._initExtraInfo();
this._mongo.insert(this._fullName, obj);
this._lastID = obj._id;
this._db._getExtraInfo("Inserted");
}
> db.user.save
function (obj) {
if (obj == null || typeof obj == "undefined") {
throw "can't save a null";
}
if (typeof obj == "number" || typeof obj == "string") {
throw "can't save a number or string";
}
if (typeof obj._id == "undefined") {
obj._id = new ObjectId;
return this.insert(obj);
} else {
return this.update({_id:obj._id}, obj, true);
}
}
ä¸é¢æ¯ pythonéçå®ç°åmongoæå
¥æ°æ®ç代ç
import pymong
logItems =[]
logItems.append({"url":
http://ww1.site.com/"ï¼"time":0.2})
logItems.append({"url":
http://ww2.site.com/"ï¼"time":0.12})
logItems.append({"url":
http://ww3.site.com/"ï¼"time":0.24})
def addLogToMongo(db,logItems):
#建ç«ä¸ä¸ªå°mongoæ°æ®åºçè¿æ¥
con = pymongo.MongoClient(db,27017)
#è¿æ¥å°æå®æ°æ®åº
db = con.my_collection
#ç´æ¥æå
¥æ°æ®,logItemsæ¯ä¸ä¸ªå表åéï¼å¯ä»¥ä½¿ç¨insertç´æ¥ä¸æ¬¡æ§åmongoDBæå
¥æ´ä¸å表ï¼å¦æç¨saveçè¯ï¼éä¸ä½¿ç¨foræ¥å¾ªç¯ä¸ä¸ªä¸ªæå
¥ï¼æçä¸é«
db.logDetail.insert(logItems)
'''
for url in logItems:
print(str(url))
db.logDetail.save(url)
'''