cocoon-cvs mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From h...@apache.org
Subject cvs commit: xml-cocoon2/src/java/org/apache/cocoon/components/language/markup/xsp EsqlHelper.java
Date Fri, 05 Jul 2002 14:43:14 GMT
haul        2002/07/05 07:43:14

  Modified:    src/java/org/apache/cocoon/components/language/markup/xsp
                        Tag: cocoon_2_0_3_branch EsqlHelper.java
  Log:
  Support xLOBs with CallableStatements
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.7.2.2   +117 -1    xml-cocoon2/src/java/org/apache/cocoon/components/language/markup/xsp/EsqlHelper.java
  
  Index: EsqlHelper.java
  ===================================================================
  RCS file: /home/cvs/xml-cocoon2/src/java/org/apache/cocoon/components/language/markup/xsp/EsqlHelper.java,v
  retrieving revision 1.7.2.1
  retrieving revision 1.7.2.2
  diff -u -r1.7.2.1 -r1.7.2.2
  --- EsqlHelper.java	4 Jun 2002 09:37:17 -0000	1.7.2.1
  +++ EsqlHelper.java	5 Jul 2002 14:43:14 -0000	1.7.2.2
  @@ -53,8 +53,10 @@
   import java.io.BufferedInputStream;
   import java.io.BufferedReader;
   import java.io.Reader;
  +import java.sql.CallableStatement;
   import java.sql.ResultSet;
   import java.io.InputStream;
  +import java.sql.Blob;
   import java.sql.Clob;
   import java.sql.Types;
   
  @@ -70,6 +72,71 @@
   public class EsqlHelper {
   
   
  +    /** returns byte array from BLOB
  +     */
  +    public final static byte[] getBlob(ResultSet set, String column) throws RuntimeException
{
  +        
  +        byte[] result = null;
  +        try {
  +            result = EsqlHelper.getBlob(set,set.findColumn(column));
  +        } catch (Exception e) {
  +            throw new RuntimeException("Error getting blob data: " + e.getMessage());
  +        }
  +        return result;
  +    }
  +
  +    /** returns byte array from BLOB
  +     */
  +    public final static byte[] getBlob(ResultSet set, int column) throws java.lang.Exception
{
  +        
  +        InputStream reader = null;
  +        byte[] buffer = null;
  +    
  +        try {
  +            if (set.getMetaData().getColumnType(column)==java.sql.Types.BLOB) {
  +                Blob dbBlob = set.getBlob(column);
  +                int length = (int) dbBlob.length();
  +                reader = dbBlob.getBinaryStream();
  +                buffer = new byte[length];
  +                reader.read(buffer);
  +                reader.close();
  +                if (reader != null)
  +                    reader.close();
  +                if (buffer == null)
  +                    return null;
  +                return buffer;
  +            } else {           
  +                return set.getString(column).getBytes();
  +            }
  +        } catch ( Exception e) {
  +            throw new RuntimeException("Error getting blob data: " + e.getMessage());
  +        }
  +    }
  +
  +    /** returns byte array from BLOB
  +     */
  +    public final static byte[] getBlob(CallableStatement cs, int column) throws java.lang.Exception
{
  +        
  +        InputStream reader = null;
  +        byte[] buffer = null;
  +    
  +        try {
  +            Blob dbBlob = cs.getBlob(column);
  +            int length = (int) dbBlob.length();
  +            reader = dbBlob.getBinaryStream();
  +            buffer = new byte[length];
  +            reader.read(buffer);
  +            reader.close();
  +            if (reader != null)
  +                reader.close();
  +            if (buffer == null)
  +                return null;
  +            return buffer;
  +        } catch ( Exception e) {
  +            throw new RuntimeException("Error getting blob data: " + e.getMessage());
  +        }
  +    }
  +
       /** returns Unicode encoded string from CLOB or String column 
        */
       public final static String getStringOrClob(ResultSet set, String column) throws RuntimeException
{
  @@ -112,6 +179,30 @@
           }
       }
   
  +    /** returns Unicode encoded string from CLOB or String column 
  +     */
  +    public final static String getStringOrClob(CallableStatement cs, int column) throws
java.lang.Exception {
  +        
  +        Reader reader = null;
  +        char[] buffer = null;
  +    
  +        try {
  +            Clob dbClob = cs.getClob(column);
  +            int length = (int) dbClob.length();
  +            reader = new BufferedReader(dbClob.getCharacterStream());
  +            buffer = new char[length];
  +            reader.read(buffer);
  +            reader.close();
  +            if (reader != null)
  +                reader.close();
  +            if (buffer == null)
  +                return "";
  +            return new String(buffer);
  +        } catch ( Exception e) {
  +            throw new RuntimeException("Error getting clob data: " + e.getMessage());
  +        }
  +    }
  +
   
       /** returns ascii string from CLOB or String column 
        */
  @@ -154,6 +245,31 @@
               }
           }
           
  +        return result;
  +      }
  +
  +    /** returns ascii string from CLOB or String column 
  +     */
  +    public final static String getAscii(CallableStatement cs, int column) {
  +        InputStream asciiStream = null;
  +        String result = null;
  +
  +        try {
  +            byte[] buffer = null;
  +            Clob dbClob = cs.getClob(column);
  +            int length = (int) dbClob.length();
  +            asciiStream = new BufferedInputStream(dbClob.getAsciiStream());
  +            buffer = new byte[length];
  +            asciiStream.read(buffer);
  +            asciiStream.close();
  +            result = (buffer!=null? new String(buffer) : null);
  +        } catch (Exception e) {
  +            throw new RuntimeException("Error getting clob data: " + e.getMessage());
  +        } finally {
  +            if (asciiStream != null) try {asciiStream.close();} catch (Exception ase) {
  +                throw new RuntimeException("Error closing clob stream: " + ase.getMessage());
  +            }
  +        }
           
           return result;
         }
  
  
  

----------------------------------------------------------------------
In case of troubles, e-mail:     webmaster@xml.apache.org
To unsubscribe, e-mail:          cocoon-cvs-unsubscribe@xml.apache.org
For additional commands, e-mail: cocoon-cvs-help@xml.apache.org


Mime
View raw message