搜索引擎

开发平台：

Java

ContentDAOImpl.java：源码内容

							package net.javacoding.jspider.core.storage.jdbc;
import net.javacoding.jspider.core.storage.spi.ContentDAOSPI;
import net.javacoding.jspider.core.storage.spi.StorageSPI;
import net.javacoding.jspider.core.logging.Log;
import net.javacoding.jspider.core.logging.LogFactory;
import java.io.InputStream;
import java.io.ByteArrayInputStream;
import java.sql.*;
/**
 * $Id: ContentDAOImpl.java,v 1.3 2003/04/11 16:37:05 vanrogu Exp $
 */
class ContentDAOImpl implements ContentDAOSPI {
    protected Log log;
    protected DBUtil dbUtil;
    protected StorageSPI storage;
    public ContentDAOImpl ( StorageSPI storage, DBUtil dbUtil ) {
        this.log = LogFactory.getLog(ContentDAOSPI.class);
        this.dbUtil = dbUtil;
        this.storage = storage;
    }
    public void setBytes ( int id, byte[] bytes ) {
        try {
            Connection connection = dbUtil.getConnection();
            PreparedStatement ps = connection.prepareStatement("insert into jspider_content ( id, content ) values ( ?, ? )");
            ps.setInt(1, id);
            ps.setBytes(2, bytes);
            try {
                ps.execute();
            } catch (IllegalArgumentException e) {
                log.error("IllegalArgumentException", e);
            } finally {
                dbUtil.safeClose(ps, log);
            }
        } catch (SQLException e) {
            log.error("SQLException", e);
        }
    }
    public InputStream getInputStream(int id) {
        byte[] bytes = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            Connection connection = dbUtil.getConnection();
            ps = connection.prepareStatement("select content from jspider_content where id=?");
            ps.setInt(1, id);
            rs = ps.executeQuery();
            if ( rs.next() ) {
              bytes = rs.getBytes("content");
            }
        } catch (SQLException e) {
            log.error("SQLException", e);
        } finally {
            dbUtil.safeClose(rs, log);
            dbUtil.safeClose(ps, log);
        }
        return new ByteArrayInputStream ( bytes );
    }
}

						