婷婷综合国产,91蜜桃婷婷狠狠久久综合9色 ,九九九九九精品,国产综合av

主頁 > 知識庫 > Lua 操作 MongoDB 數據庫實例

Lua 操作 MongoDB 數據庫實例

熱門標簽:漳州智云呼電話機器人 新岸線智能電銷機器人 武漢外呼防封系統多少錢 個人怎么在地圖標注需要的店鋪 百度地圖標注早餐區域 冀州市地圖標注 怎么去除地圖標注 地圖標注大廈 清朝地圖標注哈爾濱

最近有個工作是使用Nginx + Lua實現一個操作MongoDB數據庫的API,主要實現其count和query功能。之前沒有寫過Lua,于是也就勉強著上手,在cloudwu的 lua-mongo 的基礎上實現了操作MongoDB的API。

cloudwu的lua-mongo驅動實現了連接Mongo,進行find和findOne等基本操作的功能,所以在lua-mongo的基礎上增加了count和query等方法。修改的具體內容如下:

1、API基于luajit-2.0開發,相當于lua 5.1,需要使用lua-compat-5.2兼容lua 5.2

2、使用ngx.socket.tcp替換mongo.socket模塊

3、增加了count,query,auth等方法

修改之后的代碼見: lua-mongo

具體的操作MongoDB的lua代碼如下:

復制代碼 代碼如下:

-- lua mongo test script
-- utils
function string:split(sep)
  local sep, fields = sep or ":", {}
  local pattern = string.format("([^%s]+)", sep)
  self:gsub(pattern, function(c) fields[#fields + 1] = c end)
  return fields
end
-- 常量
HOST = "127.0.0.1"
PORT = 27017
KEEPALIVE_TIMEOUT = 60000
KEEPALIVE_SIZE = 100
CONN_TIMEOUT = 3000
DB_USER = "user"
DB_PASSWD = "password"
DB_NAME = "blog"
DB_COLLECTION = "article"
-- 引用
mongo = require("mongo")
cjson = require("cjson.safe")
cbson = require("bson")
-- 狀態
local status_msg = "error"
local status_code = 500
local message = "unknown error"
local mongo_query = {["category_id"] = {["$in"] = {1,2,3,4}}, ["status"] = {["$ne"] = 2}, ["create_time"] = {["$lte"] = 1427102260}}
local mongo_sort = {["create_time"] = 1}
local mongo_limit = 100
local mongo_skip = 0
local mongo_fields = { ["_id"] = false }
-- 涉及到時間的字段,需要使用bson轉化一下
if mongo_query["create_time"] then
  local create_time = mongo_query["create_time"]
  local t = type(create_time)
  if t == "table" then
    for key, value in pairs(create_time) do
      mongo_query["create_time"][key] = cbson.date(value)
    end
  else
    mongo_query["create_time"] = cbson.date(create_time)
  end
end
local conn = mongo.client({ host = HOST, port = PORT })
conn:set_timeout(CONN_TIMEOUT)
local db = conn:getDB(DB_NAME)
local reused_times = conn:get_reused_times()
if reused_times == 0 then
  db:auth(DB_USER, DB_PASSWD)
end
local col = db:getCollection(DB_COLLECTION)
local result = {}
-- count
local count, err = col:count(mongo_query)
local ok, err = conn:set_keepalive(KEEPALIVE_TIMEOUT, KEEPALIVE_SIZE)
if count ~= nil then
  result = count
  status_code = 200
  status_msg = "ok"
  message = "success"
end
-- query
local bson_obj
if mongo_sort then
  bson_obj = cbson.encode_order("$query", mongo_query, "$orderby", mongo_sort)
else
  bson_obj = cbson.encode({ ["$query"] = mongo_query })
end
local results = col:query(bson_obj, mongo_fields, mongo_skip, mongo_limit)
local ok, err = conn:set_keepalive(KEEPALIVE_TIMEOUT, KEEPALIVE_SIZE)
if results then
  for _, object in pairs(results) do
    for key, value in pairs(object) do
      if value == cbson.null then
        object[key] = cjson.null
      else
        local type_name, value = cbson.type(value)
        object[key] = value
      end
    end
  end
  result = results
  status_code = 200
  status_msg = "ok"
  message = "success"
end
-- findOne
local results = col:findOne({["id"] = 14 })
local ok, err = conn:set_keepalive(KEEPALIVE_TIMEOUT, KEEPALIVE_SIZE)
if results then
  for key, value in pairs(results) do
    if value == cbson.null then
      results[key] = cjson.null
    else
      local type_name, value = cbson.type(value)
      results[key] = value
    end
  end
  result = results
  status_code = 200
  status_msg = "ok"
  message = "success"
end
ngx.status = status_code
json_out = cjson.encode({ status = status_msg, message = message, data = result })
ngx.header["Content-Length"] = json_out:len()
ngx.print(json_out)

標簽:濰坊 天門 臺灣 儋州 金昌 天門 德宏 宣城

巨人網絡通訊聲明:本文標題《Lua 操作 MongoDB 數據庫實例》,本文關鍵詞  Lua,操作,MongoDB,數據庫,實例,;如發現本文內容存在版權問題,煩請提供相關信息告之我們,我們將及時溝通與處理。本站內容系統采集于網絡,涉及言論、版權與本站無關。
  • 相關文章
  • 下面列出與本文章《Lua 操作 MongoDB 數據庫實例》相關的同類信息!
  • 本頁收集關于Lua 操作 MongoDB 數據庫實例的相關信息資訊供網民參考!
  • 推薦文章
    主站蜘蛛池模板: 叙永县| 定远县| 南郑县| 密云县| 德清县| 眉山市| 宜都市| 富顺县| 翼城县| 长顺县| 呼图壁县| 海城市| 阆中市| 绥宁县| 彭水| 穆棱市| 逊克县| 盐边县| 鄢陵县| 安国市| 建水县| 陆河县| 东阿县| 沙田区| 克什克腾旗| 桓台县| 咸丰县| 建平县| 林周县| 南江县| 永修县| 衡水市| 淮北市| 上杭县| 怀柔区| 湟中县| 香格里拉县| 林芝县| 新龙县| 乐安县| 河北省|