diff --git a/src/main/java/com/alibaba/druid/sql/ast/SQLStatementImpl.java b/src/main/java/com/alibaba/druid/sql/ast/SQLStatementImpl.java index 7f7ae9a420..e800cb3d3a 100644 --- a/src/main/java/com/alibaba/druid/sql/ast/SQLStatementImpl.java +++ b/src/main/java/com/alibaba/druid/sql/ast/SQLStatementImpl.java @@ -1,36 +1,37 @@ -/* - * 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.sql.ast; - -import com.alibaba.druid.sql.visitor.SQLASTVisitor; - -public abstract class SQLStatementImpl extends SQLObjectImpl implements SQLStatement { - - private static final long serialVersionUID = 1L; - - public SQLStatementImpl(){ - - } - - public void output(StringBuffer buf) { - buf.append(super.toString()); - } - - @Override - protected void accept0(SQLASTVisitor visitor) { - throw new UnsupportedOperationException(this.getClass().getName()); - } -} +/* + * 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.sql.ast; + +import com.alibaba.druid.sql.SQLUtils; +import com.alibaba.druid.sql.visitor.SQLASTVisitor; + +public abstract class SQLStatementImpl extends SQLObjectImpl implements SQLStatement { + + private static final long serialVersionUID = 1L; + + public SQLStatementImpl(){ + + } + + public String toString() { + return SQLUtils.toSQLString(this); + } + + @Override + protected void accept0(SQLASTVisitor visitor) { + throw new UnsupportedOperationException(this.getClass().getName()); + } +} diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oracle/OracleMergeTest7.java b/src/test/java/com/alibaba/druid/bvt/sql/oracle/OracleMergeTest7.java new file mode 100644 index 0000000000..8085e5b8c7 --- /dev/null +++ b/src/test/java/com/alibaba/druid/bvt/sql/oracle/OracleMergeTest7.java @@ -0,0 +1,61 @@ +/* + * 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.oracle; + +import java.util.List; + +import org.junit.Assert; + +import com.alibaba.druid.sql.OracleTest; +import com.alibaba.druid.sql.SQLUtils; +import com.alibaba.druid.sql.ast.SQLStatement; +import com.alibaba.druid.sql.dialect.oracle.ast.stmt.OracleMergeStatement; +import com.alibaba.druid.sql.dialect.oracle.parser.OracleStatementParser; +import com.alibaba.druid.sql.parser.SQLStatementParser; + +public class OracleMergeTest7 extends OracleTest { + + public void test_0() throws Exception { + String sql = "MERGE INTO copy_emp c " + // + "USING employees e " + // + "ON (c.employee_id=e.employee_id) " + // + "WHEN MATCHED THEN " + // + "UPDATE SET " + // + "c.first_name=e.first_name, " + // + "c.last_name=e.last_name, " + // + "c.department_id=e.department_id " + // + "WHEN NOT MATCHED THEN " + // + "INSERT VALUES(e.employee_id,e.first_name,e.last_name," + // + "e.email,e.phone_number,e.hire_date,e.job_id, " + // + "e.salary,e.commission_pct,e.manager_id,e.department_id)"; + + SQLStatementParser parser = new OracleStatementParser(sql); + List stmtList = parser.parseStatementList(); + OracleMergeStatement mergeStatement = (OracleMergeStatement) stmtList.get(0); + String result = SQLUtils.toOracleString(mergeStatement); + Assert.assertEquals("MERGE INTO copy_emp c" // + + "\nUSING employees e ON c.employee_id = e.employee_id" // + + "\nWHEN MATCHED THEN UPDATE SET c.first_name = e.first_name, c.last_name = e.last_name, c.department_id = e.department_id" // + + "\nWHEN NOT MATCHED THEN INSERT VALUES (e.employee_id, e.first_name, e.last_name, e.email, e.phone_number, e.hire_date, e.job_id, e.salary, e.commission_pct, e.manager_id, e.department_id)", + result); + // Assert.assertTrue(visitor.getColumns().contains(new TableStat.Column("employees", "employee_id"))); + // Assert.assertTrue(visitor.getColumns().contains(new TableStat.Column("employees", "salary"))); + // Assert.assertTrue(visitor.getColumns().contains(new TableStat.Column("employees", "department_id"))); + // Assert.assertTrue(visitor.getColumns().contains(new TableStat.Column("bonuses", "employee_id"))); + // Assert.assertTrue(visitor.getColumns().contains(new TableStat.Column("bonuses", "bonus"))); + } + +}