2. 程式人生 > >Mongodb的簡單操作方法

Mongodb的簡單操作方法

阿新 • • 發佈：2018-12-24

    MongoDB資料庫屬於一種非關係型的資料庫，對資料的儲存主要是以鍵值對的方式儲存，而且在很大程度上提高了資料的存取時間和效率，簡單總結了下Mongodb的操作方法。

首先我是使用samus驅動實現基本資料操作，在這裡首先下載驅動MongoDB.dll和MongoDB.GridFS.dll。下面是詳細的使用方法，程式碼是從vs裡面直接copy過來的，沒整理，基本都有說明。

 Mongo mongo = new Mongo("mongodb://localhost");

 MongoDatabase mongodb = mongo.GetDatabase("test") as MongoDatabase

; //定義全域性

#region 使用泛型類操作

        ///<summary>

        /// Add

        ///</summary>

        ///<param name="sender"></param>

        ///<param name="e"></param>

        protected void Button1_Click(object sender, EventArgs e)

        {

            //新增

            List<Student> std = new

List<Student>()

            {

                new Student(){ Age = 20, NikeName = "", Sex = true, UserName = "cpg"},

                new Student(){ Age = 33, NikeName = "", Sex = false, UserName = "lfd"}

            };

            MongoCollection<Student> collection = mongodb.GetCollection<Student

>() as MongoCollection<Student>;

            mongo.Connect();

            collection.Insert(std);

            mongo.Disconnect();

        }

        ///<summary>

        /// Get

        ///</summary>

        ///<param name="sender"></param>

        ///<param name="e"></param>

        protected void Button2_Click(object sender, EventArgs e)

        {

            //獲取

            MongoCollection<Student> col = mongodb.GetCollection<Student>() as MongoCollection<Student>;

            mongo.Connect();

            List<Student> list = col.FindAll().Documents.ToList();

            //Student std = col.FindOne(p => p.Age == 23);//獲取一個

            mongo.Disconnect();

        }

        ///<summary>

        /// Edit

        ///</summary>

        ///<param name="sender"></param>

        ///<param name="e"></param>

        protected void Button3_Click(object sender, EventArgs e)

        {

            Student std = new Student() { Sex = false, Age = 100, UserName = "fishangle", NikeName = "" };

            MongoCollection<Student> col = mongodb.GetCollection<Student>() as MongoCollection<Student>;

            mongo.Connect();

            col.Update(std, p => p.UserName == "cpg");//修改匹配到的第一個（從後往前）

            List<Student> list = col.FindAll().Documents.ToList();

            mongo.Disconnect();

        }

        ///<summary>

        /// Del

        ///</summary>

        ///<param name="sender"></param>

        ///<param name="e"></param>

        protected void Button4_Click(object sender, EventArgs e)

        {

            MongoCollection<Student> col = mongodb.GetCollection<Student>() as MongoCollection<Student>;

            mongo.Connect();

            col.Remove(p => p.Sex == true);//刪除指定的（匹配的都將刪除）

            //col.Remove(x => true);//刪除全部

            mongo.Disconnect();

        }

#endregion

#region 一般操作 (一般操作在獲取集合時必須有一個預設的CollectionName

        ///<summary>

        /// Add

        ///</summary>

        ///<param name="sender"></param>

        ///<param name="e"></param>

        protected void Button5_Click(object sender, EventArgs e)

        {

            MongoCollection<Document> col = mongodb.GetCollection<Document>("mongoCollection") as MongoCollection<Document>;

            mongo.Connect();

#region 單個插入

            Document doc = new Document();

            doc["Id"] = 1;

            doc["name"] = "池鵬剛";

            col.Insert(doc);

#endregion

#region 多個插入

            List<Document> list = new List<Document>()

            {

                new Document(){{"Id",1},{"name","cpg1"}},

                new Document(){{"Id",2},{"name","cpg2"}},

                new Document(){{"Id",3},{"name","cpg3"}}

            };

            col.Insert(list);

            List<Document> dtAll = col.FindAll().Documents.ToList();

#endregion

            mongo.Disconnect();

        }

        ///<summary>

        /// get

        ///</summary>

        ///<param name="sender"></param>

        ///<param name="e"></param>

        protected void Button6_Click(object sender, EventArgs e)

        {

            MongoCollection<Document> col = mongodb.GetCollection<Document>("mongoCollection") as MongoCollection<Document>;

            mongo.Connect();

            List<Document> dtAll = col.FindAll().Documents.ToList();

            var dtOne = col.FindOne(new Document() { { "Id", 1 } });//發現id為1的doc

            var name = dtOne["name"];//取出此doc中的name值

            mongo.Disconnect();

        }

        ///<summary>

        /// del

        ///</summary>

        ///<param name="sender"></param>

        ///<param name="e"></param>

        protected void Button8_Click(object sender, EventArgs e)

        {

            MongoCollection<Document> col = mongodb.GetCollection<Document>("mongoCollection") as MongoCollection<Document>;

            mongo.Connect();

            List<Document> dtAll = col.FindAll().Documents.ToList();

            //col.Remove(p => true);//刪除全部

            col.Remove(new Document() { { "Id", 1 } });//匹配的都將刪除

            List<Document> dtAlls = col.FindAll().Documents.ToList();

            mongo.Disconnect();

        }

        ///<summary>

        /// update

        ///</summary>

        ///<param name="sender"></param>

        ///<param name="e"></param>

        protected void Button7_Click(object sender, EventArgs e)

        {

            MongoCollection<Document> col = mongodb.GetCollection<Document>("mongoCollection") as MongoCollection<Document>;

            mongo.Connect();

            List<Document> dtAll = col.FindAll().Documents.ToList();

            Document doc = new Document();

            doc["Id"] = 1;

            doc["name"] = " 曉風殘月";

            col.Update(doc, new Document() { { "Id", 1 } });

            List<Document> dtAlls = col.FindAll().Documents.ToList();

            mongo.Disconnect();

        }

#endregion

#region 檔案操作

        protected void Button9_Click(object sender, EventArgs e)

        {

            string fileName = FileUpload1.FileName;

            byte[] byteFile = FileUpload1.FileBytes;

            Stream stream = FileUpload1.FileContent;

            string name = Guid.NewGuid().ToString();

            //這裡GridFile建構函式有個過載，bucket引數就是用來替換那個建立集合名中預設的"fs"的。

            mongo.Connect();

            GridFile gridFile = new GridFile(mongodb, "img");

            using (GridFileStream gridFileStream = gridFile.Create(fileName))

            {

                gridFileStream.Write(byteFile, 0, byteFile.Length);

            }

            mongo.Disconnect();

        }

        protected void Button10_Click(object sender, EventArgs e)

        {

            string filename = "圖片1.jpg";

            mongo.Connect();

            GridFile gridFile = new GridFile(mongodb, "img");

            GridFileStream gridFileStream = gridFile.OpenRead(filename);

            byte[] bytes = new byte[gridFileStream.Length];

            gridFileStream.Read(bytes, 0, bytes.Length);

            mongo.Disconnect();

        }

#endregion

#region 索引

        protected void Button12_Click(object sender, EventArgs e)

        {

#region 新增索引

            // 1. 預設索引

            //MongoDB有個預設的“_id”的鍵，他相當於“主鍵”的角色。集合建立後系統會自動建立一個索引在“_id”鍵上，

            //它是預設索引，索引名叫“_id_”，是無法被刪除的。我們可以通過以下方式檢視：

            MongoCollection<Document> mongoCollection = mongodb.GetCollection<Document>("mongoCollection") as MongoCollection<Document>;

            mongo.Connect();

            var _idIndex = mongoCollection.Metadata.Indexes.Single(x => x.Key == "_id_");

            Console.WriteLine(_idIndex);

            // 2. 單列索引

            //在單個鍵上建立的索引就是單列索引，例如我們要在“UserInfo”集合上給“UserName”鍵建立一個單列索引，語法如下：（1表示正序，-1逆序）

            mongoCollection.Metadata.CreateIndex(new Document { { "name", 1 } }, false);

            //接著，我們用同樣方法查詢名為“_UserName_”的索引

            var _UserName_Index = mongoCollection.Metadata.Indexes.Single(x => x.Key == "_name_");

            Console.WriteLine(_UserName_Index);

            // 3.組合索引

            //另外，我們還可以同時對多個鍵建立組合索引。如下程式碼建立了按照“UserId”正序，“UserName”逆序的組合索引:

            mongoCollection.Metadata.CreateIndex(new Document { { "Id", 1 }, { "name", -1 } }, false);

            // 4.子文件索引

            //　我們可以對文件型別的鍵建立各種索引，例如單列索引，如下建立使用者詳細資訊“Detail”的單列索引：

            mongoCollection.Metadata.CreateIndex(new Document { { "Detail", 1 } }, false);

            //對子文件的鍵建立組合索引：例如在“Detail.Address”和“Detail.Age”上建立組合索引：

            mongoCollection.Metadata.CreateIndex(new Document { { "Detail.Address", 1 }, { "Detail.Age", -1 } }, false);

            // 5.唯一索引

            //　唯一索引限制了對當前鍵新增值時，不能新增重複的資訊。值得注意的是，當文件不存在指定鍵時，會被認為鍵值是“null”，

            //所以“null”也會被認為是重複的，所以一般被作為唯一索引的鍵，最好都要有鍵值對。

            //　對“UserId”建立唯一索引(這時候最後一個引數為“true”)：

            mongoCollection.Metadata.CreateIndex(new Document { { "UserId", 1 } }, true);

#endregion

#region 得到索引

            var allIndex = mongoCollection.Metadata.Indexes;//獲取所有索引

#endregion

#region 刪除索引

            var listIndexes = mongoCollection.Metadata.Indexes.ToList();//得到所有索引

            for (int i = 0; i < listIndexes.Count; i++)

            {

                if (listIndexes[i].Key != "_id_")

                {

                    mongoCollection.Metadata.DropIndex(listIndexes[i].Key);

                }

            }

#endregion

        }

        protected void Button13_Click(object sender, EventArgs e)

        {

            Mongo mg = new Mongo("mongodb://localhost");

            MongoDatabase mongoIndex = mg.GetDatabase("mongoIndex") as MongoDatabase;

            MongoCollection<Document> col = mongoIndex.GetCollection<Document>("indexCollection") as MongoCollection<Document>;

            mg.Connect();

            col.Insert(getList());

            mg.Disconnect();

        }

        ///<summary>

        ///初始化集合

        ///</summary>

        ///<returns></returns>

        public List<Document> getList()

        {

            List<Document> docList = new List<Document>();

            for(int i=0;i<10000;i++)

            {

                docList.Add(new Document() { { "ID", i }, { "Class", "grade" + i }, { "std", new Student() { UserName = "user" + i, Age = i + 20, NikeName = "", Sex = (i % 2 == 0 ? true : false) } } });

            };

            return docList;

        }

        protected void Button14_Click(object sender, EventArgs e)

        {

            Mongo mg = new Mongo("mongodb://localhost");

            MongoDatabase mongoIndex = mg.GetDatabase("mongoIndex") as MongoDatabase;

            MongoCollection<Document> col = mongoIndex.GetCollection<Document>("indexCollection") as MongoCollection<Document>;

            mg.Connect();

            col.Metadata.CreateIndex(new Document { { "ID", 1 }, { "Class",1 } }, false);//加入索引 1表示正序 -1表示逆序

            Stopwatch sw = new Stopwatch();

            sw.Start();

            List<Document> docList = col.FindAll().Documents.ToList();

            sw.Stop();

            mg.Disconnect();

            Label1.Text = sw.ElapsedMilliseconds.ToString();

        }

        protected void Button15_Click(object sender, EventArgs e)

        {

            Mongo mg = new Mongo("mongodb://localhost");

            MongoDatabase mongoIndex = mg.GetDatabase("mongoIndex") as MongoDatabase;

            MongoCollection<Document> col = mongoIndex.GetCollection<Document>("indexCollection") as MongoCollection<Document>;

            mg.Connect();

            //col.Metadata.CreateIndex(new Document { { "ID", 1 } }, false);

            Stopwatch sw = new Stopwatch();

            sw.Start();

            List<Document> docList = col.FindAll().Documents.ToList();

            sw.Stop();

            mg.Disconnect();

            Label2.Text = sw.ElapsedMilliseconds.ToString();

        }

        protected void Button16_Click(object sender, EventArgs e)

        {

            Mongo mg = new Mongo("mongodb://localhost");

            MongoDatabase mongoIndex = mg.GetDatabase("mongoIndex") as MongoDatabase;

            MongoCollection<Document> col = mongoIndex.GetCollection<Document>("indexCollection") as MongoCollection<Document>;

            mg.Connect();

            Label3.Text = "";

            foreach (var index in col.Metadata.Indexes)//col.Metadata.Indexes 獲取所有索引

            {

                Label3.Text += index+"<br/>";

            }

        }

#endregion

以上程式碼僅供參考。

相關推薦

Mongodb的簡單操作方法

    MongoDB資料庫屬於一種非關係型的資料庫，對資料的儲存主要是以鍵值對的方式儲存，而且在很大程度上提高了資料的存取時間和效率，簡單總結了下Mongodb的操作方法。 首先我是使用samus驅動實現基本資料操作，在這裡首先下載驅動MongoDB.dll和MongoD

web自動化8-selenium簡單操作方法

bdr url isp nbt web selenium attr () 尺寸 1. 控制窗口大小 form selenium import webdriver driver = webdriver.Chrome() driver.get("http://www.ba

MongoDB簡單操作

class mil 管理 drop 刪除數據 iter inf dbms document MongoDB是一個基於 分布式 文件存儲的開源數據庫系統 在高負載的情況下,添加更多的節點,可以保證服務器性能 MongoDB將數據存儲為一個文檔,數據結構由鍵值(key=valu

視訊壓縮的簡單操作方法

視訊壓縮的簡單操作方法，我們在生活中經常會用到視訊檔案，有的時候因視訊太大導致視訊無法接收，那麼下面我就給大家簡單的介紹一下如何將視訊線上壓縮。1、 視訊線上壓縮可以直接點選文件處理，然後點選視訊壓縮即可；2、 進入之後就可以進行檔案的自定義了，可以根據自己壓縮視訊檔案的需要進行定義壓縮型別和輸出格式等；3、

視頻壓縮的簡單操作方法

images 如何 RoCE 方法 http ESS term src nag 視頻壓縮的簡單操作方法，我們在生活中經常會用到視頻文件，有的時候因視頻太大導致視頻無法接收，那麽下面我就給大家簡單的介紹一下如何將視頻在線壓縮。1、 視頻在線壓縮可以直接點擊文檔處理，然後點擊

安卓手機PDF轉圖片的簡單操作方法

有時候我們可能需要將手機的照片放在一起，然後轉換為PDF格式的檔案，現在不僅是電腦手機也可以實現了，徹底的解除了電腦的束縛，今天小編就將轉換的方法分享給大家。 轉換工具介紹：它是一款提供檔案格式轉換的辦公應用。支援一鍵完成PDF檔案與Office、HTML、TX

ThinkPHP下MongoDB的操作方法

<?php namespace Home\Controller; use Think\Controller; class IndexController extends Controller { public function mongo() { $model = D("

mongodb基本操作方法

一、mongodb簡介 mongodb屬於文件型資料庫，儲存的是文件（Bson->json的二進位制化）。我們熟知的MYSQL資料庫，它的資料是以表的形式儲存的，每條記錄都具有相同的結構，這樣使得查詢起來很方便，但是卻增加了空間的壓力；文件型資料庫如mo

mongoDB 簡單操作

一、新增資料庫 use DATABASE_NAME 例如：use tom _database 當tom _database不存在時會新建資料庫tom_databse，當tom_database存在時切換到tom_database資料庫。當前資料庫的名稱可以通過db命令檢視

對MongoDB簡單操作

展示資料庫：show dbs/databases //在show資料庫的時候，新建立的資料庫如果不給了裡邊新增資料，則show不出來。 建立資料庫：use 資料庫名稱 切換資料庫 ：use 資料庫名稱 刪除資料庫：db.dropDatabase(); //刪除資料庫時，不需

MongoDB簡單操作指令

1.db：檢視當前指向的資料庫 > db xubo 2.use：使用某個資料庫 > use test switched to db test > db test 3.show dbs：顯示有哪些資料庫及其大小 > show dbs loc

mongodb操作指令以及在node.js封裝mongodb的操作方法

1、啟動mongodb： cd path/mongodb/bin // 開啟命令列，切換到mongodb目錄下的bin目錄 mongod --dbpath path/mongodb/data/db // 設定p

IDEA的簡單操作方法

IntelliJ IDEA的安裝 想必下載按鈕大家都知道點哪（.exe是個下拉選單，自行選擇和自己電腦匹配的版本，例：.exe是windos平臺），安裝包開啟基本就是下一步下一步，那我就只補充下版本說明好了。  ①Community：免費的，僅有部分功能，因為能用Ma

node.js零基礎詳細教程(7)：node.js操作mongodb，及操作方法的封裝

font 裏的 ges 格式 上進 ins 方法 回調函數 方式 第七章 建議學習時間4小時 課程共10章 學習方式：詳細閱讀，並手動實現相關代碼 學習目標：此教程將教會大家 安裝Node、搭建服務器、express、mysql、mongodb、編寫後臺業務邏輯、編寫接口

C#中使用1.7版本驅動操作MongoDB簡單例子

text spa 自動 .get mongo ets lock www. 密碼 代碼如下: //創建數據庫鏈接 //在1.7的版本驅動中這樣寫是會報 MongoServer方法已過時的 //MongoServer server = MongoDB.Driver

使用Flask+MongoDB實現基於REST的接口簡單操作

服務器環境 互聯 utf 遇到的問題 like .exe 查找 提示信息 進入 目錄 前言 1 準備工作 2 具體實現 前言 最近在搗鼓如何使用阿裏雲服務器搭建一個簡單的基於Flask框架的後端接口，剛開始為了圖方便，就直接買了一個Wind

java對mongodb數據庫的簡單操作

odr 賦值 log 對象創建 tcollect dbo release content doc 準備工作： 　　下載好mongodriver.jar包（https://oss.sonatype.org/content/repositories/releases/org/m

MongoDB簡單使用-查詢操作2

reduce post ide trac 操作 ems ive like 系統 1查看當前數據庫的文檔 輸入： db.media.find() 系統返回：{ "_id" : ObjectId("5aa490f053350e04ddbd6fa6"), "Type" : "Bo

MongoDB簡單使用 —— 基本操作

ons mongo code mongdb b- 方式 檢查 簡潔 2.4 本身MongoDB直接支持的是Bson文檔，Bson文檔在C#的官方驅動中對應的是BsonDocument類： var bsonDoc = new BsonDocument(){ ["_id

C#簡單操作MongoDB

更新 builder ria ins 關系 date 轉換 客戶端 新的 一 安裝MongoDB 官網按需下載, 安裝, 一步到位. 二 VS創建新項目 創建一個.netcore console項目, 然後nuget安裝驅動MongoDB.Driver 三 建立連接