sqlwarningchain.java

数据仓库工具

package com.internetcds.jdbc.tds;

import java.sql.SQLException;
import java.sql.SQLWarning;

/**
 * Helper class to redruce duplicated code.
 *
 * @author Stefan Bodewig <a href="mailto:[e-mail]">[e-mail]</a>
 *
 * @version  $Id: SQLWarningChain.java,v 1.1 2003/04/29 18:07:50 sinisa Exp $
 */
class SQLWarningChain  {
   public static final String cvsVersion = "$Id: SQLWarningChain.java,v 1.1 2003/04/29 18:07:50 sinisa Exp $";
   
   private SQLWarning warnings;
   
   SQLWarningChain () 
   {
      warnings = null;
   }
   
   /**
    * The first warning added with {@see #addWarning addWarning}.
    * Subsequent warnings will be chained to this SQLWarning.  
    */
    synchronized SQLWarning getWarnings() {
        return warnings;
    }

   /**
    * After this call {@see #getWarnings getWarnings} returns null
    * until {@see #addWarning addWarning} has been called again.  
    */
    synchronized void clearWarnings() {
        warnings = null;
    }

    /**
     * Adds a SQLWarning to the warning chain.
     */
    synchronized void addWarning(SQLWarning warn) {
        if (warnings == null) {
            warnings = warn;
        } else {
            warnings.setNextWarning(warn);
        }
    }

    /**
     * Adds the SQLWarning wrapped in the packet if it's not an ErrorResult.
     * Returns the wrapped SQLException otherwise.
     */
    SQLException addOrReturn(PacketMsgResult pack) {
        if (pack instanceof PacketErrorResult) {
            return pack.getMsg().toSQLException();
        } else {
            addWarning(pack.getMsg().toSQLWarning());
            return null;
        }
    }
}