往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;

将上面的语句输入到命令行中（如果安装了query brower， 你可以按照参考[1]中的指示来建表，那样会更加方便。），执行，表建立成功。

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
    }
}

向drivermanager注册了驱动后，我们就可以通过调用 drivermanager.getconnection()方法来获得和数据库的连接。其实在上面的例子中就有这条语句，只不过被注释掉了。在后面的实现中会有完整的例子。

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();
…

3.3 完整代码

上面列出了完整的代码。

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.");
    }
  }
}

4 总结

到此，我们就介绍完了使用往mysql保存图片的全过程。这个例子是个最简单的实例，读者可以根据自己的实际需要加入其它的一些功能，比如读取文件，删除等，使整个程序更加完善。在写这篇文章的时候主要参考了参考[2]，在此谢过。参考[3]中是一个相当漂亮的例子，不仅有保存还有读取，而且是有非常直观的图形界面，感兴趣的可以深入研究。

以上所述是小编给大家介绍的往mysql中存储图片的方法,希望对大家有所帮助