MongoDB

MongoDB

link

マニュアル

ドキュメント指向データベース

---

スキーマレス

---

• スキーマを定義しなくても利用できる
• スキーマレスのため保守性が高い
• JSON方式でデータを保持
• テーブルのことはコレクションと呼ぶ

パフォーマンス

---

• 機能制限により、高パフォーマンスを実現
• トランザクションがない
  • 処理速度がかなり高速
• 大量データの高速処理に向く
• スケールアウトが簡単な設定で可能

操作感

---

• RDBと似た操作
• 複雑な検索条件を利用できる

インストール

---

• https://docs.mongodb.com/manual/installation/

Ubuntu

---

• コミュニティエディション

ubuntu@puli-mon:~$ cat /etc/os-release 
NAME="Ubuntu"
VERSION="20.04.2 LTS (Focal Fossa)"
   :
ubuntu@puli-mon:~$ wget -qO - https://www.mongodb.org/static/pgp/server-4.4.asc | sudo apt-key add -
OK
ubuntu@puli-mon:~$ echo "deb [ arch=amd64,arm64 ] https://repo.mongodb.org/apt/ubuntu focal/mongodb-org/4.4 multiverse" | sudo tee /etc/apt/sources.list.d/mongodb-org-4.4.list
ubuntu@puli-mon:~$ sudo apt-get update
ubuntu@puli-mon:~$ sudo apt-get install -y mongodb-org

ディレクトリ

---

種類	場所	備考
データ	/var/lib/mongodb
ログ	/var/log/mongodb
設定	/etc/mongod.conf

開始

---

ubuntu@puli-mon:/etc$ sudo systemctl start mongod

• 失敗する場合

sudo systemctl daemon-reload

リモートホストから接続

---

• デフォルトでは、localhostからのみ接続可能なため、bindIp の行を変更
• $ sudo vi /etc/mongod.conf

# network interfaces
net:
  port: 27017
#  bindIp: 127.0.0.1
  bindIp: 0.0.0.0

monogoシェルの実行

---

ubuntu@puli-mon:/etc$ mongo
MongoDB shell version v4.4.6
connecting to: mongodb://127.0.0.1:27017/?
          :
---
> 

GUI

---

Robo 3T

---

• https://robomongo.org/download
• Only 3T

• 起動

データベース

データベース作成

---

• use で作成

> use testdb
switched to db testdb

• db。ｄろｐDatabase()　でカレントDBを削除

コレクションを作成

---

> db.createCollection("testDoc")
{ "ok" : 1 }

• 一覧を確認

> show dbs
admin   0.000GB
config  0.000GB
local   0.000GB
testdb  0.000GB

ドキュメントの登録

---

• testDocは、コレクション

> db.testDoc.insertOne(
... {name:"Foo",value:"Bar"}
... )
{
	"acknowledged" : true,
	"insertedId" : ObjectId("609f57392efac2b731a534eb")
}

検索

---

• find

> db.testDoc.find()
{ "_id" : ObjectId("609f57392efac2b731a534eb"), "name" : "Foo", "value" : "Bar" }

DB統計

---

> db.stats()
{
	"db" : "testdb",
	"collections" : 1,                       // コレクション数
	"views" : 0,    
	"objects" : 1,
	"avgObjSize" : 51,
	"dataSize" : 51,                       //　圧縮前データサイズ
	"storageSize" : 20480,
	"indexes" : 1,                           //　インデックス数
	"indexSize" : 20480,             //　インデックスデータ量
	"totalSize" : 40960,
	"scaleFactor" : 1,
	"fsUsedSize" : 2561937408,
	"fsTotalSize" : 20629221376,
	"ok" : 1
}

コレクション

種類	コマンド	例
コレクションの作成	db.createCollection(コレクション名)	db.createCollection("testCollection")
コレクションの一覧表示	show collections
統計情報表示	db.collection.stats()
コレクションの削除	db.collection.drop()	db.testCollection.drop

Cappedコレクション

---

• コレクションに入れられるデータの上限を設定
• データ量が上限になると、古いドキュメントから削除されていく
• レプリカセットでは、Cappedコレクションを使ってデータを同期している
• createCollection のオプションを変更して作成

db.createCollection(
  "コレクション名",
  [capped: true, size:  データ上限(バイト)サイズ]
)

登録

方法	コマンド	例
1件登録	db.collection.insertOne({...})	db.testCollection.insertOne({key:"1",value:"a"})
複数登録	db.collection.insertMany([ {...}, {...} ])	db.testCollection.insertMany([ {key:2,value:"b"}, {key:3,value:"c"} ])

検索

方法	コマンド	例
全件	db.collection.find()	db.testCollection.find()
フィールドを指定	db.collection.find( {検索条件}, {key1:0,kye2:1,...} ) //key1を非表示、key2を表示	db.testCollection.find( {key:2}, {_id:0,key:1,value:1} )
完全一致	{key:value}
部分一致	{key:/value/}
前方一致	{key:/^value/}
後方一致	{key:/value$/}
以下	{key:{$lte:value}}
未満	{key:{$lt:value}}
以上	{key:{$gte:value}}
より大きい	{key:{$gt:value}}
範囲指定	{key:{$gte:value1, $lte:value2}}
and	{$and:[ {key1:value1}, {key2:value2} ]}
or	{$or:[ {key1:value1}, {key2:value2} ]}
null	{key:null} 以下が検索される 1.データ型がNull 2.フィールドなし 3.undefined
フィールドの存在有無($exists)	{ key: {$exists: false}}
データ型を指定($type)	{key:{$type:"null"}} // Null型を指定して検索
ソート	db.collection.find().sort({...}) // 1:昇順,-1:降順	db.testCollection.find().sort( {key:-1} )
件数	db.collection.find().count()

更新

方法	コマンド	例
1件ドキュメントを更新	db.collection.updateOne( {検索条件}, {$set:{更新内容}} )	一致するデータが複数あっても、1件しか更新されない db.testCollection.updateOne( {key:"1"}}, {$set:{value2:"v2"}} )
複数件のドキュメントを更新	db.collection.updateMany( {検索条件}, {$set:{更新内容}} )	更新に一致したドキュメントを全て更新 db.testCollection.updateMany( {key:{$lt:4}}, {$set:{value2:"v2"}} )
ドキュメントの置き換え	db.collection.replaceOne( {検索条件} {更新内容} )	入れ替えられるのは1件だけ db.testCollection.replaceOne( {key:"1"}, {key:1, value:"a", value2:"v1"} )
フィールド名を変更	$rename 旧Key:"新Key"	db.testCollection.updateMany( {}, {$rename:{value:"val1"}} )
配列のインデックス	フィールド名.n	{$set:{"ary.3":"hoge"}}
登録または更新(upsert)	db.collection.updateOne( {検索条件}, {更新内容}, {upsert: true} )

削除

方法	コマンド	例
1件削除	db.collection.deleteOne({検索条件})	複数件一致しても、削除されるのは1件
複数件削除	db.collection.deleteMany({検索条件})

集計

• findで集計はできないため、aggregationメソッドを利用する

集計	集計関数	例
最大値	$max
最小値	$min
平均値	$avg

簡単な集計

---

db.collection.aggregate([
  { $match:{<検索条件>}},
  { $group:{ _id::"$<集計フィールド>",<集計結果表示名>:{<集計関数>:"$集計フィールド"}}}
])

基本

• • $group に 指定した _id　フィールドごとに集計を行う
  • "$フィールド名"と入力する
  • 集計関数 $sumを指定、複数指定も可能

db.getCollection("O1").aggregate([
    { $match: { 'head.MakeDate.Year':{ '$gt':'2010', '$lt':'2020' }} },
    { $group: { _id:'$head.MakeDate.Year', tosu: {'$sum':{ '$toInt': '$TorokuTosu' }}} }
])

グループ化のあとに、さらに条件を適用

db.getCollection("O1").aggregate([
    { $match: { 'head.MakeDate.Year':{ '$gt':'2010', '$lt':'2020' }} },
    { $group: { _id:'$head.MakeDate.Year', tosu: {'$sum':{ '$toInt': '$TorokuTosu' }}} },
    { $match: { 'tosu' : { '$gt': 49000 }} } 
])

集計関数を複数同時に使用

db.getCollection("O1").aggregate([
    { $match: { 'head.MakeDate.Year':{ '$gt':'2010', '$lt':'2020' }} },
    { $group: { _id:'$head.MakeDate.Year', 
        tosu_total: {'$sum':{ '$toInt': '$TorokuTosu' }},
        tosu_max: {'$max':{ '$toInt': '$TorokuTosu' }},
        tosu_min: {'$min':{ '$toInt': '$TorokuTosu' }},
        tosu_avg: {'$avg':{ '$toInt': '$TorokuTosu' }} }}
])

Tips

stringをintに変換

db.getCollection('O1').find({},{tosu:{ '$toInt': '$TorokuTosu' }})

プログラミング

C#

---

• C# MongoDriver

Insert

---

using MongoDB.Driver;
   :
var client = new MongoClient("mongodb://puli-mon.local");
var mongoDb = client.GetDatabase("jra");
var colH1 = mongoDb.GetCollection<JV_H1_HYOSU_ZENKAKE>("h1");
   :
colH1.InsertOne(rec);