ApplyBindingExecStatsTable.java 1.5 KB

1234567891011121314151617181920212223242526272829303132333435
  1. import java.nio.charset.StandardCharsets;
  2. import java.nio.file.Files;
  3. import java.nio.file.Path;
  4. import java.sql.Connection;
  5. import java.sql.DriverManager;
  6. import java.sql.ResultSet;
  7. import java.sql.Statement;
  8. /**
  9. * Apply company_tag_binding_exec_stats to tenant databases.
  10. */
  11. public class ApplyBindingExecStatsTable {
  12. private static final String HOST = "cq-cdb-8fjmemkb.sql.tencentcdb.com:27220";
  13. private static final String USER = "root";
  14. private static final String PWD = "Ylrz_1q2w3e4r5t6y";
  15. public static void main(String[] args) throws Exception {
  16. String sql = Files.readString(
  17. Path.of("d:/ylrz_saas_new/java/sql/tenant/V20260621_01__lobster_binding_exec_stats.sql"),
  18. StandardCharsets.UTF_8);
  19. String[] dbs = args.length > 0 ? args : new String[]{"fs_tenant_cs1"};
  20. for (String db : dbs) {
  21. String url = "jdbc:mysql://" + HOST + "/" + db + "?useSSL=false&serverTimezone=GMT%2B8&allowMultiQueries=true";
  22. try (Connection c = DriverManager.getConnection(url, USER, PWD);
  23. Statement st = c.createStatement()) {
  24. st.execute(sql);
  25. try (ResultSet rs = st.executeQuery(
  26. "SELECT COUNT(*) FROM information_schema.TABLES WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='company_tag_binding_exec_stats'")) {
  27. rs.next();
  28. System.out.println(db + " company_tag_binding_exec_stats exists: " + (rs.getInt(1) > 0));
  29. }
  30. }
  31. }
  32. }
  33. }