import java.sql.*;

/**
 * 查询 company 表中的企业及其行业字段
 */
public class InvestigateCompany {
    public static void main(String[] a) throws Exception {
        Class.forName("com.mysql.cj.jdbc.Driver");
        String url = "jdbc:mysql://cq-cdb-8fjmemkb.sql.tencentcdb.com:27220/ylrz_saas_tenant_1"
                + "?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false";
        try (Connection c = DriverManager.getConnection(url, "root", "Ylrz_1q2w3e4r5t6y")) {
            // 1) 列出 company 表所有列
            System.out.println("=== company 表所有列 ===");
            try (Statement st = c.createStatement();
                 ResultSet rs = st.executeQuery(
                         "SELECT column_name, data_type, column_comment FROM information_schema.columns "
                                 + "WHERE table_schema=DATABASE() AND table_name='company' ORDER BY ordinal_position")) {
                while (rs.next()) {
                    System.out.println("  " + rs.getString(1) + " | " + rs.getString(2) + " | " + rs.getString(3));
                }
            }

            // 2) 列出所有企业及行业相关字段
            System.out.println("\n=== company 表所有企业（含 company_type/join_type/send_if_type 等）===");
            try (Statement st = c.createStatement();
                 ResultSet rs = st.executeQuery(
                         "SELECT company_id, company_name, company_type, join_type, send_if_type, status "
                                 + "FROM company WHERE is_del='0' OR is_del IS NULL ORDER BY company_id LIMIT 200")) {
                while (rs.next()) {
                    System.out.printf("  cid=%s | name=%s | type=%s | join=%s | sendIf=%s | status=%s%n",
                            rs.getString(1), rs.getString(2), rs.getString(3),
                            rs.getString(4), rs.getString(5), rs.getString(6));
                }
            }

            // 3) company_workflow_lobster 工作流及其行业字段（包括软删除）
            System.out.println("\n=== company_workflow_lobster 全部工作流 ===");
            try (Statement st = c.createStatement();
                 ResultSet rs = st.executeQuery(
                         "SELECT id, company_id, template_code, template_name, industry_type, "
                                 + "template_kind, status, create_time FROM company_workflow_lobster "
                                 + "ORDER BY id")) {
                while (rs.next()) {
                    System.out.printf("  id=%s | cid=%s | code=%s | name=%s | industry=%s | kind=%s | status=%s | t=%s%n",
                            rs.getString(1), rs.getString(2), rs.getString(3), rs.getString(4),
                            rs.getString(5), rs.getString(6), rs.getString(7), rs.getString(8));
                }
            }

            // 4) 行业语料矩阵 lobster_sales_corpus 中 industry_type 分布
            System.out.println("\n=== lobster_sales_corpus industry_type 分布 ===");
            try (Statement st = c.createStatement();
                 ResultSet rs = st.executeQuery(
                         "SELECT industry_type, COUNT(*) cnt FROM lobster_sales_corpus GROUP BY industry_type")) {
                while (rs.next()) {
                    System.out.printf("  industry=%s | cnt=%s%n", rs.getString(1), rs.getString(2));
                }
            }

            // 5) lobster_system_prompt 中 industry_type 分布
            System.out.println("\n=== lobster_system_prompt industry_type 分布 ===");
            try (Statement st = c.createStatement();
                 ResultSet rs = st.executeQuery(
                         "SELECT industry_type, COUNT(*) cnt FROM lobster_system_prompt GROUP BY industry_type")) {
                while (rs.next()) {
                    System.out.printf("  industry=%s | cnt=%s%n", rs.getString(1), rs.getString(2));
                }
            }

            // 6) lobster_learning_corpus 中行业分布
            System.out.println("\n=== lobster_learning_corpus industry_type 分布 ===");
            try (Statement st = c.createStatement();
                 ResultSet rs = st.executeQuery(
                         "SELECT industry_type, COUNT(*) cnt FROM lobster_learning_corpus GROUP BY industry_type")) {
                while (rs.next()) {
                    System.out.printf("  industry=%s | cnt=%s%n", rs.getString(1), rs.getString(2));
                }
            }

            // 7) 主库中的 tenant_info（如果可以访问主库）
            System.out.println("\n=== 尝试访问主库 ylrz_saas.tenant_info ===");
            try (Statement st = c.createStatement();
                 ResultSet rs = st.executeQuery(
                         "SELECT id, tenant_name, db_url, status FROM ylrz_saas.tenant_info WHERE status=1 ORDER BY id")) {
                while (rs.next()) {
                    System.out.printf("  tid=%s | name=%s | db=%s | status=%s%n",
                            rs.getString(1), rs.getString(2), rs.getString(3), rs.getString(4));
                }
            } catch (SQLException e) {
                System.out.println("  [ERR] " + e.getMessage());
            }
        }
    }
}