Class MySQLTest

compatibility/mysql/java/MySQLTest.java:6–136

import java.util.LinkedList;

public class MySQLTest {
    public static class Tests {
        private Connection conn;
        private Statement st;
        private List<Test> tests = new LinkedList<>();

        public void connect(String ip, int port, String user, String password) {
            try {
                String url = "jdbc:mysql://" + ip + ":" + port + "/";
                conn = DriverManager.getConnection(url, user, password);
                st = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }

        public void disconnect() {
            try {
                st.close();
                conn.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }

        public void addTest(String query, String[][] expectedResults) {
            tests.add(new Test(query, expectedResults));
        }

        public boolean runTests() {
            for (Test test : tests) {
                if (!test.run()) {
                    return false;
                }
            }
            return true;
        }

        public void readTestsFromFile(String filename) {
            try (BufferedReader br = new BufferedReader(new FileReader(filename))) {
                String line;
                while ((line = br.readLine()) != null) {
                    if (line.trim().isEmpty()) continue;
                    String query = line;
                    List<String[]> results = new LinkedList<>();
                    while ((line = br.readLine()) != null && !line.trim().isEmpty()) {
                        results.add(line.split(","));
                    }
                    String[][] expectedResults = results.toArray(new String[0][]);
                    addTest(query, expectedResults);
                }
            } catch (IOException e) {
                e.printStackTrace();
                System.exit(1);
            }
        }

        public class Test {