共计 4799 个字符,预计需要花费 12 分钟才能阅读完成。
自动写代码机器人,免费开通
如何在 MySQL 中存储图片?相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。
首先,先要在数据库中建表。我在名为 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.
}
}
}
看完上述内容,你们掌握如何在 MySQL 中存储图片的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注丸趣 TV 行业资讯频道,感谢各位的阅读!
向 AI 问一下细节