ตัวอย่างของการอ่านและการเขียนฟิลด์ oracle blob ของ Java

复制代码代码如下:

แพ็คเกจ com.wanmei.meishu;

นำเข้า java.io.FileInputStream;

นำเข้า java.io.FileOutputStream;

นำเข้า java.io.FileReader;

นำเข้า java.io.InputStream;

นำเข้า java.io.OutputStream;

นำเข้า java.sql.Connection;

นำเข้า java.sql.DriverManager;

นำเข้า java.sql.PreparedStatement;

นำเข้า java.sql.ResultSet;

นำเข้า java.sql.SQLException;

นำเข้า java.util.Properties;

นำเข้า oracle.sql.BLOB;

BlobUtil คลาสสาธารณะ {

BlobUtil ส่วนตัวแบบคงที่ bu;

env สตริงส่วนตัว;

BlobUtil สาธารณะคงที่ getInstance (String env) {

bu = BlobUtil ใหม่ ();

bu.env = env;

กลับบู;

-

-

* <p>得到数据库链接</p>

* @กลับ

* @พ่นข้อยกเว้น

-

การเชื่อมต่อส่วนตัว getConnection() พ่นข้อยกเว้น {

ไดรเวอร์สตริง = "oracle.jdbc.driver.OracleDriver";

Class.forName(คนขับ);

สตริง env = this.env;

Properties pro = คุณสมบัติใหม่ ();

// 读取classes 目录下的配置文件

pro.load(FileReader ใหม่(Class.class.getResource("/config.properties").getFile()));

โฮสต์สตริง = pro.getProperty(env + ".host");

ฐานข้อมูลสตริง = pro.getProperty(env + ".database");

ชื่อผู้ใช้สตริง = pro.getProperty(env + ".username");

รหัสผ่านสตริง = pro.getProperty(env + ".password");

พอร์ตสตริง = pro.getProperty(env + ".port");

String url = "jdbc:oracle:thin:@" + โฮสต์ + /// + พอร์ต +/// + ฐานข้อมูล;

กลับ DriverManager.getConnection (url, ชื่อผู้ใช้, รหัสผ่าน);

-

-

* <p>传入项目，任务，附件名称，文件路径，写入数据库</p>

* @param projectId

* @param รหัสงาน

* @param ชื่อไฟล์

* ไฟล์ @param

* @return 返回是否成功

-

การเขียนบูลีนสาธารณะ (String projectId, String jobId, String fileName, String file) {

การเชื่อมต่อการเชื่อมต่อ = null;

ResultSet rs = null;

คำสั่งที่เตรียมไว้ ps = null;

หยดหยด = null;

ธงบูลีน = เท็จ;

พยายาม {

conn = getConnection();

conn.setAutoCommit(เท็จ);

สตริง sql = "INSERT INTO PS_ZP_PRJ_WBS_BLOB BLB(ZP_PRJ_ID, ZZ_SEQ_NUM, ZZ_FILE_NAME, ZZ_IMAGE_BLOB) VALUES(?, ? ,? ,empty_blob())";

PS = conn.prepareStatement(sql);

ps.setString(1, รหัสโครงการ);

ps.setString(2, รหัสงาน);

ps.setString(3, ชื่อไฟล์);

PS.executeUpdate();

sql = "เลือก ZZ_IMAGE_BLOB จาก PS_ZP_PRJ_WBS_BLOB โดยที่ ZP_PRJ_ID = ? AND ZZ_SEQ_NUM = ? AND ZZ_FILE_NAME = ? สำหรับการอัปเดต";

PS = conn.prepareStatement(sql);

ps.setString(1, รหัสโครงการ);

ps.setString(2, รหัสงาน);

ps.setString(3, ชื่อไฟล์);

อาร์เอส = ps.executeQuery();

ถ้า(rs.ถัดไป()) {

หยด = (BLOB) rs.getBlob(1);

-

InputStream ใน = FileInputStream ใหม่ (ไฟล์);

OutputStream ออก = blob.setBinaryStream(1L);

ไบต์ [] บัฟเฟอร์ = ไบต์ใหม่ [1024];

ความยาว int = -1;

ในขณะที่ ((ความยาว = in.read (บัฟเฟอร์)) != -1){

out.write (บัฟเฟอร์, 0, ความยาว);

-

ใน.ปิด();

ออก.ปิด();

conn.commit();

conn.setAutoCommit (จริง);

ธง = จริง;

-

จับ (ข้อยกเว้นจ) {

ถ้า (conn != null) {

พยายาม {

conn.ย้อนกลับ();

} จับ (SQLException e1) {

e1.printStackTrace();

-

-

-

ในที่สุด {

พยายาม {

rs.ปิด();

ปล.ปิด();

conn.ปิด();

-

จับ (ข้อยกเว้นจ) {

e.printStackTrace();

-

-

ธงส่งคืน;

-

-

* <p>根据项目Id，任务Id，文件名读取数据库blob字段文件，写入指定的文件路径</p>

* @param projectId

* @param รหัสงาน

* @param ชื่อไฟล์

* ไฟล์ @param

* @return 返回是否成功

-

อ่านบูลีนสาธารณะ (String projectId, String jobId, String fileName, String file) {

การเชื่อมต่อการเชื่อมต่อ = null;

ResultSet rs = null;

คำสั่งที่เตรียมไว้ ps = null;

หยดหยด = null;

ธงบูลีน = เท็จ;

พยายาม {

conn = getConnection();

สตริง sql = "เลือก ZZ_IMAGE_BLOB จาก PS_ZP_PRJ_WBS_BLOB โดยที่ ZP_PRJ_ID = ? AND ZZ_SEQ_NUM = ? AND ZZ_FILE_NAME = ?";

PS = conn.prepareStatement(sql);

ps.setString(1, รหัสโครงการ);

ps.setString(2, รหัสงาน);

ps.setString(3, ชื่อไฟล์);

อาร์เอส = ps.executeQuery();

ถ้า(rs.ถัดไป()) {

หยด = (BLOB) rs.getBlob(1);

-

InputStream ใน = blob.getBinaryStream();

ไบต์ [] buf = ไบต์ใหม่ [1024];

int ไบต์ใน = 0;

FileOutputStream out = FileOutputStream ใหม่ (ไฟล์);

ในขณะที่ ((bytesIn = in.read (buf, 0, 1024)) != -1) {

out.write (buf, 0, bytesIn);

-

ใน.ปิด();

ออก.ปิด();

ธง = จริง;

-

จับ (ข้อยกเว้นจ) {

e.printStackTrace();

-

ในที่สุด {

พยายาม {

rs.ปิด();

ปล.ปิด();

conn.ปิด();

-

จับ (ข้อยกเว้นจ) {

e.printStackTrace();

-

-

ธงส่งคืน;

-

โมฆะคงที่สาธารณะ main (String [] args) {

BlobUtil bu = BlobUtil.getInstance("MSDEV");

System.out.println(bu.write("CB", "001", "image1", "D://61e44b02jw1dw4xbp2zo6j.jpg"));

System.out.println(bu.read("CB", "001", "image1", "D://2.jpg"));

-

-