MongoDB常用操作

来源:https://www.cnblogs.com/quanee/archive/2019/10/19/11703548.html
-Advertisement-
Play Games

MongoDB 是一個基於分散式文件存儲的資料庫。由 C++ 語言編寫。旨在為 WEB 應用提供可擴展的高性能數據存儲解決方案。是一個介於關係資料庫和非關係資料庫之間的產品,是非關係資料庫當中功能最豐富,最像關係資料庫的。 指定文本編輯器 創建資料庫 查看所有資料庫 查看當前資料庫或集合db插入記錄 ...


MongoDB 是一個基於分散式文件存儲的資料庫。由 C++ 語言編寫。旨在為 WEB 應用提供可擴展的高性能數據存儲解決方案。是一個介於關係資料庫和非關係資料庫之間的產品,是非關係資料庫當中功能最豐富,最像關係資料庫的。

  • 指定文本編輯器

EDITOR="\"C:\\Program Files\\Sublime Text 3\\sublime_text.exe\""

  • 創建資料庫
use docname
  • 查看所有資料庫
show dbs
  • 查看當前資料庫或集合db插入記錄
db.docname.insert({key:value,key:value,...})
  • 查看集合
show collections
  • 查看當前操作集合及文檔
db.docname
  • 查看所有記錄
db.colname.find()
  • 查看單條記錄
db.colname.findOne()
  • 修改記錄
db.colname.update({key:value},{$set:{key:value,...}})
  • 刪除集合
db.colname.drop()
  • 刪除文檔
db.dropDatabases()
  • 查看當前資料庫參數
db.stats()
  • 幫助
db.help()
  • 命名db.getCollection("db-name").insert({...})

直接執行function insert(object){db.getCollection("colname").insert(objection)}

調用insert({key:value,...})

修改器指定一個鍵值對,存在鍵就修改,不存在就創建

$set{$set:{field:value}}
  • 為指定鍵的數字類型數值進行加減操作

\(inc{\)inc:{field:value}}

  • 刪除指定鍵

\(unset{\)set:{field:1}}

  • 指定鍵是數組就追加新的數值指定鍵不是數組則中斷當前操作指定鍵不存在則創建數組類型的鍵值對

\(push{\)push:{field:value}}

  • 批量添加數據

\(pushAll{\)pushAll:{field:array}}

  • 目標數組存在此項則不操作,不存在則添加

\(addToSet{\)addToSet:{field:value}}

  • 從指定數組刪除數據,1刪除最後一個,-1刪除第一個

\(pull{\)pull{field:value}}

  • 批量刪除

\(pullAll{\)pullAll{field:array}}

  • 數組定位器,只對數組中部分進行操作

{ "_id" : 4, "books" : [ { "type" : "js", "name" : "extjs4" }, { "type" : "js", "name" : "jquery" }, { "type" : "db", "name" : "mongodb" } ] }

db.student.update({"books.type":"js"},{\(set:{"books.\).count":152}})

  • 刪除記錄
db.colname.remove({field:value})

$addToSet與$each結合批量數組更新

db.colname.update({field:value},{$addToSet:{field:{$each:[value,...]}}})

runCommand可以執行MongoDB中的特殊函數

findAndModify(特殊函數)返回update或remove後的文檔

runCommand({"findAndModify":"processes",query:{查詢器},sort{排序},new:trueupdate:{更新器},remove:true})

EG:ps = db.runCommand({findAndModify:"student",query:{name:"maxkim"},update:{$set:{age:234}},new:true})

  • 查看返回值
ps.value
  • 查詢顯示 1,不顯示 0返回指定列
db.colname.find({field:{$...:...}},{_id:0, name:1,...})

$gte 大於等於

$gt 大於

$lte 小於等於

$lt 小於

$in 任意參數在引用集合里,則匹配

db.c2.find({age:{$in:[1,2,3]}})
  • $nin (not in)所有參數都不在引用集合里,則匹配

  • $all 所有參數在引用集合里,則匹配

  • $or 有一個條件匹配就成立
db.c2.find({$or:[{age:{$lt:5}},{age:{$gt:999995}}]})
  • $ne 不匹配參數條件

  • $not 不匹配結果

  • $exists 判斷元素是否存在

  • $slice 選擇返迴文檔的子集
db.product.find({},{reviews:{$slice:12}}) 
  • 返回前12條
db.product.find({},{reviews:{$slice:-5}}) 
  • 返回後5條

正則查詢

db.colname.find({field:/li/i},{field:0,...})

db.review.find({text:/best|worst/i})

db.review.find({text:{$regex:"best|worsst",$options:"i"}})
  • 索引
db.colname.find({field.n:value})$size 
  • 指定數組長度
db.persons.find({books:{$size:4}},{_id:0, books:1})
  • 添加欄位
db.persons.update({},{$set:{field:n}},false,true)
  • 改變更新方式
db.persons.update({},{$push:{field:"value"},$inc:{field:1}})
  • 索引1為正序 -1為倒序
db.books.ensureIndex({number:1})
  • 索引命名
db.books.ensureIndex({name:1},{name:"new_name"})
  • 唯一索引
db.books.ensureIndex({name:-1},{unique:true})
  • 剔除重覆值
db.books.ensureIndex({name:-1},{unique:true,dropDups:true})
  • 使用指定索引查詢
db.books.find({name:"",number:1}).hint({name:-1})
  • 查看查詢使用索引及查詢數據狀態信息(分析查詢性能)
db.books.find({name:"",number:1}).explain
  • 刪除索引
db.runCommand({dropIndexes:"books", index:"name_1"})
  • 刪除所有索引
db.runCommand({dropIndexes:"books", index:"*"})
  • 匹配子文檔.
db.users.find({'addresses.name':"home"}).pretty()

$elemMatch 
  • 所有詞語在相同的子文檔中,則匹配
db.users.find({addresses:{$elemMatch:{name:"home",state:"NY"}}})
  • $size 子文檔數組大小與提供的文本值相同,則匹配
db.users.find({address:{$size:3}})
  • $where 執行任意JavaScript來選擇文檔
db.reviews.find({$where:"this.helpful_votes>3"})

2D查詢數據

var map = [{ "gis" : { "x" : 185, "y" : 150 }},{ "gis" : { "x" : 70, "y" : 180 }},{ "gis" : { "x" : 75, "y" : 180 }},{ "gis" : { "x" : 185, "y" : 185 }},{ "gis" : { "x" : 65, "y" : 185 }},{ "gis" : { "x" : 50, "y" : 50 }},{ "gis" : { "x" : 50, "y" : 50 }},{ "gis" : { "x" : 60, "y" : 55 }},{ "gis" : { "x" : 65, "y" : 80 }},{ "gis" : { "x" : 55, "y" : 80 }},{ "gis" : { "x" : 0, "y" : 0 }},{ "gis" : { "x" : 0, "y" : 200 }},{ "gis" : { "x" : 200, "y" : 0 }},{ "gis" : { "x" : 200, "y" : 200 }}]for(var i = 0;iprev.m){
prev.m = doc.m;
prev.name = doc.name;
prev.country = doc.country;
}
},
condition:{m:{$gt:90}} }}
)
  • 固定集合

  • 創建一個1000個位元組的固定集合,可以存儲10個文檔
db.createCollection("MyColl",{size:1000,capped:true,max:10})
  • 普通集合轉換固定集合
db.runCommand({convertToCapped:"persons",size:100000})
  • 反向排序,預設插入順序
db.MyColl.find().sort({$natural:-1})

GridFS

  • 上傳文件
mongofiles -d colname -l "localfile" put "filename"
  • 查看所有文件
mongofiles -d test list
  • 刪除文件
mongofiles -d test delete 'filename'
  • Eval(啟用)
db.eval("function(name){return name;}","uspcat")
  • 導出
mongoexport.exe -d test -c persons -o "D:\MongoDB\log\dump.json"
  • 導入
mongoimport.exe --db test --collection persons --file "D:\MongoDB\log\dump.json"
  • 運行時備份
mongodump.exe --host 127.0.0.1:27017 -d test -o "D:\MongoDB\log\test"
  • 運行時恢復
mongorestore.exe --host 127.0.0.1:27017 -d test "D:\MongoDB\log\test.json\test\"

fsync
  • 上鎖(use admin)
db.runCommand({fsync:1, lock:1})
  • 上鎖
db.currentOp()
  • 數據恢復
db.repairDatabase()
  • 添加用戶
 db.createUser({user:"pangdahai",pwd:"123",roles:
[{role:"readWriteAnyDatabase",db:"admin"}]})
Successfully added user: {
        "user" : "quanee",
        "roles" : [
                {
                        "role" : "readWriteAnyDatabase",
                        "db" : "admin"
                }
        ]
}
  • 添加許可權認證

  • auth
db.auth("username","password")
  • 刪除用戶
db.system.users.remove({user:"username"})
  • 查看所有用戶
db.system.users.find()
  • 用戶登錄

mongo 127.0.0.1:27017/username

主從複製

  • 主伺服器配置
master.conf

dbpath=D:\MongoDB\master

port = 8888

bind_ip = 127.0.0.1

master=true
  • 從伺服器配置
dbpath=D:\MongoDB\slave

port = 7777

bind_ip = 127.0.0.1

source = 127.0.0.1:8888 #主伺服器數據源

slave = true
  • 主伺服器運行
db.getMongo().setSlaveOk();
(rs.setSlaveOk())
  • 索引碎片整理
db.values.reIndex()
  • 查詢分析器開啟
db.setProfilingLevel(2)
  • 強制使用指定索引
hing({indexname:1})
  • 通配符

$** 匹配任意欄位中包含的字元串

-- 解析字元串>>>刪除分詞>>>匹配詞乾

-- 關鍵字使用雙引號包含,必須匹配含有雙引號的短語

db.books.find({$text:{$search:'"books"'}})  匹配含有books的短語
  • 排除單詞
db.books.find({$text:{$search:'mongodb -second'}}) 搜索匹配mongodb但不包含second的短語
  • 排除文檔
db.books.find({$text:{$search:'mongodb -"second"  '}}) 搜索匹配mongodb但不包含second的文檔
  • 分配權重(預設為1,其他值為被髮現的概率的倍數,即對索引的影響)
db.books.createIndex(
{'$**': 'text'},<--使用字元串索引索引所有欄位
{weights:
{title: 10, <---為欄位指定1以外的權重
dategories:5}
}
)
  • 在索引里指定語言
db.books.createIndex(
{'$**':'text'},
{weights:
{title:10,
categories:5},
name:'index_name',
default_language:'french'
}
)

切換存儲引擎到WiredTiger

  • 設置配置文件YAML
storage:
dbpath:"/data/db"   資料庫存儲路徑
joural:
enabled:true    是否啟用日誌,預設true
engine:"wiredTiger" 存儲引擎,預設mmapv1
wiredTiger:
engineConfig:
cacheSizeGB:8   使用記憶體大小,預設是物理記憶體的一半,至少1G
journalCompressor:none  日誌壓縮器,預設snappy, 設置為none獲取最佳性能
collectionConfig:
blockCompressor:none    集合數據壓縮器(none,snappy,zlib)
indexConfig:
prefixCompression:false 是否為索引使用壓縮
collection.aggregate(pipeline)
pipline=[{$match:?},
{$group:?},
{$sort:?},
{$limit:?},
{$skip:?},
{$unwind:?},
{$redact:?},
{$sample:?},
{$out:?}
]
  • $match:選擇24號發佈的商品且交易時長為三天的商品

  • $group:打組。實際上是求和、平均等計算性的打組

  • 按照price進行分組,每相同price的加1,即求每種價格出現的次數

  • $sort:對'counts'進行排序,-1代表從高到低排序,1代表順序

  • $limit:和find中limit一樣+

  • $price相當於把原始數據中price勾過來
pipeline = [
{'$match':{'$and':[{'pub_date':'2016.12.24'},{'time':3}]}},
{'$group':{'_id':'$price','counts':{'$sum':1}}},
{'$sort' :{'counts':-1}},
{'$limit':10}
]
  • '\(slice':['\)cates',2,1] 2表示跳過兩個,選擇第三個

  • '$group'更新_id 新建 counts欄位

  • 按照count欄位排序
pipeline2 = [
{'$match':{'$and':[{'pub_date':'2015.12.24'},{'time':3}]}},
{'$group':{'_id':{'$slice':['$cates',2,1]},'counts':{'$sum':1}}},
{'$sort':{'counts':-1}}
]
  • 調用aggregate函數
item_info.aggregate(pipeline)

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • https://www.jb51.net/article/82608.htm https://blog.csdn.net/taian1665/article/details/86492400 https://blog.51cto.com/bantu/1982399 https://blog.csdn ...
  • 今日工作:資料庫連接、數據寫入 一、資料庫連接:使用了pymysql庫 二、數據寫入 代碼部分結束,雖然今天的代碼看起來又少又容易,但sql語句可真是廢了不少力氣。 最終資料庫成果,總共1729條數據: ...
  • 1. 鎖分類 MySQL中主要分為全局鎖、表級鎖和行鎖三類。本篇主要涉及全局鎖和表級鎖。 2. 全局鎖 全局鎖是對整個資料庫實例進行加鎖。 Flush table with read lock(FRTWRL)該命令用於加全局鎖。使用該命令之後,整個庫處於只讀狀態,不能執行數據的增刪改查、建表、修改表 ...
  • 列的查詢 語法1-1 基本的SELECT語句 SELECT <列名>,... FROM <表名>; 語法1-2 查詢出表中所有的列 SELECT * FROM <表名>; 星號(*)是代表全部列的意思。使用星號無法設定列的顯示順序。 語法1-3 1.為列設定別名 eg:SELECT product_ ...
  • 作為一名應用系統開發人員,為什麼要關註數據內部的存儲和檢索呢?首先,你不太可能從頭開始實現一套自己的存儲引擎,往往需要從眾多現有的存儲引擎中選擇一個適合自己應用的存儲引擎。因此,為了針對你特定的工作負載而對資料庫調優時,最好對存儲引擎的底層機制有一個大概的瞭解。 今天我們就先來瞭解下關係型資料庫My ...
  • 前言 當我們在Redis資料庫中set一個KV的時候,這個KV保存在哪裡?如果我們get的時候,又從哪裡get出來。時間複雜度,空間複雜的等等,怎麼優化等等一系列問題。 伺服器中的資料庫 Redis伺服器將所有資料庫信息都保存在redis.h##redisService結構體中。代碼如下: 列了幾個 ...
  • 1. 外鍵(foreign key) 1. 定義:讓當前表欄位的值在另一個表的範圍內選擇 2. 語法 foreign key(參考欄位名) references 主表(被參考欄位名) on delete 級聯動作 on update 級聯動作 3. 使用規則 1. 主表、從表欄位數據類型要一致 2. ...
  • 1. 表欄位的操作 1. 語法: alter table 表名 執行動作; 2. 添加欄位(add) alter table 表名 add 欄位名 數據類型; alter table 表名 add 欄位名 數據類型 first; alter table 表名 add 欄位名 數據類型 after 字 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...