MongoDB的賬戶與權限管理及在Python與Java中的登錄

本文主要介紹了MongoDB的賬戶新建，權限管理（簡單的），以及在Python，Java和默認客戶端中的登陸。

默認的MongoDB是沒有賬戶權限管理的，也就是說，不需要密碼即可登陸，即可擁有讀寫的權限（當然，重啟服務還是需要在本機執行）。
這個對於自己做實驗室足夠使用的，但是對於開放數據給他人使用時很不安全的，倒不是怕竊取數據，主要是怕某些豬隊友一下把db給drop了，如果沒有容災備份哭都來不及。
對於MongoDB的權限配置，我看着官方文檔和別人的筆記也算是踩過坑的人了，把踩過的坑寫出來給大家看一下，減少別人踩坑的次數。主要踩的坑還是集中在不同的語言的登陸上，這一方面資料比較少。

首先切換到admin數據庫
 use admin 
然后創建一個超級用戶，其中user和pwd的值可以自己隨便定義。

db.createUser(
  {
    user: "super_user",
    pwd: "super_user_paasswd",
    roles: [ { role: "__system", db: "admin" } ]
  }
)

 

隨后我們新建兩個用戶，一個具有讀寫權限，一個只有讀取的權限。
讀寫權限的賬號給所有需要寫數據的服務和程序使用，讀取的賬號給同事查看和聚集數據的時候使用。

//新建讀賬號
db.createUser( { 
    "user" : "rouser",//賬號名稱
    "pwd": "rouserpwd",//密碼
    "customData" : {
        //注釋
        user_abs:"read-only user for data analysis" 
    },
    "roles" : [ 
        {
            role: "readAnyDatabase",//讀所有數據庫
            db: "admin"
        } 
    ]
    },{ 
        w: "majority" , 
        wtimeout: 5000 
    } 
)
//新建讀寫賬號
db.createUser( { 
    "user" : "rwuser",//賬號名稱
    "pwd": "rwuser_pwd",//密碼
    "customData" : { //注釋
        user_abs:"read-write user for data extractor" 
    },
    "roles" : [ 
        {
            role: "readWriteAnyDatabase",//讀寫所有數據庫
            db: "admin"
        } 
    ]
    },{ 
        w: "majority" , 
        wtimeout: 5000 
    } 
)

 

創建完成以后，首先檢查一下是不是新建好了，簡單的說，就是看一下admin里面是不是記錄了你要的用戶賬戶：

db.getCollection("system.users").find({})

//輸出：
//實際輸入：db.getCollection("system.users").find({},{"credentials":0})
{ "_id" : "admin.super_user", "user" : "super_user", "db" : "admin", "roles" : [ { "role" : "__system", "db" : "admin" } ] }
{ "_id" : "admin.rouser", "user" : "rouser", "db" : "admin", "customData" : { "user_abs" : "read-only user for data analysis" }, "roles" : [ { "role" : "readAnyDatabase", "db" : "admin" } ] }
{ "_id" : "admin.rwuser", "user" : "rwuser", "db" : "admin", "customData" : { "user_abs" : "read-write user for data extractor" }, "roles" : [ { "role" : "readWriteAnyDatabase", "db" : "admin" } ] }

 

看到輸出了所有的賬戶信息，就OK了，下一步就是重新啟動服務，在重啟服務之前，需要在config文件中設置`auth = true`，這樣才會需要登錄，否則什么都沒變
以下是我的Config文件，最后一行是重新安裝服務的Command，如果沒有安裝過，使用--install參數即可：

#存放數據目錄
dbpath=F:\FeaturesData\data
#日志文件
logpath=F:\FeaturesData\mongo.log
#Cache Size
wiredTigerCacheSizeGB=1

auth = true
logappend = true
directoryperdb = true

#執行
# mongod --config "F:\FeaturesData\mongo.config" --serviceName "MongoDB" --reinstall

 

這樣啟動以后Mongo就有權限了，這個時候的登陸要使用賬號密碼：
 mongo" -u super_user -p super_user_paasswd --authenticationDatabase admin 127.0.0.1/test 
其中127.0.0.1/test是IP/數據庫名稱以連接默認數據庫。

這個時候你可以試一下使用只讀賬號刪庫或者刪集合，會出現drop failed: MongoError: not authorized on test to execute command

意味着你沒有權限刪除，這個時候不要說刪除，插入操作也是不能做的。

 

除了使用默認的客戶端連接，我們還可以使用其它語言的Driver去連接。

這里考慮使用Python和Java兩種情況
首先考慮在Python中的連接，我們使用URI登陸：

try:# Python 3.x
    from urllib.parse import quote_plus
except ImportError:# Python 2.x
    from urllib import quote_plus
from pymongo import MongoClient

#Example
user = 'USER'
password = 'PASSWORD'
host = '127.0.0.1:27017'
#Code
uri = "mongodb://%s:%s@%s" % (
    quote_plus(user), quote_plus(password), host)
client = MongoClient(uri)

再考慮使用Java登陸（稍微麻煩一點）：

//這個是我自己封裝的讀取Properties文件的類
import com.zjtj.yuanyifan.Util.PropertiesUtil;

import com.mongodb.BasicDBObject;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;

private MongoCollection<Document> getMongoDBConnection() {
        //初始化Mongodb數據庫連接，變量名我想不需要解釋了
        PropertiesUtil pu = new PropertiesUtil();
        String vfdbname = pu.getPropString("vehicle_features_db_name", "vf");
        String vfdbip = pu.getPropString("vehicle_features_db_ip", "127.0.0.1");
        String vfdbport = pu.getPropString("vehicle_features_db_port", "27017");
        String vfdbuser = pu.getPropString("vehicle_features_db_user", "USER_HERE");
        String vfdbpwd  = pu.getPropString("vehicle_features_db_pwd", "PASSWD_HERE");
        try {
            
            ServerAddress sainfo = new ServerAddress(vfdbip, Integer.valueOf(vfdbport));
            List<MongoCredential> mgauth = new ArrayList<>();
            mgauth.add(MongoCredential.createCredential(vfdbuser,"admin",vfdbpwd.toCharArray()));
            MongoCollection<Document> mgdbc = new MongoClient(sainfo,mgauth).getDatabase(vfdbname).getCollection("daily_features");
            String dbgInfo = String.format("Connected to mongodb://%s:%s/%s/\n", vfdbip, vfdbport, vfdbname);
            System.out.printf(dbgInfo);
            fcc_log.info(dbgInfo);
            return mgdbc;
        } catch (Exception ex) {
            String errInfo = "Error while initializing MongoDB connection: " + ex.getMessage();
            System.err.println(errInfo);
            fcc_log.fatal(errInfo);
        }
    }