PowerBuilder 用 UPDATEBLOB 与 SELECTBLOB 存取图片等大字段

pbai

免费乐捐，感谢支持

PowerBuilder 用 UPDATEBLOB 与 SELECTBLOB 存取图片等大字段

阅读说明
1. 适用版本：PowerBuilder 9 / 10 / 11 / 12.5（UPDATEBLOB / SELECTBLOB 是嵌入式 SQL 的标准语法，自 PB 6 起即有，所有版本通用；本文代码已在 PB 12.5 实机验证）
2. 支持数据库：SQLite / SQL Server / Oracle / MySQL 等支持二进制大对象（BLOB / IMAGE / VARBINARY(MAX)）的数据库；本文示例以 SQLite 实机验证，Blob 语句一字不变适用于其它库
3. 操作系统与环境要求：Windows 7+；演示用 SQLite 需 PBIDEA 提供的 LIT SQLite 接口（PbIdea.dll + sqlite3.dll），标准项目换成你的 SQL Server / Oracle 只需改 SQLCA 连接串，Blob 语句不变
4. 难度系数：★★★☆☆
5. 其它阅读说明：示例用一张图片或任意二进制文件演示；流程是「文件 → Blob → 入库」，取回时是「库 → Blob → 文件」；先把文件读进 Blob 再操作最稳妥

---

为什么要专门学这两个语句

PowerBuilder 里，普通的 INSERT / SELECT 处理的是「字符串」和「数值」。但图片、PDF、Word 文档、压缩包这类二进制大对象（Binary Large Object，简称 Blob），有两个特点让普通 SQL 处理不了：

• 体积大：一个图片可能几 MB，远超过 string 类型（以及嵌入 SQL 字符串绑定）的上限，塞不进 :ls_text 这种字符串变量。
  
• 含特殊字节：二进制里有 0x00 等控制字节，当成字符串处理会被截断、乱码。
  

所以 PB 在嵌入式 SQL 里单独给了两条语句：

• UPDATEBLOB：把内存里的 blob 变量写进某张表的 Blob 列。
  
• SELECTBLOB：把表里 Blob 列的内容读进内存的 blob 变量。
  

它们和普通的 UPDATE / SELECT 完全平行，区别只在「操作的是 Blob 列、绑定的是 blob 类型变量」。

---

一、第一步：把文件读进 Blob（FileOpen + FileReadEx）

存库之前，先把磁盘上的文件读进一个 blob 变量。PB 用 FileOpen 以流模式（StreamMode!）打开，再用 FileReadEx 一次性读入。

前置：窗口上放一个按钮 cb_load，在其 clicked 事件里贴下方代码；先准备一个二进制文件（图片、PDF 都行），记下它的路径。
步骤：1) 打开窗口；2) 点击 cb_load；3) 在 MessageBox 里看到读入的字节数。

2. // 示例输入：要读入的文件路径（换成你自己的文件）
3. string ls_path
4. ls_path = 'C:\temp\photo.png'
5. // 接收文件内容的 blob 变量
6. blob lb_pic
8. int li_f
9. long ll_len
10. li_f = FileOpen(ls_path, StreamMode!, Read!, LockRead!)
11. if li_f < 0 then
12.         MessageBox('错误', '文件打开失败，请检查路径')
13.         return
14. end if
15. ll_len = FileReadEx(li_f, lb_pic)
16. FileClose(li_f)
18. MessageBox('已读入字节数', string(ll_len))

复制代码

要点：

• StreamMode! 是「二进制流」模式，按字节读，不会像文本模式那样做换行转换——读二进制文件必须用这个模式。
  
• FileReadEx(fileno, blobvar) 返回实际读到的字节数（读失败返回 -1）。它一次把整个文件读进 blob，比老式的 FileRead 按行读要省事得多。
  
• 读到的 lb_pic 现在在内存里，可以拿去存库了。
  

---

二、写入数据库：UPDATEBLOB

Blob 变量准备好后，用 UPDATEBLOB 写进表的 Blob 列。注意它必须单独成句，不能用普通 UPDATE 的 SET col = :lb_pic 写法（普通 UPDATE 的绑定变量只认字符串/数值）。

前置：已 CONNECT USING SQLCA; 成功；数据表已建好，例如 files(id integer, name varchar(50), content blob)，并且已经有一行 id = 1。

2. // 示例输入：要写入的 blob（假设已由上一步读入）
3. blob lb_pic
4. // 示例输入：目标记录 id
5. long ll_id
6. ll_id = 1
8. UPDATEBLOB files
9.   SET content = :lb_pic
10.   WHERE id = :ll_id
11.   USING SQLCA;
12. if SQLCA.SQLCode <> 0 then
13.         MessageBox('写入失败', SQLCA.SQLErrText)
14. else
15.         MessageBox('写入成功', '字节数=' + string(len(lb_pic)))
16. end if

复制代码

要点：

• SET content = :lb_pic 右边必须是 :blob变量，冒号绑定。
  
• WHERE 条件可以带普通变量（如 :ll_id），和普通 UPDATE 一样。
  
• 必须跟 USING SQLCA;（或你自己的事务对象）。
  
• 写完一定要检查 SQLCA.SQLCode：0 成功，非 0 看 SQLCA.SQLErrText。
  

---

三、取回数据库：SELECTBLOB

取回时方向相反，用 SELECTBLOB ... INTO :blob变量。

2. // 示例输入：要取回的记录 id
3. long ll_id
4. ll_id = 1
5. // 接收读出的 blob
6. blob lb_back
8. SELECTBLOB content
9.   INTO :lb_back
10.   FROM files
11.   WHERE id = :ll_id
12.   USING SQLCA;
13. if SQLCA.SQLCode <> 0 then
14.         MessageBox('读取失败', SQLCA.SQLErrText)
15. else
16.         MessageBox('取回字节数', string(len(lb_back)))
17. end if

复制代码

要点：

• INTO :lb_back 的变量必须是 blob 类型。
  
• 一次 SELECTBLOB 只能取一个 Blob 列，且 INTO 后面只能跟这一个 blob 变量（不能像普通 SELECT 那样 INTO :a, :b 混着来）。
  
• 同样必须 USING SQLCA; 并检查 SQLCA.SQLCode。
  

---

四、把 Blob 写回文件：FileWriteEx

取回的 blob 要还原成文件，用 FileOpen（流模式写）+ FileWriteEx。

2. // 示例输入：写出的目标路径
3. string ls_out
4. ls_out = 'C:\temp\photo_copy.png'
5. // 示例输入：要写出的 blob（已由上一步取回）
6. blob lb_back
8. int li_o
9. li_o = FileOpen(ls_out, StreamMode!, Write!, LockWrite!)
10. if li_o < 0 then
11.         MessageBox('错误', '无法创建目标文件')
12.         return
13. end if
14. FileWriteEx(li_o, lb_back)
15. FileClose(li_o)
17. MessageBox('已写出字节数', string(len(lb_back)))

复制代码

---

五、完整可运行示例（一个函数串起来）

下面把「读文件 → 入库 → 取回 → 写回验证」完整串在一次调用里，也是本文在 PB 12.5 实机跑通的代码。它以 SQLite 做演示库（LIT SQLite 是 PBIDEA 提供的 SQLite 接口），换成 SQL Server / Oracle 只改 SQLCA 的连接串，UPDATEBLOB / SELECTBLOB 语句一字不变。

2. // 示例输入：源二进制文件路径（换成你自己的文件）
3. string ls_in
4. ls_in = 'C:\temp\sample.bin'
5. // 示例输入：写回验证用的目标路径
6. string ls_out
7. ls_out = 'C:\temp\sample_out.bin'
9. int li_f
10. long ll_len
11. blob lb_data
13. // 1) 文件 -> Blob
14. li_f = FileOpen(ls_in, StreamMode!, Read!, LockRead!)
15. if li_f < 0 then
16.         MessageBox('错误', '源文件打开失败')
17.         return
18. end if
19. ll_len = FileReadEx(li_f, lb_data)
20. FileClose(li_f)
22. // 2) 连接 SQLite 演示库（生产环境换成你的 MSSQL/Oracle 连接串）
23. SQLCA.DBMS = 'LIT SQLite'
24. SQLCA.Database = 'pblit_demo.db'
25. SQLCA.AutoCommit = true
26. CONNECT USING SQLCA;
27. if SQLCA.SQLCode <> 0 then
28.         MessageBox('连接失败', SQLCA.SQLErrText)
29.         return
30. end if
32. // 3) 建表并清空旧数据，保证可重复运行
33. string ls_sql
34. ls_sql = 'create table if not exists files(id integer primary key, name varchar(50), content blob)'
35. EXECUTE IMMEDIATE :ls_sql USING SQLCA;
36. ls_sql = 'delete from files where id = 1'
37. EXECUTE IMMEDIATE :ls_sql USING SQLCA;
38. INSERT INTO files(id, name) VALUES(1, 'sample.bin') USING SQLCA;
40. // 4) UPDATEBLOB 写入
41. UPDATEBLOB files SET content = :lb_data WHERE id = 1 USING SQLCA;
42. if SQLCA.SQLCode <> 0 then
43.         MessageBox('入库失败', SQLCA.SQLErrText)
44.         DISCONNECT USING SQLCA;
45.         return
46. end if
48. // 5) SELECTBLOB 取回
49. blob lb_back
50. SELECTBLOB content INTO :lb_back FROM files WHERE id = 1 USING SQLCA;
51. if SQLCA.SQLCode <> 0 then
52.         MessageBox('取回失败', SQLCA.SQLErrText)
53.         DISCONNECT USING SQLCA;
54.         return
55. end if
57. DISCONNECT USING SQLCA;
59. // 6) 写回文件做往返验证
60. int li_o
61. li_o = FileOpen(ls_out, StreamMode!, Write!, LockWrite!)
62. FileWriteEx(li_o, lb_back)
63. FileClose(li_o)
65. // 结果输出：三次字节数应一致，证明往返无损
66. MessageBox('Blob 往返验证', '读入=' + string(ll_len) + ' 入库=' + string(len(lb_data)) + ' 取回=' + string(len(lb_back)))

复制代码

连接串差异（仅举例，Blob 语句不变）：SQL Server 用 SQLCA.DBMS = 'SNC SQL Native Client' + SQLCA.ServerName / SQLCA.Database / SQLCA.LogId / SQLCA.LogPass；Oracle 用 SQLCA.DBMS = 'O73 Oracle7' 系列或 O10/O11 驱动。无论哪种，上面的 UPDATEBLOB / SELECTBLOB 四行原样照搬即可。

---

六、边界情况与常见坑

• 普通 UPDATE 不能改 Blob 列：UPDATE files SET content = :lb_pic 会编译报错或运行失败。必须用 UPDATEBLOB。
  
• 普通 SELECT INTO 不能取 Blob：SELECT content INTO :ls_x 把 blob 当字符串会截断/报错。必须用 SELECTBLOB。
  
• SELECTBLOB 一次只能一个 Blob 列：想同时取 Blob 和普通列，分开两条语句，或先把普通列用普通 SELECT 取，Blob 单独 SELECTBLOB。
  
• 必须检查 SQLCA.SQLCode：Blob 操作出错（列不存在、事务没连、类型不匹配）时 PB 不会抛异常，只会把 SQLCode 置非 0。养成「写完必查」的习惯。
  
• WHERE 条件不能省且要能定位到行：UPDATEBLOB / SELECTBLOB 都靠 WHERE 锁定行，条件错会把别的行写坏或取空。
  
• Blob 变量要先有值再写：UPDATEBLOB 把一个空 blob（长度 0）写进去，库里就是空的——不是报错，是「存了个空」。读文件失败时 lb_data 可能为空，先确认 ll_len > 0。
  
• 事务与提交：如果 SQLCA.AutoCommit = false，UPDATEBLOB 后要 COMMIT USING SQLCA; 才真正落库；AutoCommit = true 则自动提交。忘了提交，取回时可能读不到刚写的内容。
  
• FileOpen 模式要配对：读用 Read!，写用 Write!；二进制一律 StreamMode!，文本才用 LineMode!。用错模式文件会损坏。
  

---

七、与 DataWindow 的 Blob 列对比

如果你的数据已经在 DataWindow 里（比如 d_files 有一列 content 是 blob 类型），不必走嵌入式 SQL，直接用 DataWindow 的方法：

2. // 示例输入：行号
3. long ll_row
4. ll_row = 1
5. // 示例输入：blob 列名
6. string ls_col
7. ls_col = 'content'
9. // 从 DataWindow 取 blob 列
10. blob lb_col
11. lb_col = dw_1.GetItemBlob(ll_row, ls_col)
12. // 写回 blob 列
13. dw_1.SetItemBlob(ll_row, ls_col, lb_col)
14. // 真正落库仍需 Update()
15. dw_1.Update()
17. MessageBox('DataWindow Blob', '取回字节=' + string(len(lb_col)))

复制代码

两种路线怎么选：

• 嵌入式 UPDATEBLOB / SELECTBLOB：适合后台服务、脚本、不在界面上的批量处理，不依赖 DataWindow。
  
• DataWindow 的 GetItemBlob / SetItemBlob + Update()：适合界面上直接编辑、随 DataWindow 一起提交，和界面绑定更自然。
  

---

八、进阶：PBIDEA 的 uo_blob 封装

PBIDEA 的 websuite.pbl 里有一套 uo_blob 对象，对上述「读文件 / 写文件 / 入库 / 取回」做了更顺手的封装（例如把文件直读直写、Base64 编解码、与 uo_database 联动等收进对象方法），适合不想手写 FileOpen/FileReadEx 细节的场景。它的方法签名以本机 PBIDEA/export_20260811/websuite.pbl/uo_blob.sru 为准，需要时对照源码取用即可。本文核心是标准嵌入式 SQL，掌握后接入 uo_blob 只是少写几行胶水代码。

---

九、小结

• 二进制大字段不能用普通 INSERT / SELECT，必须用 UPDATEBLOB（写）和 SELECTBLOB（读）。
  
• 标准流程：文件 → FileOpen/FileReadEx 读进 blob → UPDATEBLOB 入库 → SELECTBLOB 取回 → FileWriteEx 写回文件。
  
• 三条铁律：绑定变量用 :blob、必须 USING SQLCA;、写完必查 SQLCA.SQLCode。
  
• 界面场景可用 DataWindow 的 GetItemBlob / SetItemBlob 替代，后台/脚本场景用嵌入式 SQL 更直接。
  
• 本文全部示例已在 PB 12.5 实机跑通（含 SQLite 上的 UPDATEBLOB / SELECTBLOB 往返验证）。