| 
         
          package com.kevin.mysql; 
          /* 
          * mysql 插入blog的例子 
          * 
          */ 
          import java.io.*; 
          import java.sql.*; 
                                                               
          public class DBTest { 
            public static void main(String[] args) { 
              String driver = "com.mysql.jdbc.Driver"; 
              String url = "jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=GBK"; 
              String user = "root"; 
              String password = ""; 
              try { 
                  Class.forName(driver); 
                  Connection conn = DriverManager.getConnection(url, user, password); 
           
                 
                  File file = new File("./laurapausini.jpg"); 
                  int length = (int) file.length(); 
                  InputStream fin = new FileInputStream(file); 
           
                 
                  PreparedStatement pstmt = conn.prepareStatement( 
                        "INSERT INTO files(description,filecontent) VALUES(?, ?)"); 
                  pstmt.setString(1, "Logo"); 
                  pstmt.setBinaryStream (2, fin, length); 
                  pstmt.executeUpdate(); 
                  pstmt.clearParameters(); 
                  pstmt.close(); 
                  fin.close(); 
           
                /* 
                  * 读取blob输出到文件 
                  */ 
                  Statement stmt = conn.createStatement(); 
                  ResultSet result = stmt.executeQuery("SELECT * FROM files"); 
                  result.next(); 
                  String description = result.getString(1); 
                  Blob blob = result.getBlob(2); 
           
                   
                  System.out.println("描述:" + description); 
                  FileOutputStream fout = new FileOutputStream("./laurapausini2.jpg"); 
                  fout.write(blob.getBytes(1, (int)blob.length())); 
                  fout.flush(); 
                  fout.close(); 
                                                               
                  stmt.close(); 
                  conn.close(); 
              } 
              catch(ClassNotFoundException e) { 
                  System.out.println("找不到驱动"); 
                  e.printStackTrace(); 
              } 
              catch(SQLException e) { 
                  e.printStackTrace(); 
              } 
              catch(IOException e) { 
                  e.printStackTrace(); 
              } 
            } 
          }
         
       |