/integration-tests: move mysql-client-tests to integration-tests

integration-tests/mysql-client-tests/java/MySQLConnectorTest.java

@@ -0,0 +1,74 @@
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.sql.ResultSet;
+ 
+public class MySQLConnectorTest {
+    public static void main(String[] args) {
+        Connection conn = null;
+
+	String user = args[0];
+	String port = args[1];
+	String db   = args[2];
+
+        try {
+            String url = "jdbc:mysql://127.0.0.1:" + port + "/" + db;
+            
+	    String password = "";
+ 
+            conn = DriverManager.getConnection(url, user, password);
+	    
+	    Statement st = conn.createStatement();
+
+	    String[] queries = {
+		 "create table test (pk int, `value` int, primary key(pk))",
+		 "describe test",
+		 "select * from test",
+		 "insert into test (pk, `value`) values (0,0)",
+		 "select * from test"
+	    };
+
+	    // Only test the first row, column pair for now
+	    String[] results = {
+		"0",
+		"pk",
+		null,
+		"1",
+		"0"
+	    };
+
+	    for (int i = 0; i < queries.length; i++) { 
+		String query    = queries[i];
+		String expected = results[i];
+		if ( st.execute(query) ) {
+		    ResultSet rs = st.getResultSet();
+		    if (rs.next()) {
+			String result = rs.getString(1);
+			if ( !expected.equals(result) ) {
+			    System.out.println("Query: \n" + query);
+			    System.out.println("Expected:\n" + expected);
+			    System.out.println("Result:\n" + result);
+			    System.exit(1);
+			}
+		    }
+		} else {
+		    String result = Integer.toString(st.getUpdateCount());
+		    if ( !expected.equals(result) ) {
+			System.out.println("Query: \n" + query);
+			System.out.println("Expected:\n" + expected);
+			System.out.println("Rows Updated:\n" + result);
+			System.exit(1);
+		    }
+		}
+	    }
+	    
+	    System.exit(0);
+
+        } catch (SQLException ex) {
+            System.out.println("An error occurred.");
+            ex.printStackTrace();
+	    System.exit(1);
+        }
+    }
+}