sooxin-JAVA

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

            // 取得檔案
            File file = new File("./logo_phpbb.jpg");
            int length = (int) file.length();
            InputStream fin = new FileInputStream(file);
            // 填入資料庫
            PreparedStatement pstmt = conn.prepareStatement(
            "INSERT INTO files VALUES(?, ?)");
             
            pstmt.setString(1, "米小國Logo");
            pstmt.setBinaryStream (2, fin, length);
             
            pstmt.executeUpdate();
            pstmt.clearParameters();
            pstmt.close();
            fin.close();
            

1
2

Blob blob = result.getBlob(2);  // 取得BLOB
            Clob clob = result.getClob(2)  // 取得CLOB 
            

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

import java.io.*;
            import java.sql.*;
            public class DBTest {
            public static void main(String[] args) {
            String driver = "com.mysql.jdbc.Driver";
            String url = "jdbc:mysql://localhost:3306/upload?useUnicode=true&characterEncoding=Big5";
            String user = "caterpillar";
            String password = "123456";
            try {
            Class.forName(driver);
            Connection conn = DriverManager.getConnection(url, user, password);
             
            // 取得檔案
            File file = new File("./logo_phpbb.jpg");
            int length = (int) file.length();
            InputStream fin = new FileInputStream(file);
             
            // 填入資料庫
            PreparedStatement pstmt = conn.prepareStatement(
            "INSERT INTO files VALUES(?, ?)");
            pstmt.setString(1, "米小國Logo");
            pstmt.setBinaryStream (2, fin, length);
            pstmt.executeUpdate();
            pstmt.clearParameters();
            pstmt.close();
            fin.close();
             
            // 從資料庫取出檔案
            Statement stmt = conn.createStatement();
            ResultSet result = stmt.executeQuery("SELECT * FROM files");
            result.next();
            String description = result.getString(1);
            Blob blob = result.getBlob(2);
             
            // 寫入檔案
            System.out.println("檔案描述：" + description);
            FileOutputStream fout = new FileOutputStream("./logo_phpbb_2.jpg");
            fout.write(blob.getBytes(1, (int)blob.length()));
            fout.flush();
            fout.close();
            stmt.close();
            conn.close();
            }
            catch(ClassNotFoundException e) {
            System.out.println("找不到驅動程式");
            e.printStackTrace();
            }
            catch(SQLException e) {
            e.printStackTrace();
            }
            catch(IOException e) {
            e.printStackTrace();
            }
            }
            }