local skynet = require "skynet"
  require "skynet.manager"
  local mysql = require "skynet.db.mysql"
  
  local db
  local idx = ...
  local command = {}
  
  function command.open(conf)
  	local function on_connect(db)

  		local servId = skynet.getenv("servId")

          db:query("set names utf8mb4");

  		db:query(string.format("use server_%s", servId))

  	end

  	local servId = skynet.getenv("servId")

  	db=mysql.connect({

  		host=conf.host,
  		port=conf.port,

  		database= "mysql",

  		user=conf.user,
  		password=conf.pwd,

  		max_packet_size = 5 * 1024 * 1024,

  		on_connect = on_connect
  	})
  	if not db then
  		print("failed to connect")
  	end

  end
  
  skynet.start(function()
  	skynet.dispatch("lua", function(session, address, cmd, ...)
  		if cmd == "open" then
  			local f = command[string.lower(cmd)]
  			skynet.ret(skynet.pack(f(...)))

  		elseif string.lower(cmd) == "quote_sql_str" then
  			skynet.ret(skynet.pack(db[string.lower(cmd)](...)))

  		else
  			skynet.ret(skynet.pack(db[string.lower(cmd)](db, ...)))
  		end
  	end)
  	skynet.info_func(function()
  		return skynet.stat("mqlen")
  	end)
  	skynet.register(".mysql" .. idx)
  end)