| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171 |
- import java.sql.*;
- import java.util.ArrayList;
- import java.util.List;
- /**
- * Set all hidden menus to visible (visible='0') for review/cleanup.
- * - tenant DB: sys_menu
- * - master DB: tenant_sys_menu (+ sys_menu if present)
- */
- public class ShowAllMenus {
- private static final String MASTER_HOST = getenv("DB_HOST", "cq-cdb-8fjmemkb.sql.tencentcdb.com");
- private static final int MASTER_PORT = Integer.parseInt(getenv("DB_PORT", "27220"));
- private static final String MASTER_USER = getenv("DB_USER", "root");
- private static final String MASTER_PASSWORD = getenv("DB_PASSWORD", "Ylrz_1q2w3e4r5t6y");
- private static final String MASTER_DB = getenv("DB_NAME", "ylrz_saas");
- public static void main(String[] args) throws Exception {
- Class.forName("com.mysql.cj.jdbc.Driver");
- boolean dryRun = args.length > 0 && "dry-run".equalsIgnoreCase(args[0]);
- System.out.println("=== Show all menus (visible 1 -> 0) === dryRun=" + dryRun);
- try (Connection master = open(MASTER_HOST, MASTER_PORT, MASTER_DB, MASTER_USER, MASTER_PASSWORD)) {
- if (dryRun) {
- preview(master, "tenant_sys_menu");
- if (tableExists(master, "sys_menu")) {
- preview(master, "sys_menu");
- }
- } else {
- int n = unhide(master, "tenant_sys_menu");
- System.out.println("[MASTER] tenant_sys_menu unhidden=" + n);
- if (tableExists(master, "sys_menu")) {
- n = unhide(master, "sys_menu");
- System.out.println("[MASTER] sys_menu unhidden=" + n);
- }
- }
- }
- List<Long> tenantIds;
- try (Connection master = open(MASTER_HOST, MASTER_PORT, MASTER_DB, MASTER_USER, MASTER_PASSWORD)) {
- tenantIds = loadActiveTenantIds(master);
- }
- int ok = 0;
- for (Long tenantId : tenantIds) {
- TenantDb tenant;
- try (Connection master = open(MASTER_HOST, MASTER_PORT, MASTER_DB, MASTER_USER, MASTER_PASSWORD)) {
- tenant = loadTenant(master, tenantId);
- }
- if (tenant == null) {
- continue;
- }
- try (Connection conn = open(tenant.host, tenant.port, tenant.database, tenant.user, tenant.password)) {
- if (!tableExists(conn, "sys_menu")) {
- continue;
- }
- if (dryRun) {
- int hidden = countHidden(conn, "sys_menu");
- System.out.println("[TENANT " + tenantId + "] " + tenant.database + " hidden=" + hidden);
- } else {
- int n = unhide(conn, "sys_menu");
- System.out.println("[TENANT " + tenantId + "] " + tenant.database + " unhidden=" + n);
- }
- ok++;
- }
- }
- System.out.println("\nDone. tenants processed=" + ok);
- }
- private static int unhide(Connection conn, String table) throws SQLException {
- String sql = "UPDATE " + table + " SET visible = '0', update_time = NOW() "
- + "WHERE visible = '1' AND status = '0'";
- try (Statement st = conn.createStatement()) {
- return st.executeUpdate(sql);
- }
- }
- private static int countHidden(Connection conn, String table) throws SQLException {
- try (Statement st = conn.createStatement();
- ResultSet rs = st.executeQuery(
- "SELECT COUNT(*) FROM " + table + " WHERE visible = '1' AND status = '0'")) {
- rs.next();
- return rs.getInt(1);
- }
- }
- private static void preview(Connection conn, String table) throws SQLException {
- System.out.println("\n--- " + table + " hidden menus ---");
- try (Statement st = conn.createStatement();
- ResultSet rs = st.executeQuery(
- "SELECT menu_id, parent_id, menu_name, path FROM " + table
- + " WHERE visible = '1' AND status = '0' ORDER BY parent_id, menu_id LIMIT 80")) {
- int n = 0;
- while (rs.next()) {
- n++;
- System.out.printf(" id=%d parent=%d path=%s name=%s%n",
- rs.getLong(1), rs.getLong(2), rs.getString(4), rs.getString(3));
- }
- int total = countHidden(conn, table);
- System.out.println(" shown=" + n + " total hidden=" + total);
- }
- }
- private static boolean tableExists(Connection conn, String table) throws SQLException {
- try (ResultSet rs = conn.getMetaData().getTables(null, null, table, null)) {
- return rs.next();
- }
- }
- private static List<Long> loadActiveTenantIds(Connection master) throws SQLException {
- List<Long> ids = new ArrayList<>();
- try (Statement st = master.createStatement();
- ResultSet rs = st.executeQuery("SELECT id FROM tenant_info WHERE status = 1 ORDER BY id")) {
- while (rs.next()) {
- ids.add(rs.getLong(1));
- }
- }
- return ids;
- }
- private static TenantDb loadTenant(Connection master, long tenantId) throws SQLException {
- try (PreparedStatement ps = master.prepareStatement(
- "SELECT db_url, db_account, db_pwd FROM tenant_info WHERE id = ? AND status = 1 LIMIT 1")) {
- ps.setLong(1, tenantId);
- try (ResultSet rs = ps.executeQuery()) {
- if (!rs.next()) {
- return null;
- }
- return parseJdbcUrl(rs.getString("db_url"), rs.getString("db_account"), rs.getString("db_pwd"));
- }
- }
- }
- private static TenantDb parseJdbcUrl(String jdbcUrl, String user, String password) {
- String body = jdbcUrl.substring("jdbc:mysql://".length());
- int slash = body.indexOf('/');
- String hostPort = body.substring(0, slash);
- String rest = body.substring(slash + 1);
- int q = rest.indexOf('?');
- String database = q >= 0 ? rest.substring(0, q) : rest;
- int colon = hostPort.indexOf(':');
- TenantDb t = new TenantDb();
- t.host = colon >= 0 ? hostPort.substring(0, colon) : hostPort;
- t.port = colon >= 0 ? Integer.parseInt(hostPort.substring(colon + 1)) : 3306;
- t.database = database;
- t.user = user != null ? user : MASTER_USER;
- t.password = password != null ? password : MASTER_PASSWORD;
- return t;
- }
- private static Connection open(String host, int port, String database, String user, String password)
- throws SQLException {
- return DriverManager.getConnection(
- "jdbc:mysql://" + host + ":" + port + "/" + database
- + "?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&allowMultiQueries=true",
- user, password);
- }
- private static String getenv(String key, String defaultValue) {
- String v = System.getenv(key);
- return v != null && !v.isEmpty() ? v : defaultValue;
- }
- private static final class TenantDb {
- String host;
- int port;
- String database;
- String user;
- String password;
- }
- }
|