ScanServerAllSchemas.java 1.1 KB

123456789101112131415161718
  1. import java.sql.*;
  2. public class ScanServerAllSchemas {
  3. public static void main(String[] a) throws Exception {
  4. Class.forName("com.mysql.cj.jdbc.Driver");
  5. Connection m = DriverManager.getConnection("jdbc:mysql://cq-cdb-8fjmemkb.sql.tencentcdb.com:27220/mysql?allowMultiQueries=true","root","Ylrz_1q2w3e4r5t6y");
  6. Statement st = m.createStatement();
  7. ResultSet rs = st.executeQuery("SELECT TABLE_SCHEMA FROM information_schema.TABLES WHERE TABLE_NAME='company_workflow_lobster' ORDER BY 1");
  8. int missing=0;
  9. while (rs.next()) {
  10. String db=rs.getString(1);
  11. Connection c=DriverManager.getConnection("jdbc:mysql://cq-cdb-8fjmemkb.sql.tencentcdb.com:27220/"+db+"?allowMultiQueries=true","root","Ylrz_1q2w3e4r5t6y");
  12. ResultSet r2=c.createStatement().executeQuery("SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='company_workflow_lobster' AND COLUMN_NAME='visible_company_ids'");
  13. r2.next(); boolean has=r2.getInt(1)>0; if(!has){ missing++; System.out.println("MISSING: "+db);} c.close();
  14. }
  15. System.out.println("total missing="+missing);
  16. m.close();
  17. }
  18. }