1
2
3
4
5
6
7

<hibernate-configuration>
  <session-factory>
  .....
  <mapping resource="com/Achi/orm/sample02/TestUser3.hbm.xml"/>
  .....
 </session-factory>
</hibernate-configuration>

1
2
3
4
5
6

<hibernate-mapping>
 <class name="com.Achi.orm.sample02.TestUser3" table="test_user3">
  <property name="name"    type="java.lang.String"  column="name"/>
  <property name="image"   type="java.sql.Blob"     column="image"/>
 </class>
</hibernate-mapping>

1
2
3
4
5
6
7
8
9
10
11
12
13
14

package com.Achi.orm.sample02;
import java.sql.Blob;
public class TestUser3 {
  private String name;
  private Blob image;
  
  public TestUser3() {}
 
  public void setName(String newValue) { this.name = newValue; }
  public String getName()              { return this.name;     }
  
  public void setImage(Blob newValue) { this.image = newValue; }
  public Blob getImage()              { return this.image;     }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115

package com.Achi.orm.sample02;
 
import java.io.File;
import java.io.FileInputStream;
import java.io.OutputStream;
import oracle.sql.BLOB;
import org.hibernate.lob.SerializableBlob;
import org.hibernate.Hibernate;
import org.hibernate.LockMode;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import org.hibernate.cfg.Configuration;
 
public class StartHibernate_insertBlob {
 
  // 程式進入點
  public static void main(String args[]) {
  
    // --------------------------------------------------------------
    // 變數宣告
    // --------------------------------------------------------------
    File file = null;
    FileInputStream fileInputStream = null;
    String imagePath = "C:\\test_Blob_03.JPG";
    SessionFactory sessionFactory = null;
    Session session = null;
    Transaction tx = null;
    
    try {
      // ------------------------------------------------------------
      // [匯入] 圖檔
      // ------------------------------------------------------------
      file = new File(imagePath);
      fileInputStream = new FileInputStream(file);
      
      // ------------------------------------------------------------
      // [初始化] Blob
      // ------------------------------------------------------------      
      TestUser3 bean = new TestUser3();
      bean.setImage(Hibernate.createBlob(new byte[1]));
 
      // ------------------------------------------------------------
      // [設定] Name 
      // ------------------------------------------------------------      
      bean.setName("Achi");
      
      // ------------------------------------------------------------
      // [建立] Configuration 來管理 hibernate.cfg.xml 
      // ------------------------------------------------------------
      Configuration config = new Configuration().configure();
      
      // ------------------------------------------------------------
      // [建立] SessionFactory
      // ------------------------------------------------------------
      sessionFactory = (SessionFactory) config.buildSessionFactory();
      
      // ------------------------------------------------------------
      // [建立] Session
      // ------------------------------------------------------------
      session = sessionFactory.openSession();
      
      // ------------------------------------------------------------
      // [建立] Transaction
      // ------------------------------------------------------------
      tx = session.beginTransaction();
      
      // ------------------------------------------------------------
      // [儲存]
      // ------------------------------------------------------------
      session.save(bean);
      
      // ------------------------------------------------------------
      // [強制] flush，主要是先讓 Hibernate 去 insert 空欄位先。 
      // ------------------------------------------------------------
      session.flush();
      
      // ------------------------------------------------------------
      // [執行] refresh，讓 Hibernate 執行 Select For Update。
      // ------------------------------------------------------------
      session.refresh(bean, LockMode.UPGRADE);
      
      // ------------------------------------------------------------
      // [真正] 要寫入的 Blob 資料
      // ------------------------------------------------------------
      SerializableBlob sBlob = (SerializableBlob)bean.getImage();
      BLOB blob = (BLOB)sBlob.getWrappedBlob();
      OutputStream os = blob.getBinaryOutputStream();   
      byte[] data = new byte[(int)fileInputStream.available()];
      fileInputStream.read(data);
      os.write(data);
 
      // ------------------------------------------------------------
      // [強制] flush
      // ------------------------------------------------------------
      session.flush();
      
      // ------------------------------------------------------------
      // COMMIT
      // ------------------------------------------------------------
      tx.commit();
      
      // ------------------------------------------------------------
      // CLOSE
      // ------------------------------------------------------------
      fileInputStream.close();
      os.close();
      session.close();
      sessionFactory.close();
            
    } catch(Exception e) {
      e.printStackTrace();
    }
  }
}

1
2
3
4
5

CREATE TABLE test_user3 (
  name    VARCHAR2(10) NOT NULL,
  image   BLOB,
  PRIMARY KEY (name)
)