public BlobSource(String url,
    ComponentManager manager) throws MalformedURLException 
{
    
        super(manager);
        if (!url.startsWith("blob:/")) {
            throw new MalformedURLException("Malformed url for a blob source : " + url);
        }
        this.systemId = url;
        // Parse the url
        int start = URL_PREFIX_LEN;
        int end;
        // Datasource
        end = url.indexOf('/", start);
        if (end == -1) {
            throw new MalformedURLException("Malformed blob source (cannot find datasource) : " + url);
        }
        this.datasourceName = url.substring(start, end);
        // Table
        start = end + 1;
        end = url.indexOf('/", start);
        if (end == -1) {
            throw new MalformedURLException("Malformed blob source (cannot find table name) : " + url);
        }
        this.tableName = url.substring(start, end);
        // Column
        start = end + 1;
        end = url.indexOf('[", start);
        if (end == -1) {
            this.columnName = url.substring(start);
        } else {
            this.columnName = url.substring(start, end);
            // Condition
            start = end + 1;
            end = url.length() - 1;
            if (url.charAt(end) != ']") {
                throw new MalformedURLException("Malformed url for a blob source (cannot find condition) : " + url);
            } else {
                this.condition = url.substring(start, end);
            }
        }
}

Create a file source from a 'blob:' url and a component manager.

The url is of the form "blob:/datasource/table/column[condition]

 public InputStream getInputStream() throws IOException, ProcessingException 
{
        if (getLogger().isDebugEnabled()) {
            getLogger().debug("Opening stream for datasource " + this.datasourceName +
                ", table " + this.tableName + ", column " + this.columnName +
                (this.condition == null ? ", no condition" : ", condition " + this.condition)
            );
        }
        Connection cnx = null;
        Statement stmt = null;
        try {
            cnx = getConnection();
            stmt = cnx.createStatement();
            StringBuffer selectBuf = new StringBuffer("SELECT ").append(this.columnName).
                append(" FROM ").append(this.tableName);
            if (this.condition != null) {
                selectBuf.append(" WHERE ").append(this.condition);
            }
            String select = selectBuf.toString();
            if (getLogger().isDebugEnabled()) {
                getLogger().debug("Executing statement " + select);
            }
            ResultSet rs = stmt.executeQuery(select);
            rs.next();
            int colType = rs.getMetaData().getColumnType(1);
            switch(colType) {
                case Types.BLOB :
                    Blob blob = rs.getBlob(1);
                    return new JDBCInputStream(blob.getBinaryStream(), cnx);
                //break;
                case Types.CLOB :
                    Clob clob = rs.getClob(1);
                    return new JDBCInputStream(clob.getAsciiStream(), cnx);
                //break;
                case Types.LONGVARBINARY :
                case Types.VARBINARY :
                    return new JDBCInputStream(rs.getBinaryStream(1), cnx);
                //break;
                default :
                    String value = rs.getString(1);
                    stmt.close();
                    rs.close();
                    cnx.close();
                    return new ByteArrayInputStream(value.getBytes());
            }
        } catch(SQLException sqle) {
            String msg = "Cannot retrieve content from " + this.systemId;
            getLogger().error(msg, sqle);
            try {
                if (cnx != null) {
                    cnx.close();
                }
            } catch(SQLException sqle2) {
                // PITA
                throw new ProcessingException("Cannot close connection", sqle2);
            }
            // IOException would be more adequate, but ProcessingException is cascaded...
            throw new ProcessingException(msg, sqle);
        }
}

Get the input stream for this source.

 public String getSystemId() 
{
        return this.systemId;
}

Return the unique identifer for this source