把上传的文件保存到数据库中。数据库的类型为blob和longblob。上传文件的大小大于1M是需要修改MySQL的my.ini配置文件。

修改内容如下：

1. [mysqld]
2. max_allowed_packet=1024M

实验步骤：

一、创建数据库表。

脚本：

1. DROP TABLE IF EXISTS `upload`;
2. CREATE TABLE `upload` (
3. `dir` varchar(100) NOT NULL DEFAULT '', /* 保存上传的时间 */
4. `upload` longblob, /* 存储文件 */
5. PRIMARY KEY (`dir`)
6. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

二、建立Java项目

三、添加MySQL数据库驱动包

四、添加iBatis包

五、添加iBatis主配置文件

代码：

1. <?xml version="1.0" encoding="UTF-8" ?>
2. <!DOCTYPE sqlMapConfig
3. PUBLIC "-//ibatis.apache.org//DTD SQL Map Config 2.0//EN"
4. "http://ibatis.apache.org/dtd/sql-map-config-2.dtd">
5. <sqlMapConfig>
6. <transactionManager type="JDBC" commitRequired="false">
7. <dataSource type="SIMPLE">
8. <property name="JDBC.Driver"   value="com.mysql.jdbc.Driver"/>
9. <property name="JDBC.ConnectionURL" value="jdbc:mysql://10.32.52.19:3306/iBatis"/>
10. <property name="JDBC.Username" value="root"/>
11. <property name="JDBC.Password" value="root"/>
12. </dataSource>
13. </transactionManager>
14. <sqlMap resource="oks-sql.xml"/>
15. </sqlMapConfig>

六、添加映射文件

代码：

1. <?xml version="1.0" encoding="UTF-8"?>
2. <!DOCTYPE sqlMap
3. PUBLIC "-//ibatis.apache.org//DTD SQL Map 2.0//EN"
4. "http://ibatis.apache.org/dtd/sql-map-2.dtd">
5. <sqlMap namespace="sql" >
6. <typeAlias
7. alias="upload"
8. type="Upload" />
9. <insert
10. id="up"
11. parameterClass="upload" >
12. INSERT INTO upload(dir,upload) values(#dir#,#uploadIn#)
13. </insert>
14. <select
15. id="down"
16. resultClass="upload" >
17. select dir,upload as uploadIn from upload
18. </select>
19. </sqlMap>

七、编写数据表实体类。

注意：数据库中的Blob类型和longblob类型在实体类中使用byte[]

代码：

1. import java.io.FileOutputStream;
2. /**
3. * TODO Put here a description of what this class does.
4. *
5. * @author Administrator.
6. * Created Sep 12, 2012.
7. */
8. public class Upload {
9. private String dir;
10. private byte[] uploadIn;
11. private FileOutputStream uploadOut;
12. /**
13. * TODO Put here a description of what this constructor does.
14. *
15. */
16. public Upload() {
17. super();
18. // TODO Auto-generated constructor stub.
19. }
20. public String getDir() {
21. return this.dir;
22. }
23. public void setDir(String dir) {
24. this.dir = dir;
25. }
26. public byte[] getUploadIn() {
27. return this.uploadIn;
28. }
29. public void setUploadIn(byte[] uploadIn) {
30. this.uploadIn = uploadIn;
31. }
32. public FileOutputStream getUploadOut() {
33. return this.uploadOut;
34. }
35. public void setUploadOut(FileOutputStream uploadOut) {
36. this.uploadOut = uploadOut;
37. }
38. }

八、编写连接代码

代码：

1. private static SqlMapClient sqlMapClient;
2. static {
3. Reader reader = null;
4. try {
5. reader = Resources.getResourceAsReader("sqlMapConfig.xml");
6. } catch (IOException exception) {
7. exception.printStackTrace();
8. }
9. // 得到SqlMapClient
10. sqlMapClient = SqlMapClientBuilder.buildSqlMapClient(reader);
11. }

九、编写上传文件的代码

代码：

1. public static void upload() {
2. try {
3. sqlMapClient.startTransaction();
4. Upload upload = new Upload();
5. upload.setDir(System.currentTimeMillis() + "");
6. try {
7. ByteArrayOutputStream bytestream = new ByteArrayOutputStream(); //转换byte数组
8. FileInputStream in = new FileInputStream("d:/jcifs-1.3.14.jar"); //文件
9. int ch;
10. //转换成byte数组
11. while ((ch = in.read()) != -1) {
12. bytestream.write(ch);
13. }
14. byte imgdata[] = bytestream.toByteArray();
15. upload.setUploadIn(imgdata);
16. } catch (IOException exception) {
17. exception.printStackTrace();
18. }
19. sqlMapClient.insert("up", upload);
20. sqlMapClient.commitTransaction();
21. } catch (SQLException exception) {
22. // TODO Auto-generated catch-block stub.
23. exception.printStackTrace();
24. }
25. }

十、编写下载的文件

代码：

1. public static void down() {
2. try {
3. byte[] Buffer = new byte[4096];
4. int size = 0;
5. sqlMapClient.startTransaction();
6. Upload upload = (Upload) sqlMapClient.queryForObject("down");
7. try {
8. FileOutputStream fileOutputStream = new FileOutputStream(
9. "d:/b.jar"); //保存文件
10. InputStream inputStream = new ByteArrayInputStream(
11. upload.getUploadIn()); //byte转换为流
12. while ((size = inputStream.read(Buffer)) != -1) {
13. System.out.println(size);
14. fileOutputStream.write(Buffer, 0, size);
15. }
16. } catch (FileNotFoundException exception) {
17. // TODO Auto-generated catch-block stub.
18. exception.printStackTrace();
19. } catch (IOException exception) {
20. // TODO Auto-generated catch-block stub.
21. exception.printStackTrace();
22. }
23. sqlMapClient.commitTransaction();
24. } catch (SQLException exception) {
25. // TODO Auto-generated catch-block stub.
26. exception.printStackTrace();
27. }
28. }