天使不喜欢看代码

package com.fengchunhua.sqltools;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.mysql.jdbc.Blob;

public class LotoOfMenmoneyBLOBIntoDB {
	private static Connection conn = JDBCConnectTools.getMySQLConnection();
	/**
	 * @param args
	 * @throws SQLException 
	 * @throws IOException 
	 */
	public static void main(String[] args) throws SQLException, IOException {
		LotoOfMenmoneyBLOBIntoDB db = new LotoOfMenmoneyBLOBIntoDB();
		db.insertIntoDB();
		db.getBlob();
		conn.commit();
  
	}	
	public void setConn(Connection conn){
		this.conn = conn;
	}
	public void setSql(String sql){
		
	}
	public void insertIntoDB() throws SQLException, IOException{
         try {  
   
             //创建一个PreparedStatement实例  
             PreparedStatement pstmt=conn.prepareStatement("insert into typetest (id,name,tid,nameblob) values(1,'mao','1001',?)");  
             File file = new File("D:\\mydoc\\workspace\\SQLsmallPage\\a.jpg") ;  
             FileInputStream fis = new FileInputStream(file);              
             //把输入流设置为预处理语句的对象。 
             System.out.println(file.length());
             pstmt.setBinaryStream(1, fis, (int)file.length());        
             //执行更新  
             pstmt.executeUpdate();                    
             pstmt.close();  
             fis.close();  
   
         }  
         catch(Exception e)  
         {  
             e.printStackTrace();  
         }  

	}
	public void getBlob() throws SQLException{
		
		try{
	             //创建一个Statement实例  
	             Statement stmt=conn.createStatement();  
	             ResultSet rst=stmt.executeQuery("select * from typetest where id=1");  
	             rst.next();   
	             //获得blob数据和它的输入流，然后通过输入流把数据写到文件中。         
	             Blob blob = (Blob) rst.getBlob("nameblob") ;  
	             FileOutputStream out=new FileOutputStream(new File("D:\\mydoc\\workspace\\SQLsmallPage\\d.jpg"));  
	             InputStream in=blob.getBinaryStream();  
	             int i;  
	             while((i=in.read())!=-1)  
	             out.write(i);  
	             //关闭输入、输出流.  
	             in.close();  
	             out.close();  
	   
	         } catch(Exception e){  
	             e.printStackTrace();  
	               
	         }  

	}

}