TeamTableInitを移設

Author: miyabi033

src/main/java/dev/felnull/pointed/Pointed.java

@@ -7,6 +7,7 @@
 import dev.felnull.pointed.core.database.api.PointServiceImpl;
 import dev.felnull.pointed.core.listener.ChatListener;
 import dev.felnull.pointed.core.util.ChatReader;
+import dev.felnull.pointed.teams.database.TeamTableInitializer;
 import lombok.Getter;
 import org.bukkit.Bukkit;
 import org.bukkit.configuration.file.FileConfiguration;
@@ -42,6 +43,7 @@ public void onEnable() {
         saveDefaultConfig();
         setupPlugin();
         TableInitializer.initTables();
+        TeamTableInitializer.initTables();
     }
 
     @Override

src/main/java/dev/felnull/pointed/core/database/TableInitializer.java

@@ -170,7 +170,7 @@ public static void initTables() {
 
     // ========= ユーティリティ =========
 
-    private static void addColumnIfNotExists(Connection conn, String baseTable, String columnName, String columnDefinition) {
+    public static void addColumnIfNotExists(Connection conn, String baseTable, String columnName, String columnDefinition) {
         String phys = Names.phys(baseTable); // バッククォートなし実名
         try {
             boolean exists = false;
@@ -234,7 +234,7 @@ private static void ensureUniqueIndex(Connection conn, String baseTable, String
         }
     }
 
-    private static void ensureIndex(Connection conn, String baseTable, String indexName, String[] columns) {
+    public static void ensureIndex(Connection conn, String baseTable, String indexName, String[] columns) {
         String phys = Names.phys(baseTable);
         try {
             if (indexExists(conn, phys, indexName)) return;
@@ -259,9 +259,9 @@ private static boolean indexExists(Connection conn, String physTable, String ind
         return false;
     }
 
-    private static void ensureForeignKey(Connection conn, String baseTable, String foreignKeyName,
-                                         String col, String refBaseTable, String refCol,
-                                         String onDelete, String onUpdate) {
+    public static void ensureForeignKey(Connection conn, String baseTable, String foreignKeyName,
+                                        String col, String refBaseTable, String refCol,
+                                        String onDelete, String onUpdate) {
         String phys = Names.phys(baseTable);
         try {
             if (foreignKeyExists(conn, phys, foreignKeyName)) return;

src/main/java/dev/felnull/pointed/teams/database/TeamTableInitializer.java

@@ -0,0 +1,48 @@
+package dev.felnull.pointed.teams.database;
+
+import dev.felnull.pointed.core.database.Db;
+import dev.felnull.pointed.core.database.Names;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.logging.Logger;
+
+import static dev.felnull.pointed.core.database.TableInitializer.*;
+
+public class TeamTableInitializer {
+    private static final Logger LOGGER = Logger.getLogger("Pointed");
+    public static void initTables() {
+        try (Connection conn = Db.get().getConnection();
+             Statement stmt = conn.createStatement()) {
+
+            // ========== 1) 骨格だけCREATE（最小列） ==========
+            // team_meta（骨格）
+            stmt.executeUpdate("CREATE TABLE IF NOT EXISTS " + Names.t("team_meta") + " (" +
+                    " subject_id BIGINT NOT NULL," +
+                    " PRIMARY KEY (subject_id)" +
+                    ") ENGINE=InnoDB DEFAULT CHARSET=utf8mb4");
+
+            // ========== 2) 不足カラムを追加 ==========
+            // team_meta
+            addColumnIfNotExists(conn, "team_meta", "color_code", "VARCHAR(16) NOT NULL");
+            addColumnIfNotExists(conn, "team_meta", "sort_order", "INT NOT NULL DEFAULT 0");
+            addColumnIfNotExists(conn, "team_meta", "active",     "TINYINT(1) NOT NULL DEFAULT 1");
+
+            // ========== 3) インデックス・制約 ==========
+
+            // subjects(id) へのFK。subjects 削除時に team_meta も自動削除
+            ensureForeignKey(conn, "team_meta", "fk_tm_subject",
+                    "subject_id", "subjects", "id", "CASCADE", "CASCADE");
+
+            // 並び順・有効/無効フィルタの補助INDEX
+            ensureIndex(conn, "team_meta", "idx_tm_sort",   new String[]{"sort_order"});
+            ensureIndex(conn, "team_meta", "idx_tm_active", new String[]{"active"});
+
+            LOGGER.info("[Pointed] テーブル初期化完了！");
+
+        } catch (SQLException e) {
+            LOGGER.warning("[Pointed] テーブル初期化中にエラー: " + e.getMessage());
+        }
+    }
+}