MysqL中插入图片的方法:首先要在数据库中建表;然后装载JDBC驱动,建立连接;最后创建Statement接口类,来执行sql语句即可。
1、首先,先要在数据库中建表。我在名为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]中的指示来建表,那样会更加方便。),执行,表建立成功。
2、实现图像存储类
表完成后,我们就开始写个java类,来完成向数据库中插入图片的操作。我们知道,Java与数据库连接是通过JDBC driver来实现的。我用的是MysqL网站上提供的MysqL Connector/J,如果你用的是其他类型的driver, 在下面的实现过程中可能会有些许差别。
2.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()方法来获得和数据库的连接。其实在上面的例子中就有这条语句,只不过被注释掉了。在后面的实现中会有完整的例子。
2.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(); …
2.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教程(视频)