[Swift] Hướng dẫn kết nối server Perfect với MongoDB

Như bài ví dụ trước mình có hướng dẫn cách thiết lập căn bản để các bạn có thể viết 1 webservice đơn giản và kết nối với cơ sở dữ liệu là database bằng ngôn ngữ Swift. Các bạn có thể xem qua tại đây.

Bài này mình xin hướng dẫn các bạn thiết lập server hiện tại cho chạy với database MongoDB.

MongoDB là gì?

MongoDB là một cơ sở dữ liệu (database) theo dạng tài liệu (document), mã nguồn mở (open source), miễn phí, chạy trên nhiều nền tảng (cross-platform). Được phân loại như là NoSQL database.

MongoDB không sử dụng cấu trúc cơ sở dữ liệu quan hệ dựa theo dạng bảng (table) như truyền thống, mà dùng cơ chế lưu theo dạng document (JSON) với scheme động (MongoDB gọi đó là định dạng BSON) làm cho việc tích hợp các dữ liệu trong một số loại ứng dụng dễ dàng hơn và nhanh hơn.

Còn chần chờ gì nữa các bạn không thử xài MongoDB để cảm nhận công nghệ NoSql là như thế nào ^^.

Hướng dẫn cài đặt MongoDB trên máy local:

Bước 1: Bạn vào trang chủ download của MongoDB. Có 2 cách để cài MongoDB 1 là theo manual tức là bạn tải file về bình thường và cài đặt, cách thứ 2 là cài thông qua brew. Mình thích cài theo cách thứ 2.

Bước 2: Bạn vào trang hướng dẫn cài MongoDB theo brew và làm theo hướng dẫn của người ta. Lưu ý hướng dẫn cài rất đơn giản nhưng có nhìu sư lựa chọn tuỳ theo nhu cầu của bạn thì cài theo dạng bình thường hay có hỗ trợ TLS/SSL

Bước 3: Khởi tạo thư mục chứa dữ liệu MongoDB, bằng cách nhập lệnh sau:

 mkdir -p /data/db

Thiết lập quyền truy suất thư mục đó:

sudo chmod 777 /data/db

Chạy MongoDB server:

mongod

PS: Nên để nguyên tab khởi tạo chạy MongoDB để sử dụng, khi nào không cần sử dụng thì đóng tab này đi để tắt Server của MongoDB.

Mở tab mới trên terminal và nhập lệnh để mở command line cho MongoDB:

mongo

Trên terminal đó bạn nhập dòng lệnh như sau để khởi tạo database với tên là PerfectDatabase:

use PerfectDatabase

Sau đó bạn khởi tạo đối tượng Collection là User (giống Table của cở sở dữ liệu thông thường):

db.createCollection(“User",{capped:true,autoIndexID:true,size:10240,max:100})

Sau khi bạn khởi tạo Collection xong bạn có thể chạy đoạn code Post để thêm dữ liệu trước khi dùng Get api để lấy dữ liệu về như code demo của mình bên dưới.

Hướng dẫn thiết lập MongoDB connector với Perfect  trên Server Local:

Bước 1: Nắm kéo thả project MongoDB trong thư mục Connectors project vào workspace:

Bước 2: Chọn Target là PerfectServer, và nhấn dấu cộng phần "Linked Frameworks and Libraries" để sử dụng MongoDB connector.

Bước 3: Thêm code server
Tại file "PerfectHandlers.swift" chúng ta thêm những đoạn code khai báo 2 loại Restful Api như sau:

	import MongoDB
	let MONGODB_HOST = "mongodb://localhost"
	// database name and table
	let DATABASE = "PerfectDatabase"
	let TABLE = "User"
	// This function is required. The Perfect framework expects to find this function
	// to do initialization
	public func PerfectServerModuleInit() {
	// Install the built-in routing handler.
	// This is required by Perfect to initialize everything
	Routing.Handler.registerGlobally()
	// register routes for MongoDb connections
	Routing.Routes["GET", "/mongodb"] = { _ in
	return GetMongoHandler()
	}
	Routing.Routes["POST", "/mongodb"] = { _ in
	return PostMongoHandler()
	}
	}

view raw mongodb_init hosted with ❤ by GitHub

Và khai báo đối tượng của phương thức Get lấy danh sách những item trong collection:

	class GetMongoHandler: RequestHandler {
	func handleRequest(request: WebRequest, response: WebResponse) {
	// open MongoDb connection
	do {
	// open mongodb connection
	let client = try MongoClient(uri: MONGODB_HOST)
	defer {
	client.close()
	}
	let status = client.serverStatus()
	switch status {
	case .Error:
	response.setStatus(500, message: "Server Error")
	response.requestCompletedCallback()
	return
	case .ReplyDoc:
	//Success
	let db = client.getDatabase(DATABASE)
	let collection = db.getCollection(TABLE)
	let bson = try BSON(json: "{}")
	defer {
	bson.close()
	collection.close()
	db.close()
	}
	let results = collection.find(bson)
	let resultsCount = collection.count(bson)
	print("resultsCount: \(resultsCount)")
	var countInt = 0
	switch resultsCount {
	case .Error:
	response.setStatus(501, message: "Get Item Error")
	response.requestCompletedCallback()
	return
	case .ReplyInt(let count):
	countInt = count
	default:
	response.setStatus(500, message: "Unknown Error!")
	response.requestCompletedCallback()
	return
	}
	var userList = [JSONValue]()
	let jsonEncoder = JSONEncoder()
	for _ in 0..<countInt {
	let item = results?.next()
	print("fetched: \(item)")
	userList.append(item?.description)
	}
	do {
	let userListJson = try jsonEncoder.encode(["users":userList])
	// write the JSON to the response body
	response.appendBodyString(userListJson)
	response.addHeader("Content-Type", value: "application/json")
	response.setStatus(200, message: "OK")
	} catch {
	response.setStatus(500, message: "Server Error")
	}
	default:
	response.setStatus(500, message: "Unknown Error!")
	response.requestCompletedCallback()
	return
	}
	} catch {
	response.setStatus(401, message: "Connection error!")
	}
	response.requestCompletedCallback()
	}
	}

view raw mongodb_get hosted with ❤ by GitHub

Còn đối tượng cho phương thức Post thì viết như sau:

	class PostMongoHandler: RequestHandler {
	func handleRequest(request: WebRequest, response: WebResponse) {
	let reqData = request.postBodyString // get the request body
	let jsonDecoder = JSONDecoder() // JSON decoder
	do {
	let json = try jsonDecoder.decode(reqData) as! JSONDictionaryType
	print("received request JSON: \(json.dictionary)")
	let userName = json.dictionary["userName"] as? String
	let firstName = json.dictionary["firstName"] as? String
	let lastName = json.dictionary["lastName"] as? String
	guard userName != nil else {
	// bad request, bail out
	response.setStatus(400, message: "Bad Request")
	response.requestCompletedCallback()
	return
	}
	do {
	// open mongodb connection
	let client = try MongoClient(uri: MONGODB_HOST)
	defer {
	client.close()
	}
	let status = client.serverStatus()
	switch status {
	case .Error:
	response.setStatus(500, message: "Server Error")
	response.requestCompletedCallback()
	return
	case .ReplyDoc:
	//Success
	let db = client.getDatabase(DATABASE)
	let collection = db.getCollection(TABLE)
	let bson = BSON()
	defer {
	bson.close()
	collection.close()
	db.close()
	}
	bson.append("userName", string: userName!)
	bson.append("firstName", string: firstName!)
	bson.append("lastName", string: lastName!)
	let result = collection.save(bson)
	switch result {
	case .Success:
	response.setStatus(201, message: "Created")
	default:
	response.setStatus(501, message: "Insert Error")
	}
	default:
	response.setStatus(500, message: "Unknown Error!")
	response.requestCompletedCallback()
	return
	}
	} catch {
	print("error decoding json from data: \(reqData)")
	response.setStatus(401, message: "Connection error!")
	}
	} catch {
	print("error decoding json from data: \(reqData)")
	response.setStatus(400, message: "Bad Request")
	}
	// this completes the request and sends the response to the client
	response.requestCompletedCallback()
	}
	}

view raw mongodb_post hosted with ❤ by GitHub

Bạn có thể mở lệnh curl để chạy thử api trên terminal.

Các bạn có thể lấy toàn bộ source code của mình tại GitHub

Tài liệu tham khảo:

- Integrate MySQL Into a Swift Perfect Web Server.
- MongoDB tutorials.