初始化选择对应游戏数据库

测试
1 parent f2b3aacd
Showing 2 changed files with 16 additions and 1 deletions Show diff stats
src/csvdata
src/services/dbseed.lua
-Subproject commit 2499d73adbdf6ea3562ce3a815d3189e3a3aab7c
+Subproject commit c676c602628af1a3aa68b3d14b9bb80718ed4614
@@ -241,6 +241,20 @@ local function loadAllUserInfo()
 	end
 end
  
+local function selectDb()
+	local work_count = tonumber(skynet.getenv("thread"))
+	for i = 1, work_count do
+		local mysqld = skynet.localname(".mysql" .. i)
+
+		local servId = skynet.getenv("servId")
+		local ok, result = pcall(skynet.call, mysqld, "lua", "query", string.format("use server_%s", servId))
+		if not ok then
+			skynet.error("select db error", "\n", debug.traceback(coroutine.running(), nil))
+			return
+		end
+	end
+end
+
 skynet.start(function ()
 	--local new = redisproxy:hsetnx("autoincrement_set", "server_start", os.date("%Y%m%d", skynet.timex())) == 1
 	--if not new then
@@ -259,5 +273,6 @@ skynet.start(function ()
 	initRedisDb()
 	initSeaportTask()		-- 海港任务数据初始化
 	loadAllUserInfo()
+	selectDb()
 	skynet.exit()
 end)
 \ No newline at end of file