mysql数据库中，Blob（二进制数据类型）怎么用

存图片或者附件

1. import java.sql.*;
   
2. import java.io.*;
   
3. public class binarydata {
   
4. 
   
5.         public static void main(String[] args) {
   
6.                 // TODO Auto-generated method stub
   
7.                 read();
   
8.                 //create();
   
9.         }
   
10.         public static void create()
    
11.         {
    
12.                 Connection ct=null;
    
13.                 PreparedStatement ps=null;
    
14.                 ResultSet rs=null;
    
15.                 try
    
16.                 {
    
17.                             ct=JDBCUtils.getConnection();
    
18.                               String sql="insert into picture(picture)values(?)";
    
19.                             ps=ct.prepareStatement(sql);
    
20.                              InputStream in=new BufferedInputStream(new FileInputStream(new File("1.png")));
    
21.                             ps.setBinaryStream(1, in);
    
22.                             int i=ps.executeUpdate();
    
23.                         System.out.println("i="+i);
    
24.                             in.close();
    
25.                 }catch(Exception e)
    
26.                 {
    
27.                         e.printStackTrace();
    
28.                 }finally
    
29.                 {
    
30.                         JDBCUtils.free(rs, ps, ct);
    
31.                 }
    
32.         }
    
33.        
    
34.         public static void read()
    
35.         {
    
36.                 Connection ct=null;
    
37.                 PreparedStatement ps=null;
    
38.                 ResultSet rs=null;
    
39.                 try
    
40.                 {
    
41.                         ct=JDBCUtils.getConnection();
    
42.                         String sql="select picture from picture";
    
43.                         ps=ct.prepareStatement(sql);
    
44.                         rs=ps.executeQuery();
    
45.                         int m=0;
    
46.                         while(rs.next())
    
47.                         {
    
48.                                
    
49.                                 InputStream in=rs.getBinaryStream("picture");
    
50.                                 OutputStream out=new BufferedOutputStream(new FileOutputStream(new File("D://"+(m++)+".png")));
    
51.                                 byte[] buf=new byte[1024];
    
52.                                 int i=0;
    
53.                                 while((i=in.read(buf))!=-1)
    
54.                                 {
    
55.                                         out.write(buf,0,i);
    
56.                                 }
    
57.                                 in.close();
    
58.                                 out.close();
    
59.                         }
    
60.                 }catch(Exception e)
    
61.                 {
    
62.                         e.printStackTrace();
    
63.                 }finally
    
64.                 {
    
65.                         JDBCUtils.free(rs, ps, ct);
    
66.                 }
    
67.         }
    
68. 
    
69. }
    
70. 
    
71. 
    
72. 
    
73. 
    
74. 
    
75. 
    
76. 
    
77. 
    
78. 
    
79. 
    
80. 
    
81. 
    
82. 
    
83. 
    
84. 
    
85. 
    
86. 
    
87. 
    
88. 
    
89. 
    
90. 
    
91. 
    
92. 
    
93. 
    

复制代码

工具类：

1. 
   
2. 
   
3. import java.sql.*;
   
4. 
   
5. public class JDBCUtils {
   
6.         private static String url="jdbc:mysql://localhost:3306/user";
   
7.         private static String user="root";
   
8.         private static String password="root";
   
9.        
   
10.         private JDBCUtils(){}
    
11.        
    
12.         static
    
13.         {
    
14.                 try {
    
15.                         Class.forName("com.mysql.jdbc.Driver");
    
16.                 } catch (ClassNotFoundException e) {
    
17.                         // TODO Auto-generated catch block
    
18.                         e.printStackTrace();
    
19.                 }
    
20.         }
    
21.        
    
22.         public static Connection getConnection() throws SQLException
    
23.         {
    
24.                 return DriverManager.getConnection(url,user,password);
    
25.         }
    
26.        
    
27.         public static void free(ResultSet rs,Statement st,Connection ct)
    
28.         {
    
29.                 try
    
30.                 {
    
31.                         if(rs!=null)
    
32.                                 rs.close();
    
33.                 }catch(Exception e)
    
34.                 {
    
35.                         e.printStackTrace();
    
36.                 }
    
37.                 finally
    
38.                 {
    
39.                         try
    
40.                         {
    
41.                                 if(st!=null)
    
42.                                         st.close();
    
43.                         }catch(Exception e)
    
44.                         {
    
45.                                 e.printStackTrace();
    
46.                         }finally
    
47.                         {
    
48.                                 if(ct!=null)
    
49.                                         try {
    
50.                                                 ct.close();
    
51.                                         } catch (SQLException e) {
    
52.                                                 // TODO Auto-generated catch block
    
53.                                                 e.printStackTrace();
    
54.                                         }
    
55.                         }
    
56.                 }
    
57.         }
    
58. 
    
59. }
    

复制代码