往MySQL中存储图片的方法

1 介绍

在设计到数据库的开发中，难免要将图片或音频文件插入到数据库中的情况。一般来说，我们可以同过插入图片文件相应的存储位置，而不是文件本身，来避免直接向数据库里插入的麻烦。但有些时候，向MySQL中插入图片更加容易管理。那么在MySQL中该怎么存储呢？

参考资料[1]中有个相当清晰的例子，不过是基于MySQL图形界面的查询工具Query Brower的，你的机子上没有安装的话，可能得不到很好的理解。我在这里不在赘述，更详细的资料请看给出的链接吧。

还有，[1]中的例子其实只是向我们说明了Query Brower的易用和强大，对我们在开发中实际应用不是很大。所以下面就让我们用JAVA写一个向MySQL中存储的简单实例。

2 建表

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

DROP TABLE IF EXISTS `test`.`pic`;CREATE TABLE `test`.`pic` ( `idpic` int(11) NOT NULL auto_increment, `caption` varchar(45) NOT NULL default '', `img` longblob NOT NULL, PRIMARY KEY (`idpic`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;

3 实现图像存储类

表完成后，我们就开始写个Java类，来完成向数据库中插入图片的操作。我们知道，Java与数据库连接是通过JDBC driver来实现的。我用的是MySQL网站上提供的MySQL Connector/J，如果你用的是其他类型的driver，在下面的实现过程中可能会有些许差别。

3.1 装载JDBC驱动，建立连接

JDK中提供的DriverManager接口用来管理Java Application 和 JDBC Driver之间的连接。在使用这个接口之前， DriverManager需要知道要连接的JDBC 驱动。最简单的方法就是用Class.forName()来向DriverManager注册实现了java.sql.Driver 的接口类。对MySQL Connector/J来说，这个类的名字叫com.mysql.jdbc.Driver。

下面这个简单的示例说明了怎样来注册Connector/J Driver。

import java.sql.Connection;import java.sql.DriverManager;import java.sql.SQLException; public class LoadDriver {  public static void main(String[] args) {    try {      // The newInstance() call is a work around for some      // broken Java implementations      Class.forName("com.mysql.jdbc.Driver").newInstance();            // Connection con = DriverManager.getConnection(……)      // ……    } catch (Exception ex) {      // handle the error    }}

3.2 PreparedStatement

完成上面的步骤后，我们就可以同过建立的连接创建Statement接口类，来执行一些SQL语句了。在下面的例子，我用的是PreparedStatement，还有CallableStatement，它可以执行一些存储过程和函数，这里不多讲了。下面的代码片断是向pic表中插入一条记录。其中(1)处Connection接口的对象con通过调用prepareStatement 方法得到预编译的SQL 语句（precompiled SQL statement）；(2)处是为该insert语句的第一个问号赋值，(3)为第二个赋值，(4)为第三个，这步也是最该一提的，用的方法是setBinaryStream()，第一个参数3是指第三个问号，fis是一个二进制文件流，第三个参数是该文件流的长度。

PreparedStatement ps;…ps = con.prepareStatement("insert into PIC values (?,?,?)");　// (1)ps.setInt(1, id); //(2)ps.setString(2, file.getName()); (3)ps.setBinaryStream(3, fis, (int)file.length()); (4)ps.executeUpdate();…

上面列出了完整的代码。

package com.forrest.storepic; import java.io.File;import java.io.FileInputStream;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException; /** * This class describes how to store picture file into MySQL. * @author Yanjiang Qian * @version 1.0 Jan-02-2006 */public class StorePictures {    private String dbDriver;  private String dbURL;  private String dbUser;  private String dbPassword;  private Connection con;  private PreparedStatement ps;    public StorePictures() {    dbDriver = "com.mysql.jdbc.Driver";    dbURL = "jdbc:mysql://localhost:3306/test";    dbUser = "root";    dbPassword = "admin";    initDB();  }    public StorePictures(String strDriver, String strURL,      String strUser, String strPwd) {    dbDriver = strDriver;    dbURL = strURL;    dbUser = strUser;    dbPassword = strPwd;    initDB();  }   public void initDB() {    try {      // Load Driver      Class.forName(dbDriver).newInstance();      // Get connection      con = DriverManager.getConnection(dbURL,          dbUser, dbPassword);          } catch(ClassNotFoundException e) {      System.out.println(e.getMessage());    } catch(SQLException ex) {      // handle any errors      System.out.println("SQLException: " + ex.getMessage());      System.out.println("SQLState: " + ex.getSQLState());      System.out.println("VendorError: " + ex.getErrorCode());     } catch (Exception e) {      System.out.println(e.getMessage());    }  }   public boolean storeImg(String strFile) throws Exception {    boolean written = false;    if (con == null)      written = false;    else {      int id = 0;      File file = new File(strFile);      FileInputStream fis = new FileInputStream(file);            try {               ps = con.prepareStatement("SELECT MAX(idpic) FROM PIC");        ResultSet rs = ps.executeQuery();                if(rs != null) {          while(rs.next()) {            id = rs.getInt(1)+1;          }        } else {              return written;        }                ps = con.prepareStatement("insert "            + "into PIC values (?,?,?)");        ps.setInt(1, id);        ps.setString(2, file.getName());        ps.setBinaryStream(3, fis, (int) file.length());        ps.executeUpdate();                written = true;      } catch (SQLException e) {        written = false;        System.out.println("SQLException: "            + e.getMessage());        System.out.println("SQLState: "            + e.getSQLState());        System.out.println("VendorError: "            + e.getErrorCode());        e.printStackTrace();      } finally {               ps.close();        fis.close();        // close db con        con.close();      }    }    return written;  }    /**   * Start point of the program   * @param args CMD line   */  public static void main(String[] args) {    if(args.length != 1) {      System.err.println("java StorePictures filename");      System.exit(1);    }    boolean flag = false;    StorePictures sp = new StorePictures();    try {      flag = sp.storeImg(args[0]);    } catch (Exception e) {      e.printStackTrace();    }    if(flag) {      System.out.println("Picture uploading is successful.");    } else {      System.out.println("Picture uploading is failed.");    }  }}

更多相关文章

随机推荐