Kevin的技术家园

import java.sql.*;
import java.io.*;
import java.util.*;
import javax.servlet.*;
import javax.servlet.http.*;
import com.jspsmart.upload.*;

public class UpLoad extends HttpServlet {

    private ServletConfig config;
    /**
     * Init the servlet
     */
    final public void init(ServletConfig config) throws ServletException {
        this.config = config;
    }

    final public ServletConfig getServletConfig() {
        return config;
    }

    public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doPost(request, response);
    }

    public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        System.out.println("============UpLoad begin ddd=============");
        String id = null;
        SmartUpload mySmartUpload = new SmartUpload();
        PrintWriter out = response.getWriter();
        java.io.File file=null;
        try {
            Class.forName("oracle.jdbc.driver.OracleDriver");
        } catch (java.lang.ClassNotFoundException e) {
            System.err.print("ClassNotFoundException: " + e.getMessage());
        }

        try {
            //Class.forName("oracle.jdbc.driver.OracleDriver");
            Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@10.216.0.2:1521:ORCL", "test", "test");

            conn.setAutoCommit(false); //设置手动提交，以提高性能。
            Statement stmt = conn.createStatement();
            // Initialization
            mySmartUpload.initialize(config, request, response);

            mySmartUpload.setMaxFileSize(500 * 1024);

            // Upload
            mySmartUpload.upload();

            //取得text框中的数据
            id = mySmartUpload.getRequest().getParameter("id");

            //取得文件和文件名
            com.jspsmart.upload.File myFile = mySmartUpload.getFiles().getFile(0);
            String fileName = myFile.getFileName();

            if (!myFile.isMissing()) {
                //save data
                myFile.saveAs(fileName, mySmartUpload.SAVE_PHYSICAL);
                System.out.println("============fileName=" + fileName + "====");
                file = new java.io.File(fileName);

                java.io.InputStream inStream = new java.io.FileInputStream(file);

                int fileSize = myFile.getSize();
                byte[] bytes = new byte[fileSize];
                System.out.println("============fileSize=" + fileSize + "====");

                //将数据插入到表中
                String strSql = "insert into test(id,name,content) values(’" + id + "’,’" + fileName + "’,empty_blob())";
                stmt.execute(strSql);

                ResultSet rs = stmt.executeQuery("select content from zyw_test where id=’" + id + "’ for update ");
                if (rs.next()) {
                    oracle.sql.BLOB blob = ( (oracle.jdbc.OracleResultSet) rs).getBLOB("content");
                    OutputStream outStream = blob.getBinaryOutputStream();
                    inStream.read(bytes);
                    outStream.write(bytes);
                    outStream.flush();
                    stmt.execute("commit");
                    outStream.close();
                }
                inStream.close();
                stmt.close();

                if(file!=null)//删除文件
                    file.delete();

                out.println("upload sucess");
            } else {
                out.println("no file");
            }
        } catch (Exception ex) {
            if(file!=null)
                file.delete();
            out.println("upload fail");
            ex.printStackTrace();
        }

        System.out.println("============UpLoad end=============");
    }
}

这是下载，进行显示图片

import java.sql.*;
import java.io.*;
import java.util.*;
import javax.servlet.*;
import javax.servlet.http.*;

public class DownLoad extends HttpServlet{
    public void doGet(HttpServletRequest request, HttpServletResponse response)
        throws ServletException, IOException {
        doPost(request,response);
    }
    public void doPost(HttpServletRequest request, HttpServletResponse response)
        throws ServletException, IOException {
        System.out.println("======DownLoad begin=====");
        try{
            Class.forName("oracle.jdbc.driver.OracleDriver");
            Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@10.216.0.2:1521:ORCL","test","test");
            Statement stmt=conn.createStatement();
            String id=request.getParameter("id");
            String sql="SELECT id, name, content FROM test where id=’"+id+"’";
            ResultSet rs=stmt.executeQuery(sql);
            if(rs.next()){
                Blob blob = rs.getBlob("content");
                byte[] ab = blob.getBytes(1, (int)blob.length());
                response.setContentType("image/jpeg");
                ServletOutputStream op = response.getOutputStream();
                op.write(ab);
                op.flush();
                op.close();
            }
        }catch(Exception ex){
            ex.printStackTrace();
        }
        System.out.println("======DownLoad end=====");
    }
}