mysql parser support BINLOG statement

src/test/java/com/alibaba/druid/bvt/sql/mysql/Binlog_Test.java

@@ -0,0 +1,52 @@
+/*
+ * Copyright 1999-2011 Alibaba Group Holding Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.alibaba.druid.bvt.sql.mysql;
+
+import java.util.List;
+
+import junit.framework.Assert;
+import junit.framework.TestCase;
+
+import com.alibaba.druid.sql.ast.SQLStatement;
+import com.alibaba.druid.sql.dialect.mysql.parser.MySqlStatementParser;
+import com.alibaba.druid.sql.dialect.mysql.visitor.MySqlOutputVisitor;
+
+public class Binlog_Test extends TestCase {
+
+    public void test_0() throws Exception {
+        String sql = "binlog  'str'";
+
+        MySqlStatementParser parser = new MySqlStatementParser(sql);
+        List<SQLStatement> stmtList = parser.parseStatementList();
+
+        String text = output(stmtList);
+
+        Assert.assertEquals("BINLOG 'str';", text);
+    }
+    
+
+
+    private String output(List<SQLStatement> stmtList) {
+        StringBuilder out = new StringBuilder();
+
+        for (SQLStatement stmt : stmtList) {
+            stmt.accept(new MySqlOutputVisitor(out));
+            out.append(";");
+        }
+
+        return out.toString();
+    }
+}

src/test/java/com/alibaba/druid/bvt/sql/mysql/Kill_Test.java

@@ -0,0 +1,62 @@
+/*
+ * Copyright 1999-2011 Alibaba Group Holding Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.alibaba.druid.bvt.sql.mysql;
+
+import java.util.List;
+
+import junit.framework.Assert;
+import junit.framework.TestCase;
+
+import com.alibaba.druid.sql.ast.SQLStatement;
+import com.alibaba.druid.sql.dialect.mysql.parser.MySqlStatementParser;
+import com.alibaba.druid.sql.dialect.mysql.visitor.MySqlOutputVisitor;
+
+public class Kill_Test extends TestCase {
+
+    public void test_0() throws Exception {
+        String sql = "KILL  QUERY 233";
+
+        MySqlStatementParser parser = new MySqlStatementParser(sql);
+        List<SQLStatement> stmtList = parser.parseStatementList();
+
+        String text = output(stmtList);
+
+        Assert.assertEquals("KILL QUERY 233;", text);
+    }
+    
+    public void test_1() throws Exception {
+    	String sql = "KILL  CONNECTION 233";
+    	
+    	MySqlStatementParser parser = new MySqlStatementParser(sql);
+    	List<SQLStatement> stmtList = parser.parseStatementList();
+    	
+    	String text = output(stmtList);
+    	
+    	Assert.assertEquals("KILL CONNECTION 233;", text);
+    }
+
+
+    private String output(List<SQLStatement> stmtList) {
+        StringBuilder out = new StringBuilder();
+
+        for (SQLStatement stmt : stmtList) {
+            stmt.accept(new MySqlOutputVisitor(out));
+            out.append(";");
+        }
+
+        return out.toString();
+    }
+}

src/test/java/com/alibaba/druid/bvt/sql/mysql/visitor/MySqlSchemaStatVisitorTest5.java

@@ -18,6 +18,7 @@ public class MySqlSchemaStatVisitorTest5 extends TestCase {
 				+ "  LEFT JOIN (select * from view_portal_panel) c  ON a.panel_id = c.panel_id   "
 				+ " WHERE     b.user_id = ? and     ((b.is_grid='y' and c.param_name='is_hidden' and c.param_value='false') or      b.is_grid  != 'y') and b.user_id in (select user_id from table1 where id = 1)    ORDER BY    a.col ASC, a.position ASC";
 
+		sql = "select columnName from table1 where id in (select id from table3 where name = ?)";
 		MySqlStatementParser parser = new MySqlStatementParser(sql);
 		List<SQLStatement> statementList = parser.parseStatementList();
 		SQLStatement statemen = statementList.get(0);

src/test/java/com/alibaba/druid/sql/performance/TestSelectPerformance.java

@@ -16,18 +16,21 @@
 package com.alibaba.druid.sql.performance;
 
 import java.text.NumberFormat;
+import java.util.List;
 
 import junit.framework.TestCase;
 
+import com.alibaba.druid.sql.ast.SQLStatement;
+import com.alibaba.druid.sql.dialect.mysql.visitor.MySqlSchemaStatVisitor;
 import com.alibaba.druid.sql.parser.SQLStatementParser;
 
 public class TestSelectPerformance extends TestCase {
 
-    private final int COUNT = 1000 * 1;
-    private String    sql   = "SELECT F100, F101, F102, F103, F104 FROM T_001 WHERE F100 = ?";
+    private final int COUNT = 1000 * 1000;
+    private String    sql   = "SELECT      distinct a.id \"id\",    a.col \"col\",     a.position \"position\",     a.panel_id \"panelId\"    FROM     (select * from view_position_info) a LEFT JOIN db1.view_portal b ON a.panel_id = b.panel_id       LEFT JOIN (select * from view_portal_panel) c  ON a.panel_id = c.panel_id    WHERE     b.user_id = ? and     ((b.is_grid='y' and c.param_name='is_hidden' and c.param_value='false') or      b.is_grid  != 'y') and b.user_id in (select user_id from table1 where id = 1)    ORDER BY    a.col ASC, a.position ASC";
 
     public void test_simple() throws Exception {
-        for (int i = 0; i < 1; ++i) {
+        for (int i = 0; i < 5; ++i) {
             f();
         }
     }
@@ -35,7 +38,10 @@ public class TestSelectPerformance extends TestCase {
     private void f() throws Exception {
         long start = System.currentTimeMillis();
         for (int i = 0; i < COUNT; ++i) {
-            new SQLStatementParser(sql).parseStatementList();
+        	List<SQLStatement> statementList =  new SQLStatementParser(sql).parseStatementList();
+            
+            MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor();
+            statementList.get(0).accept(visitor);
             // stmtList.toString();
         }
         long time = System.currentTimeMillis() - start;