转自：https://blog.csdn.net/u014475796/article/details/49893261

在设计到数据库的开发中，难免要将图片或文档文件（如word）插入到数据库中的情况。一般来说，我们可以通过插入文件相应的存储路径，而不是文件本身，来避免直接向数据库里插入的麻烦。但有些时候，直接向MySQL中插入文件，更加安全，而且更加容易管理。

 首先，先要在数据库中建表。我在名为test的数据库下建立了一个叫pic的表。该表包括3列，id， caption和img。其中id是主键，caption是对图片的表述，img是图像文件本身。建表的SQL语句如下：

1.   DROP TABLE IF EXISTS `test`.`pic`;
2.   CREATE TABLE `test`.`pic` (
3.   `id` int(11) NOT NULL auto_increment,
4.   `caption` varchar(45) NOT NULL default ‘‘,
5.   `img` longblob NOT NULL,
6.   PRIMARY KEY (`id`)
7.   ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

 其次，在java中对文件（如图片，word文档等）的处理，其中包括把文件存储到数据库和从数据库中读取文件。（注：storeImg()和readImg()是可以处理任意文件类型的，不仅仅是图片）

</pre><pre name="code" class="sql"> 在数据库里存储文件以及从数据库读取文件的完整代码如下：

1.   <pre name="code" class="java">import java.io.*;
2.   import java.sql.*;
3.   public class StoreFile {
4.    
5.   private String dbDriver;
6.   private String dbURL;
7.   private String dbUser;
8.   private String dbPassword;
9.   private Connection con;
10.   private PreparedStatement ps;
11.   /**
12.   * 构造函数，初始化数据库的连接
13.   *
14.   */
15.   public StoreFile() {
16.   dbDriver = "com.mysql.jdbc.Driver";
17.   dbURL = "jdbc:mysql://localhost:3306/test";
18.   dbUser = "root";
19.   dbPassword = "justdoit";
20.   initDB();
21.   }
22.   public StoreFile(String strDriver, String strURL,
23.   String strUser, String strPwd) {
24.   dbDriver = strDriver;
25.   dbURL = strURL;
26.   dbUser = strUser;
27.   dbPassword = strPwd;
28.   initDB();
29.   }
30.    
31.   public void initDB() {
32.   try {
33.   // Load Driver
34.   Class.forName(dbDriver).newInstance();
35.   // Get connection
36.   con = DriverManager.getConnection(dbURL,
37.   dbUser, dbPassword);
38.   } catch(ClassNotFoundException e) {
39.   System.out.println(e.getMessage());
40.   } catch(SQLException ex) {
41.   // handle any errors
42.   System.out.println("SQLException: " + ex.getMessage());
43.   System.out.println("SQLState: " + ex.getSQLState());
44.   System.out.println("VendorError: " + ex.getErrorCode());
45.    
46.   } catch (Exception e) {
47.   System.out.println(e.getMessage());
48.   }
49.   }
50.   /**
51.   * 将指定路径的文件(比如：图片，word文档等)存储到数据库
52.   * @param strFile 要存放到数据库的文件路径，如D:\\a.jpg
53.   */
54.   public void storeImg(String strFile) throws Exception {
55.   int id = 0;
56.   File file = new File(strFile);
57.   FileInputStream fis = new FileInputStream(file);
58.   try {
59.   ps = con.prepareStatement(" insert "
60.   + "into PIC values (?,?,?)");
61.   ps.setInt(1, id);
62.   ps.setString(2, file.getName());
63.   ps.setBinaryStream(3, fis, (int) file.length());
64.   ps.executeUpdate();
65.   System.out.println("file insert success ");
66.   } catch (SQLException e) {
67.   System.out.println("SQLException: "
68.   + e.getMessage());
69.   System.out.println("SQLState: "
70.   + e.getSQLState());
71.   System.out.println("VendorError: "
72.   + e.getErrorCode());
73.   e.printStackTrace();
74.   } finally {
75.   ps.close();
76.   fis.close();
77.   con.close();
78.   }
79.   }
80.   /**
81.   * 将存储在数据库中的文件(比如：图片，word文档等)读取到指定路径
82.   * @param path 从数据库里读取出来的文件存放路径 如D:\\a.jpg
83.   * @param id 数据库里记录的id
84.   */
85.   public void readImg(String path, int id) throws Exception{
86.   initDB(); //建立与数据库的连接
87.   byte[] buffer = new byte[4096];
88.   FileOutputStream outputImage = null;
89.   InputStream is = null;
90.   try {
91.   ps = con.prepareStatement("select img from pic where id =?");
92.   ps.setInt(1, id);
93.   ResultSet rs = ps.executeQuery();
94.   rs.next();
95.   File file = new File(path);
96.   if (!file.exists()) {
97.   file.createNewFile();
98.   }
99.   outputImage = new FileOutputStream(file);
100.   Blob blob = rs.getBlob("img"); //img为数据库存放图片字段名称
101.   is = blob.getBinaryStream();
102.   int size = 0;
103.   while ((size = is.read(buffer)) != -1) {
104.   outputImage.write(buffer, 0, size);
105.   }
106.   System.out.println("file read success ");
107.   } catch (Exception e) {
108.   e.printStackTrace();
109.   } finally {
110.   is.close();
111.   outputImage.close();
112.   ps.close();
113.   con.close();
114.   }
115.   }
116.    
117.   public static void main(String[] args) throws Exception {
118.   StoreFile sp = new StoreFile();
119.   String imgPath="C:\\Users\\Administrator\\Pictures\\img12.jpg";
120.   //String wordPath="d:\\测试文档.docx";
121.   sp.storeImg(imgPath);
122.   //sp.storeImg(wordPath);
123.   //sp.readImg("D://数据库.jpg", 1); //这里的1为要传入的参数：读取文件的id
124.   //sp.readImg("D://数据库.docx", 8);
125.   }
126.   }