From 2f414c3144a8fdf2fd6b5b2b1e40d900cd607ef1 Mon Sep 17 00:00:00 2001
From: liuzujun <307836273@qq.com>
Date: Fri, 16 Apr 2021 12:03:14 +0800
Subject: [PATCH] 初始化选择对应游戏数据库

---
 src/csvdata             |  2 +-
 src/services/dbseed.lua | 15 +++++++++++++++
 2 files changed, 16 insertions(+), 1 deletion(-)

diff --git a/src/csvdata b/src/csvdata
index 2499d73..c676c60 160000
--- a/src/csvdata
+++ b/src/csvdata
@@ -1 +1 @@
-Subproject commit 2499d73adbdf6ea3562ce3a815d3189e3a3aab7c
+Subproject commit c676c602628af1a3aa68b3d14b9bb80718ed4614
diff --git a/src/services/dbseed.lua b/src/services/dbseed.lua
index 068bf6d..479f58b 100644
--- a/src/services/dbseed.lua
+++ b/src/services/dbseed.lua
@@ -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
--
libgit2 0.21.2