Alawn/Druid
1
0
Fork 0
mirror of https://github.com/alibaba/druid.git synced 2023-03-04 19:17:16 +00:00
Code Issues Releases Wiki Activity

Merge pull request #597 from yakolee/master

Browse Source 
support oracle update/delete/insert hints
This commit is contained in:
Yako
2014-07-31 18:29:33 +08:00
parent 6e2c3be1ad 95e0dd5512
commit 1ddeece1cd
4 changed files with 90 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlSelectTest_19.java
-2
View File
@@ -23,8 +23,6 @@ import com.alibaba.druid.sql.MysqlTest;
import com.alibaba.druid.sql.ast.SQLStatement;
import com.alibaba.druid.sql.dialect.mysql.parser.MySqlStatementParser;
import com.alibaba.druid.sql.dialect.mysql.visitor.MySqlSchemaStatVisitor;
import com.alibaba.druid.stat.TableStat;
import com.alibaba.druid.stat.TableStat.Column;
public class MySqlSelectTest_19 extends MysqlTest {
src/test/java/com/alibaba/druid/bvt/sql/oracle/OracleHintTest.java
+37
View File
@@ -3,12 +3,14 @@ package com.alibaba.druid.bvt.sql.oracle;
import java.util.List;
import com.alibaba.druid.sql.PagerUtils;
import com.alibaba.druid.sql.SQLUtils;
import com.alibaba.druid.sql.ast.SQLStatement;
import com.alibaba.druid.sql.dialect.oracle.parser.OracleStatementParser;
import com.alibaba.druid.sql.dialect.oracle.visitor.OracleOutputVisitor;
import com.alibaba.druid.util.JdbcUtils;
import org.junit.Assert;
import junit.framework.TestCase;
public class OracleHintTest extends TestCase {
@@ -33,4 +35,39 @@ public class OracleHintTest extends TestCase {
String countSQL = PagerUtils.count(sql, JdbcUtils.ORACLE);
Assert.assertEquals("SELECT /*+leading(e) index(e ORD_ORDER_ITEM_GS_BS_DI_IND)*/ DISTINCT COUNT(*)\nFROM ord_order_item e\nWHERE e.F1 = DATE '2011-10-01'", countSQL);
}
public void test_hint3() throws Exception {
String sql = "SELECT /*+index(a MTN_SMS_LOG_PK)*/ * from MTN_SMS_LOG a";
String formattedSql = SQLUtils.formatOracle(sql);
Assert.assertEquals("SELECT /*+index(a MTN_SMS_LOG_PK)*/ *" + "\nFROM MTN_SMS_LOG a", formattedSql);
}
public void test_hint4() throws Exception {
String sql = "UPDATE /*+index(a MTN_SMS_LOG_PK)*/  MTN_SMS_LOG  a SET GMT_MODIFIED = sysdate WHERE id=1";
String formattedSql = SQLUtils.formatOracle(sql);
Assert.assertEquals("UPDATE /*+index(a MTN_SMS_LOG_PK)*/ MTN_SMS_LOG a"
+ "\nSET GMT_MODIFIED = SYSDATE"
+ "\nWHERE id = 1", formattedSql);
}
public void test_hint5() throws Exception {
String sql = "SELECT /*+index(clk) use_nl(clk) */ distinct log.id log_id from t";
String formattedSql = SQLUtils.formatOracle(sql);
Assert.assertEquals("SELECT /*+index(clk) use_nl(clk) */ DISTINCT log.id AS log_id" + "\nFROM t", formattedSql);
}
public void test_hint6() throws Exception {
String sql = "insert /*+APPEND*/ into emp_new select a.no, sysdate, a.name, b.service_duration from emp a, work b where a.no=b.no";
String formattedSql = SQLUtils.formatOracle(sql);
Assert.assertEquals("INSERT /*+APPEND*/ INTO emp_new" + "\nSELECT a.no, SYSDATE, a.name, b.service_duration"
+ "\nFROM emp a, work b" + "\nWHERE a.no = b.no", formattedSql);
}
public void test_hint7() throws Exception {
String sql = "delete /*+PARALLEL(semp, 5) */ from semp";
String formattedSql = SQLUtils.formatOracle(sql);
Assert.assertEquals("DELETE /*+PARALLEL(semp, 5) */ FROM semp", formattedSql);
}
}