import com.alibaba.druid.sql.parser.ParserException; //导入依赖的package包/类
public static void preCheckPrePareSQL(Configuration originalConfig, DataBaseType type) {
    List<Object> conns = originalConfig.getList(Constant.CONN_MARK, Object.class);
    Configuration connConf = Configuration.from(conns.get(0).toString());
    String table = connConf.getList(Key.TABLE, String.class).get(0);

    List<String> preSqls = originalConfig.getList(Key.PRE_SQL,
            String.class);
    List<String> renderedPreSqls = WriterUtil.renderPreOrPostSqls(
            preSqls, table);

    if (null != renderedPreSqls && !renderedPreSqls.isEmpty()) {
        LOG.info("Begin to preCheck preSqls:[{}].",
                StringUtils.join(renderedPreSqls, ";"));
        for(String sql : renderedPreSqls) {
            try{
                DBUtil.sqlValid(sql, type);
            }catch(ParserException e) {
                throw RdbmsException.asPreSQLParserException(type,e,sql);
            }
        }
    }
}
 

import com.alibaba.druid.sql.parser.ParserException; //导入依赖的package包/类
public static void preCheckPostSQL(Configuration originalConfig, DataBaseType type) {
    List<Object> conns = originalConfig.getList(Constant.CONN_MARK, Object.class);
    Configuration connConf = Configuration.from(conns.get(0).toString());
    String table = connConf.getList(Key.TABLE, String.class).get(0);

    List<String> postSqls = originalConfig.getList(Key.POST_SQL,
            String.class);
    List<String> renderedPostSqls = WriterUtil.renderPreOrPostSqls(
            postSqls, table);
    if (null != renderedPostSqls && !renderedPostSqls.isEmpty()) {

        LOG.info("Begin to preCheck postSqls:[{}].",
                StringUtils.join(renderedPostSqls, ";"));
        for(String sql : renderedPostSqls) {
            try{
                DBUtil.sqlValid(sql, type);
            }catch(ParserException e){
                throw RdbmsException.asPostSQLParserException(type,e,sql);
            }

        }
    }
}
 

import com.alibaba.druid.sql.parser.ParserException; //导入依赖的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.parser.ParserException; //导入依赖的package包/类
private BindSql processToPageSQL(String sql, PageLimit offsetLimit) {
	SQLServerSelectParser parser = new SQLServerSelectParser(sql);
	try{
		SQLSelect select = parser.select();
		if(select.getQuery() instanceof SQLUnionQuery){
			return toPage(offsetLimit,(SQLUnionQuery)select.getQuery(),select,sql);
		}else{
			return toPage(offsetLimit,(SQLServerSelectQueryBlock)select.getQuery(),select ,sql);
		}
	}catch(ParserException ex){
		LogUtil.error(sql, ex);
		throw ex;
	}
}
 

import com.alibaba.druid.sql.parser.ParserException; //导入依赖的package包/类
private void parseErrorLoging(OracleUpdateStatement update) {
    if (lexer.identifierEquals("LOG")) {
        throw new ParserException("TODO. " + lexer.info());
    }
}