jdbc 使用PreparedStatement来存储和读取大数据(Blob或Clob)

  //假设这里创建的数据库位use,而创建的表位luser import  java.io.*; import java.sql.*; public class DBB{ private  static  String driver ="com.mysql.jdbc.driver"; private  static  String url ="jdbc:mysql://localhost:3306/use"; private static  String user="root"; private static String pass="admin"; public static  void main(String[]args){ Connection con= null; PreparedStatement sta= null; ResultSet res= null; try{ //获取数据源 //假设就是从d盘中读取的一张照片； File file= new File("d:" + File.separator + "photo.jpg"); int length= (int)file.length(); InputStream input = new FileInputStream(file); //加载mysql驱动 Class.forName(driver); //取得连接对象 con= DriverManager.getConnection(url,user,pass); //取得操做对象 sta= con.prepareStatement("insert into luser values(?,?,?);"); //加载数据 sta.setInt(1,110); sta.setString(2,"namefile"); sta.setBinaryStream(3,input ,length); sta.executeUpdate(); sta.clearParameters(); input.close();//释放资源； }catch(SQLException e){ e.printStackTrace(); }catch(IOException e){ e.printStackTrace(); }catch(ClassNotFoundException e){ e.printStackTrace(); } finally{ if(con!=null){ try{ con.close(); }catch(SQLException e){   //(_)%^&**(_)(&*)(*#%$%^&*(()__)((( e.printStackTrace(); } } } Statement stat= null; try{ //数据的取得 stat= con.createStatement(); stat.executeQuery("select* from luser;"); res.next(); String filename= res.getString(2); Blob blob= res.getBlob(3); //把得到的数据写到指定的文件中 FileOutputStream out= new FileOutputStream("d:" + File.separator+ "dong" +".bak"); out.write(blob.getBytes(1,(int)blob.length())); out.flush();//把内存中的东西刷出来 out.close();//释放资源 }catch(SQLException e){ e.printStackTrace(); } catch(IOException e){ e.printStackTrace(); } finally{ if(stat!= null){ try{ stat.close(); }catch(SQLException e){ e.printStackTrace(); } } if(con!=null){ try{ con.close(); }catch(SQLException e){ e.printStackTrace(); } } } } }