import com.alibaba.druid.sql.dialect.oracle.parser.OracleStatementParser; //导入依赖的package包/类
@Override
public void statementParse(SchemaConfig schema, RouteResultset rrs, SQLStatement stmt) {
	SQLSelectStatement selectStmt = (SQLSelectStatement)stmt;
	SQLSelectQuery sqlSelectQuery = selectStmt.getSelect().getQuery();
      //从mysql解析过来
	if(sqlSelectQuery instanceof MySqlSelectQueryBlock) {
		MySqlSelectQueryBlock mysqlSelectQuery = (MySqlSelectQueryBlock)selectStmt.getSelect().getQuery();
		Limit limit=mysqlSelectQuery.getLimit();
		if(limit==null)
		{
			  //使用oracle的解析，否则会有部分oracle语法识别错误
			  OracleStatementParser oracleParser = new OracleStatementParser(getCtx().getSql());
			  SQLSelectStatement oracleStmt = (SQLSelectStatement) oracleParser.parseStatement();
               selectStmt= oracleStmt;
			  SQLSelectQuery oracleSqlSelectQuery = oracleStmt.getSelect().getQuery();
			  if(oracleSqlSelectQuery instanceof OracleSelectQueryBlock)
			  {
				  parseNativePageSql(oracleStmt, rrs, (OracleSelectQueryBlock) oracleSqlSelectQuery, schema);
			  }



		  }
		if(isNeedParseOrderAgg)
		{
			parseOrderAggGroupMysql(schema, selectStmt,rrs, mysqlSelectQuery);
			//更改canRunInReadDB属性
			if ((mysqlSelectQuery.isForUpdate() || mysqlSelectQuery.isLockInShareMode()) && rrs.isAutocommit() == false)
			{
				rrs.setCanRunInReadDB(false);
			}
		}

	}


}
 

import com.alibaba.druid.sql.dialect.oracle.parser.OracleStatementParser; //导入依赖的package包/类
private Map parseOneIdx(String idx)
{
  Map map = new HashMap();
  OracleStatementParser parser = new OracleStatementParser(idx);
  OracleCreateIndexStatement statement = parser.parseCreateIndex(true);
  SQLExprTableSource tableSource = (SQLExprTableSource) statement.getTable();
  String tableName = ((SQLPropertyExpr) tableSource.getExpr()).getSimleName().toLowerCase();
  String idxType = statement.getType();
  List<SQLSelectOrderByItem> items = statement.getItems();
  List fields = new ArrayList();
  for (SQLSelectOrderByItem item : items)
  {
    SQLIdentifierExpr expr = (SQLIdentifierExpr) item.getExpr();
    fields.add(expr.getSimleName().toLowerCase());
  }
  if ("unique".equalsIgnoreCase(idxType))
    map.put(tableName, fields);
  return map;
}
 

import com.alibaba.druid.sql.dialect.oracle.parser.OracleStatementParser; //导入依赖的package包/类
public static SQLStatementParser createSQLStatementParser(String sql, String dbType, SQLParserFeature... features) {
    if (JdbcConstants.ORACLE.equals(dbType) || JdbcConstants.ALI_ORACLE.equals(dbType)) {
        return new OracleStatementParser(sql);
    }

    if (JdbcConstants.MYSQL.equals(dbType)) {
        return new MySqlStatementParser(sql, features);
    }

    if (JdbcConstants.MARIADB.equals(dbType)) {
        return new MySqlStatementParser(sql, features);
    }

    if (JdbcConstants.POSTGRESQL.equals(dbType)
            || JdbcConstants.ENTERPRISEDB.equals(dbType)) {
        return new PGSQLStatementParser(sql);
    }

    if (JdbcConstants.SQL_SERVER.equals(dbType) || JdbcConstants.JTDS.equals(dbType)) {
        return new SQLServerStatementParser(sql);
    }

    if (JdbcConstants.H2.equals(dbType)) {
        return new H2StatementParser(sql);
    }
    
    if (JdbcConstants.DB2.equals(dbType)) {
        return new DB2StatementParser(sql);
    }
    
    if (JdbcConstants.ODPS.equals(dbType)) {
        return new OdpsStatementParser(sql);
    }

    if (JdbcConstants.PHOENIX.equals(dbType)) {
        return new PhoenixStatementParser(sql);
    }

    if (JdbcConstants.HIVE.equals(dbType)) {
        return new HiveStatementParser(sql);
    }

    if (JdbcConstants.ELASTIC_SEARCH.equals(dbType)) {
        return new MySqlStatementParser(sql);
    }

    return new SQLStatementParser(sql, dbType);
}
 

import com.alibaba.druid.sql.dialect.oracle.parser.OracleStatementParser; //导入依赖的package包/类
private static SQLStatement parseSql(String sql) {
    String convertSql = trimPattern.matcher(sql).replaceAll("xtrim");
    SQLStatementParser parser = new OracleStatementParser(convertSql);
    List<SQLStatement> stmtList;
    try {
        stmtList = parser.parseStatementList();
    } catch (ParserException exception) {
        exception.printStackTrace();
        throw new RuntimeException(sql + " is invalid, detail " + exception.getMessage());
    }

    return stmtList.get(0);
}
 

import com.alibaba.druid.sql.dialect.oracle.parser.OracleStatementParser; //导入依赖的package包/类
private static SQLStatementParser getSQLStatementParser(DatabaseType databaseType,final String sql) {
    switch (databaseType) {
        case MySQL: 
            return new MySqlStatementParser(sql);
        case PostgreSQL:
        	return new PGSQLStatementParser(sql);
        case Oracle:
        	return new OracleStatementParser(sql);
        default: 
            throw new UnsupportedOperationException(String.format("Cannot support database type [%s]", databaseType));
    }
}
 

import com.alibaba.druid.sql.dialect.oracle.parser.OracleStatementParser; //导入依赖的package包/类
@Test
public void testDruidParser(){
	String sql = "select t.rowid from (select col1,col2,col3 from person_table where age>12 and name='asss' and schoolId||'tomo'||schoolId  =? order by item) t";
	OracleStatementParser s=new OracleStatementParser(sql);
	SQLSelectStatement select=s.parseSelect();
	System.out.println(select);
}
 

import com.alibaba.druid.sql.dialect.oracle.parser.OracleStatementParser; //导入依赖的package包/类
@Test
public void testTrimxResult() {
    SQLStatementParser parser = new OracleStatementParser(trimxSql);
    parser.parseStatementList();
}
 

import com.alibaba.druid.sql.dialect.oracle.parser.OracleStatementParser; //导入依赖的package包/类
@Test//(expected = ParserException.class)
// ParserException: syntax error, expect FROM, actual RPAREN CERT_CHECK_RSP_CODE
public void testTrimResultBug() {
    SQLStatementParser parser = new OracleStatementParser(trimSql);
    parser.parseStatementList();
}
 

import com.alibaba.druid.sql.dialect.oracle.parser.OracleStatementParser; //导入依赖的package包/类
@Test
public void testInterval() throws Exception {
    new OracleStatementParser(intervalSql).parseStatementList();
}
 

import com.alibaba.druid.sql.dialect.oracle.parser.OracleStatementParser; //导入依赖的package包/类
@Test(expected = Exception.class)
public void testFunction() {
	OracleStatementParser parser = new OracleStatementParser("select upper(*) from aa order by now()");
	SQLStatement st = parser.parseStatement();
	System.out.println(st);
}