資訊平台: 6月 2016

Cassandra Nosql Database Play Framework for Scala

Cassandra是一個Open Source的Database，這幾年來越來越多人使用Nosql取代傳統式的Databse，Nosql Databse特點就是免費、分散式架構，比起一般傳統式的DB速度較快，可運用在Win Linux, Mac Os平台上，但缺點就是技術文件較少，需要自已研讀國外技術文件及研究API。

今天要介紹的是使用Docker虛擬化平台，建置簡易Cassnadra Database Login model , 首先安裝Docker，安裝完成Docker後至DockerHub下載Cassandra官方建置完成的Docker image。

1.下載Cassandra Docker Image

docker pull cassandra

2.啟動Cassandra，在啟動Cassandra之前記得開啟對外Port，否則無法連線至Cassandra Database

docker run -it --name cassandra -p 7199:7199 -p 8888:8888 -p 9016:9016 -p 9042:9042 -p 9160:9160 -p 50031:50031 -p 61620:61620 -p 61621:61621  cassandra

解釋：-it 執行Docker image

--name 指定docker 名稱

-p 對外port 7199:7199 前面port為docker image內部:後面port為本機對外port

啟動完成後透過DevCenter工具，DevCenter像是MySqlWorkbench介面工具。透過DevCenter可以直接使用CQL語法CURD功能。
DevCenter是一套連接Cassandra工具，由DataStax Team所開發，下載時需要先註冊，
DataStax下次有時間在介紹。

3.啟動DataStax測試連線Cassandra for Docker image

連線正常將會在左面出現 docker cassandra [1/1 Connected] 。

3. 建立Cassandra KEYSPCE 及TABLE User Schema
透過DevCenter工具執行CQL語法

Create login KEYSPCE

CREATE KEYSPACE IF NOT EXISTS login
WITH replication = {
 'class' : 'SimpleStrategy',
 'replication_factor' : 1
};

------------------------------------------------------------------------------------------------------------------

Create user Table

CREATE TABLE login.user (
 id uuid,
 name text,
 password text,
 PRIMARY KEY (id)
);

------------------------------------------------------------------------------------------------------------------

在Cassandra比較特別的是如果你需要查詢欄位，是以PRIMARY KEY為主，
如果需要查詢Table內的欄位，只能建立index是否在查詢只能透過PRIMARY KEY才可以。
Create index for search user name

CREATE INDEX IF NOT EXISTS by_name ON login.user (name);

------------------------------------------------------------------------------------------------------------------

新增一筆USER資料
Insert data

insert into user(id,name,password)VALUES(now(),'neil','1234');

4.依個人使用開發工具習慣為主，本身比較習慣使用Intellij IDEA, 建立Play Framework

開啟build.sbt，加入Cassandra Library

libraryDependencies ++= Seq(
    "com.datastax.cassandra" % "cassandra-driver-core" % "3.0.1" ,
    "com.datastax.cassandra" % "cassandra-driver-mapping" % "3.0.1"
)

加入Library後，建立兩個Package ,cassandraDAO,loingModel，
app
|--- controllers
|--- cassandraDAO
|--- loginModel

Download My GitHub Cassandra_login_model

controllers資料夾建立一個Login Class
在Class 建立三個函式def ,分別為 login，logout,authenticate

登入動作

def login = Action { implicit request =&gt;
    println("login: "+request.body.asFormUrlEncoded)
    Ok(views.html.login(loginForm))}

登出動作

def logout = Action {
    Redirect(routes.Login.login).withNewSession.flashing(
      "success" -&gt; "You are now logged out.")}

驗證user資料，當name與password有一項不符合無法登入

def authenticate = Action { implicit request =&gt;
    loginForm.bindFromRequest.fold(
      formWithErrors =&gt; BadRequest(views.html.login(formWithErrors)),
      user =&gt; Redirect(routes.Application.index()).withSession("user" -&gt; user.name ))}

建立Cassandra Connect 新增project 名稱為cassandraDAO, 這個Connect將是連接Cassandra DB
建立一個scala trait

trait Cassandra {
    protected def cassandra_session:Session = {
      val cluster = new Cluster.Builder().
         addContactPoint("192.168.99.100").         //       local docker cassandra
         withPort(9042).
         withQueryOptions(new QueryOptions()
         .setConsistencyLevel(QueryOptions.DEFAULT_CONSISTENCY_LEVEL)
       ).build
      val session = cluster.connect()
        session}
}

新增project models,建立一個檔案為loginModel object 內容為

object loginModel {
  val KEYSPACE = "login"
  val USER_TABLE = "user"

  /**
    * login page check username is exist
    * true: return index page
    * false: return login page
    */
  def authenticate(name:String,password:String,cassandra_session:Session): Boolean= {
    val query_by_user = QueryBuilder.select().from(KEYSPACE,USER_TABLE).where(QueryBuilder.eq("name",name))
    val resultByUser = cassandra_session.executeAsync(query_by_user)
    val data =  resultByUser.get().one()
    cassandra_session.closeAsync()
    if(data == null){
      println("check username is not null ")
      true
    }else{
      if( (name.equals(data.getString("name")) &amp;&amp; password.equals(data.getString("password")) ) ){
        println("success good")
        false
      }else{
    println("username and password fail")
        true}}
  }}

新增html一個 login.scala.html，透過後端程式將資料傳送至html

login.scala.html

如果對於Play Framework 不太瞭解可以參考 Play官方Form說明
最後加入在conf/routes加入以下資訊，讓play framework可以取得到Controller資訊

# Home page
GET /index controllers.Application.index
#login
GET / controllers.Login.login
POST /login controllers.Login.authenticate
GET /login controllers.Login.logout

啟動Intellij IDE Test project

登入畫面

登入失敗

登入成功

如果有任何問題歡迎來信討論與交流 Thanks!

References:

https://hub.docker.com/

https://hub.docker.com/_/cassandra/

http://www.datastax.com/

http://www.datastax.com/what-we-offer/products-services/devcenter

資訊平台

Cassandra Nosql login model

網頁