0

我假设简单的答案是否定的，但想知道是否有一个 Java 忍者可能知道一个聪明的黑客......更具体地说，我的问题是我正在尝试创建可以从其他数据库中提取/恢复数据库的自动化数据格式（xml、另一个数据库供应商、json...）。我试图将供应商特定代码的范围限制为一个*Adapter类。界面是：

public String escapeName( String name );

public ColumnMetaData columnMetaDataFromResultSet( ResultSet resultSet ) throws SQLException;

public SqlQuery getColumnMetaDataSql( String schema, String table );

public String getCreateTableSql( TableMetaData tableMetaData );

public String getDropTableSql( TableMetaData tableMetaData );

public String getRowInsertSql( TableMetaData tableMetaData );

public String getRowSelectSql( TableMetaData tableMetaData );

public SqlQuery getTableMetaDataSql();

public TableMetaData tableMetaDataFromResultSet( ResultSet resultSet ) throws SQLException;

这个问题的重要方法是getDropTableSql( TableMetaData tableMetaData )。该方法理论上将返回一个 SQL 语句，该语句将删除元数据指示的表，以便可以重新创建它（这用于在固定期限的基础上发布完整的数据集，因此，旧的，新的）。MySQL 和 SQLServer 的适配器都支持某种安全的DROP（DROP table IF EXISTS或类似的），但 Oracle 和 DB2 不支持。所以我的下一个想法是放弃它并捕获适当的异常。但是抛出的异常是java.sql.SQLSyntaxErrorException（或者org.springframework.jdbc.BadSqlGrammarException因为我使用的是弹簧JdbcTemplate）。那个异常系列似乎很广泛，可以安全地捕获（而且它对我来说似乎并不像语法......）。每个供应商似乎返回不同的 SQLState 和 ErrorCode，所以除非我也能确定供应商，否则这些并没有多大帮助。那么，我可以吗？我知道spring会以某种方式做到这一点，很可能是从DataSource发出查询的那个中挖掘出来的。只是还没有想通。

- - - - - - - - - - - 更新 - - - - - - - - - - - - - -

我能够用这段代码实现我的目标：

private void dropTable( JdbcTemplate jdbcTemplate, String dropSql ) {
    try {
        jdbcTemplate.execute( dropSql );
    }
    catch ( BadSqlGrammarException sqle ) {
        try {
            throw sqle.getRootCause();
        }
        catch ( SQLException rootCause ) {
            int errorCode = rootCause.getErrorCode();
            String sqlState = rootCause.getSQLState();

            try {
                String vendor = jdbcTemplate.getDataSource().getConnection().getMetaData().getDatabaseProductName();

                if ( vendor.equalsIgnoreCase( "mysql" ) && errorCode == 1051 && sqlState.equals( "42S02" ) ) {
                    logger.info( "mysql table does not exist, unable to drop ({})", dropSql );
                }
                else if ( vendor.equalsIgnoreCase( "oracle" ) && errorCode == 942 && sqlState.equals( "42000" ) ) {
                    logger.info( "oracle table does not exist, unable to drop ({})", dropSql );
                }
                else {
                    throw( sqle );
                }
            }
            catch ( Exception e ) {
                throw( sqle );
            }
        }
        catch ( Throwable e ) {
            throw sqle;
        }
    }
}
4

1 回答 1

3

您可以使用 . 检查数据库供应商的名称DatabaseMetaData.getDatabaseProductName()。

这样你就不需要“分析”异常

于 2012-08-31T23:16:34.730 回答