DbQuery4.java 1.4 KB

123456789101112131415161718192021222324
  1. import java.sql.*;
  2. public class DbQuery4 {
  3. public static void main(String[] args) throws Exception {
  4. String url = "jdbc:mysql://192.168.9.181:3306/mes_cloud?useSSL=false&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&connectTimeout=5000&socketTimeout=15000";
  5. try (Connection c = DriverManager.getConnection(url, "mes_cloud", "s2ENj7KaEySTC7dW")) {
  6. q(c, "SELECT company_code, COUNT(*) c FROM js_sys_employee WHERE status='0' GROUP BY company_code ORDER BY c DESC");
  7. q(c, "SELECT e.office_code, o.office_name, COUNT(*) c FROM js_sys_employee e LEFT JOIN js_sys_office o ON o.office_code=e.office_code WHERE e.status='0' AND e.company_code='110' GROUP BY e.office_code, o.office_name ORDER BY c DESC");
  8. q(c, "SELECT COUNT(*) c FROM js_sys_employee WHERE company_code='110'");
  9. }
  10. }
  11. static void q(Connection c, String sql) throws Exception {
  12. System.out.println("SQL> " + sql);
  13. try (Statement s = c.createStatement(); ResultSet rs = s.executeQuery(sql)) {
  14. ResultSetMetaData md = rs.getMetaData();
  15. int n = md.getColumnCount(); int rows=0;
  16. while (rs.next()) {
  17. StringBuilder sb=new StringBuilder();
  18. for (int i=1;i<=n;i++){ if(i>1)sb.append(" | "); sb.append(md.getColumnLabel(i)).append("=").append(rs.getString(i)); }
  19. System.out.println(sb); rows++;
  20. }
  21. System.out.println("rows="+rows); System.out.println("---");
  22. }
  23. }
  24. }