scala 操作mongodb
介紹
Scala是一種函數式面向對象語言，它融匯了許多前所未有的特性，而同時又運行于JVM之上。隨著開發者對Scala的興趣日增，以及越來越多的工具支持，無疑Scala語言將成為你手上一件必不可少的工具。
MongoDB是一個介于關系數據庫和非關系數據庫之間的產品，是非關系數據庫當中功能最豐富，最像關系數據庫的。他支持的數據結構非常松散，是類似json的bson格式，因此可以存儲比較復雜的數據類型。Mongo最大的特點是他支持的查詢語言非常強大，其語法有點類似于面向對象的查詢語言，幾乎可以實現類似關系數據庫單表查詢的絕大部分功能，而且還支持對數據建立索引。
在本文中，我們將介紹使用 Scala語言如何與 Mongodb進行連接與數據處理。
環境安裝與配置
第一， 安裝Mongodb和Scala，如果已經安裝，可以跳過這一步。具體安裝步驟請自行搜索。
第二， 安裝SBT，SBT是Scala中的構建工具，作用相當于Maven。安裝比較簡單，具體步驟請參考：http://www.scala-sbt.org/0.13/tutorial/zh-cn/Setup.html
第三， 等安裝完成后，在控制臺執行sbt命令，出現類似以下的信息就可以了：
[root@centos6 scala-project]# sbt
[info] Loading global plugins from /root/.sbt/0.13/plugins
[info] Set current project to Casbah Tutorial (in buildfile:/home/apache/src/scala-project/)
>
第四：創建一個測試項目，并加載Casbah庫，Casbah是Mongodb的scala driver
mkdir test-project
cd test-project
vi build.sbt，輸入：
name := "Casbah Test"
version := "1.0"
scalaVersion := "2.11.2"
libraryDependencies += "org.mongodb" %% "casbah"% "2.7.3"
注意：build.sbt文件中每行要有一個空行分割。
如有問題請參考http://mongodb.github.io/casbah/guide/installation.html
完成后輸入命令：sbtconsole，第一次運行會自動下載casbah及依賴的其它庫，加載完成后如下類似如下的信息就可以了。
Welcome to Scala version 2.11.2 (Java HotSpot(TM) 64-Bit Server VM,Java 1.7.0_13).
Type in expressions to have them evaluated.
Type :help for more information.
scala>
連接Mongodb
加載scala shell：sbt console
importcom.mongodb.casbah.Imports._
val mongoClient= MongoClient("localhost", 27017)
注意：可以在控制臺輸入mongoClient. + 空格鍵，系統會自動提示可用的操作。
支持多種連接方式：
1. 簡單方式
// Connect to default - localhost, 27017
val mongoClient = MongoClient()
// connect to "mongodb01" host, default port
val mongoClient = MongoClient("mongodb01")
// connect to "mongodb02" host, port 42017
val mongoClient = MongoClient("mongodb02", 42017)
2. URI方式
val uri = MongoClientURI("mongodb://localhost:27017/")
val mongoClient = MongoClient(uri)
3. 支持權限驗證方式
//Challenge Response
valserver = new ServerAddress("localhost", 27017)
valcredentials = MongoCredential.createMongoCRCredential(userName, database,password)
valmongoClient = MongoClient(server, List(credentials))
// X.509Protocol
valserver = new ServerAddress("localhost", 27017)
valcredentials = MongoCredential.createMongoX509Credential(userName)
valmongoClient = MongoClient(server, List(credentials))
…
更多連接信息，請參考：http://mongodb.github.io/casbah/guide/connecting.html
我們在Mongodb中創建一個test_db的數據庫和test collection,并選擇簡單的用戶密碼方式，如下：
val server = newServerAddress("localhost", 27017)
val credentials =MongoCredential.createMongoCRCredential(“user”, “test_db”, “pass”.toArray)
val mongoClient= MongoClient(server, List(credentials))
出現類似如下信息即連接成功：
res2:com.mongodb.casbah.MongoClient = com.mongodb.casbah.MongoClient@42143c61
獲取數據庫和連接：
val db = mongoClient("test_db")
db.collectionNames
val coll = db("test")
增刪改查操作
增加
val user1 = MongoDBObject("name"-> "user1")
val user2 = MongoDBObject("name"-> "user2")
coll.insert(user1)
coll.insert(user2)
讀取
coll.count() //讀取總記錄數
也可以使用find讀取記錄，比如讀取所有記錄并打印出來：
coll.find().foreach(println)
val query1 =MongoDBObject("name"->"user1")
coll.findOne(query1)
更新
val update1 =MongoDBObject("email"->"user1@test.com")
val result1 = coll.update(query1,update1)
println( "Number updated: " +result.getN )
或者val result = coll.update( query, update, upsert=true )//upsert=true,如果不存在就insert
刪除
val query2 = MongoDBObject(“name”->”user2”)
val result2 = coll.remove(query2)
刪除集合
coll.drop()
更多用法請參考casbah的用戶文檔http://mongodb.github.io/casbah/index.html