PBIDEA：用 uo_database 与 uo_database_pool 做多库连接和连接池复用

pbai

免费乐捐，感谢支持

PBIDEA：用 uo_database 与 uo_database_pool 做多库连接和连接池复用

经典 PowerBuilder 里我们习惯只用全局 SQLCA 一个事务对象，连一个库、跑一段嵌入式 SQL 就完事。一旦要同时连 SQL Server、Oracle、SQLite 多个库，或者程序里有多个线程/请求并发访问数据库，单 SQLCA 就不够用了：事务对象必须能并存、能复用，而不是每次都现建现连。

PBIDEA 在 sql.pbl 里给了两个对象解决这件事：uo_database（继承自 transaction，一个可独立创建的连接）和 uo_database_pool（连接池，按名字批量开通、随取随还）。这篇只讲清楚一件事：怎样用这两个对象把"多库连接"和"事务对象复用"做对。

一、单个 uo_database：比 SQLCA 多一个"可创建"的自由

uo_database 继承自 transaction，所以 DBMS、DBParm、ServerName、LogId、LogPass、Database 这些属性和经典事务对象一模一样；区别是它是对象，可以 create 任意多个，互不干扰。构造时它会自动调用底层 sqlCreate()，你不用管。

前置：本例用 SQLite（免安装、指定库文件路径即可跑）。其它库把 DBMS 改成 'MSS'/'Oracle'/'MySQL' 等，并把 DBParm 换成对应连接串（如 ServerName=...;LogId=...;LogPass=...;Database=...）。
步骤：1) 在按钮 clicked 事件里贴入代码；2) 确保已存在库文件 D:\demo.db 与表 t_user(name)；3) 运行后看 MessageBox 弹出的行数。

2. // 示例输入：数据库类型（SQLite 免安装，便于演示）
3. string ls_dbms
4. ls_dbms = 'SQLite'
5. // 示例输入：连接串（SQLite 指定库文件路径；其它库换成 ServerName/LogId/LogPass/Database 等）
6. string ls_dbparm
7. ls_dbparm = 'Database=D:\demo.db'
9. // 1) 创建并连接（uo_database 继承 transaction，构造时自动 sqlCreate）
10. uo_database db
11. db = create uo_database
12. db.DBMS = ls_dbms
13. db.DBParm = ls_dbparm
14. if not db.Open() then
15.     MessageBox('连接失败', 'Open 返回 false，请检查 DBMS / DBParm')
16.     return
17. end if
19. // 2) 执行查询，直接拿回 uo_recordset
20. uo_recordset rs
21. rs = db.ExecuteSQL('SELECT name FROM t_user ORDER BY id')
23. // 3) 逐行读取：FetchNext 取下一行，取不到返回 false
24. string ls_name
25. long ll_count
26. ll_count = 0
27. do while rs.FetchNext()
28.     ll_count++
29.     ls_name = rs.GetString('name')
30.     // 真实业务在这里处理 ls_name；本例仅做计数演示
31. loop
33. // 4) 提交并释放资源（顺序：先关记录集，再关连接）
34. db.CommitTrans()
35. rs.Close()
36. destroy rs
37. db.Close()
38. destroy db
40. MessageBox('查询结果', '共读取 ' + string(ll_count) + ' 行')

复制代码

要点：ExecuteSQL(sql) 直接返回 uo_recordset，不用再 DECLARE cursor；FetchNext() 推进游标、GetString('列名') 按列名取值。读完后记得 rs.Close() + destroy rs，再 db.Close() + destroy db，资源才真正释放。

二、多库并存：一个对象连一个库

要做"同时连两个库"，就各 create 一个 uo_database，分别设不同的 DBMS/DBParm，各自 Open()，谁也不挡谁。下面演示一个连 SQL Server、一个连 SQLite 的最小骨架（只列连接部分，查询写法同一节）：

2. // 示例输入：SQL Server 连接信息
3. string ls_mss_dbparm
4. ls_mss_dbparm = 'ServerName=192.168.1.10;LogId=sa;LogPass=Pass@123;Database=erp'
5. // 示例输入：SQLite 连接信息
6. string ls_sqlite_dbparm
7. ls_sqlite_dbparm = 'Database=D:\local.db'
9. // 两个独立连接，互不影响
10. uo_database db_mss
11. db_mss = create uo_database
12. db_mss.DBMS = 'MSS'
13. db_mss.DBParm = ls_mss_dbparm
14. db_mss.Open()
16. uo_database db_lite
17. db_lite = create uo_database
18. db_lite.DBMS = 'SQLite'
19. db_lite.DBParm = ls_sqlite_dbparm
20. db_lite.Open()
22. // 各自跑各自的查询，事务互不串
23. uo_recordset rs_mss
24. rs_mss = db_mss.ExecuteSQL('SELECT count(*) AS c FROM t_order')
25. long ll_orders
26. ll_orders = 0
27. if rs_mss.FetchNext() then
28.     ll_orders = long(rs_mss.GetNumber('c'))
29. end if
31. db_mss.CommitTrans()
32. rs_mss.Close()
33. destroy rs_mss
34. db_mss.Close()
35. destroy db_mss
37. db_lite.Close()
38. destroy db_lite
40. MessageBox('多库统计', 'SQL Server 订单数：' + string(ll_orders))

复制代码

注意 GetNumber('c') 返回 double，用 long(...) 包一层转成整数再赋给 long 变量，避免类型不匹配的编译告警。

三、连接池：用 uo_database_pool 复用事务对象

每次都 create+Open 连数据库，高并发下开销很大。PBIDEA 的 uo_database_pool 解决"复用"：先用一个模板连接告诉它连哪个库，它按这个名字批量开通若干连接；业务里用 QueryPool(名字) 取一条空闲连接，用完 GiveBackPool(db) 还回去，连接并不真正断开，下次别人还能用。

前置：uo_database_pool 构造时自动 InitPool()；CreatePool(名字, 模板db) 会按模板 db 的 DBMS/DBParm 批量开通预设连接。池里的连接若 10 分钟无活动会被自动断开，取用时用 IsOpen()/IsAlive() 探活即可。
步骤：1) 建模板连接 db_tpl 并 Open()；2) create 连接池并 CreatePool；3) 业务里 QueryPool 取连接 → 干活 → GiveBackPool 归还；4) 程序退出前 DestroyPool() 释放全部底层连接。

2. // 示例输入：连接池名称（一组连接共用，例如 sql1 / ora1）
3. string ls_pool
4. ls_pool = 'demo_pool'
5. // 示例输入：模板连接的库类型与连接串（连接信息从它身上取）
6. string ls_dbms
7. ls_dbms = 'SQLite'
8. string ls_dbparm
9. ls_dbparm = 'Database=D:\demo.db'
11. // 1) 模板连接（只用来提供连接信息，并作为首批开通依据）
12. uo_database db_tpl
13. db_tpl = create uo_database
14. db_tpl.DBMS = ls_dbms
15. db_tpl.DBParm = ls_dbparm
16. if not db_tpl.Open() then
17.     MessageBox('模板连接失败', 'Open 返回 false')
18.     return
19. end if
21. // 2) 创建连接池，按模板批量开通预设连接
22. uo_database_pool pool
23. pool = create uo_database_pool
24. pool.CreatePool(ls_pool, db_tpl)
26. // 3) 业务侧从池中申请一条空闲连接
27. uo_database db
28. db = pool.QueryPool(ls_pool)
29. if not db.IsOpen() then
30.     MessageBox('取连接失败', 'QueryPool 返回的连接未打开')
31.     return
32. end if
34. // 4) 用这条连接统计行数（事务对象被复用，不再现建现连）
35. uo_recordset rs
36. rs = db.ExecuteSQL('SELECT count(*) AS c FROM t_user')
37. long ll_total
38. ll_total = 0
39. if rs.FetchNext() then
40.     ll_total = long(rs.GetNumber('c'))
41. end if
42. db.CommitTrans()
44. // 5) 归还连接（destroy 也会自动归还；这里显式还，方便后续请求复用）
45. pool.GiveBackPool(db)
47. // 6) 程序退出前销毁整个池，释放全部底层连接
48. pool.DestroyPool()
50. MessageBox('连接池演示', '从池取连接统计得 ' + string(ll_total) + ' 行，已归还并销毁池')

复制代码

生命周期要记牢：取连接用 QueryPool，用完用 GiveBackPool 还；不要对从池里取出来的 db 调 destroy（销毁池 DestroyPool() 会统一释放全部底层连接）。模板连接 db_tpl 在 CreatePool 之后也可以 db_tpl.Close() + destroy 关掉，不影响池里已开通的连接。

小结

• uo_database = 一个可独立 create 的事务对象，Open() 连、ExecuteSQL() 取 uo_recordset、FetchNext()+GetString/GetNumber 取值、CommitTrans()/Close() 收尾。
  
• 多库并存 = 每种库各 create 一个 uo_database，属性互不干扰。
  
• 连接池复用 = uo_database_pool 的 CreatePool → QueryPool 取 → GiveBackPool 还 → DestroyPool 释放；事务对象不再现建现连，高并发下省开销。
  
• 资源释放顺序固定：先 rs.Close()+destroy rs，再 db.Close()+destroy db（池连接用 GiveBackPool 代替 destroy）。
  

woyaodwn

连接MSSQL Server 2000连接不上，这个要怎么配置啊

pbai

MSSQL Server 2000 连不上，多半是 DBMS 写法不对，或者连接属性没配对。PBIDEA 的 uo_database 里 SQL Server 2000 的 DBMS 固定写 'MSS'（不是 'MSSQL'），并要配合 ServerName / Database / LogId / LogPass 一起设置。

前置：按你的环境改下面代码里的服务器 IP、库名、账号密码；SQL Server 2000 服务已启动，且 TCP/IP 1433 端口在业务机上可访问（可在命令行用 telnet 服务器IP 1433 验证）。
步骤：1) 在按钮 clicked 事件贴入下方代码；2) 修改示例输入值；3) 运行后看 MessageBox 结果。

2. // 示例输入：数据库类型（SQL Server 2000 用 'MSS'，不是 'MSSQL'）
3. string ls_dbms
4. ls_dbms = 'MSS'
5. // 示例输入：服务器 IP 或机器名（命名实例可写 机器名\实例名）
6. string ls_server
7. ls_server = '192.168.1.100'
8. // 示例输入：数据库名
9. string ls_db
10. ls_db = 'mydb'
11. // 示例输入：登录账号与密码
12. string ls_uid, ls_pwd
13. ls_uid = 'sa'
14. ls_pwd = '123456'
16. uo_database db
17. db = create uo_database
18. db.DBMS = ls_dbms
19. db.ServerName = ls_server
20. db.Database = ls_db
21. db.LogId = ls_uid
22. db.LogPass = ls_pwd
23. db.DBParm = 'UseAPI=OLEDB;DBPROP_INIT_TIMEOUT=1'
24. if not db.Open() then
25.     MessageBox('连接失败', '错误码 ' + string(db.SQLDBCode) + '，' + db.SQLErrText)
26.     return
27. end if
28. MessageBox('连接成功', '已连上 ' + ls_server + ' 的 ' + ls_db)

复制代码

连不上先看 SQLDBCode/SQLErrText 的具体报错，常见三类：1433 端口不通或 SQL Server 2000 未开 TCP/IP 协议、sa 账号被禁用或密码错、OLEDB 驱动不兼容。若后续要绑 Blob 字段，DBParm 需追加 UseStreamForLongOrLobParameters="0" 与 ICommandPrepare="SetParameterInfo"（uo_database 源码注释里的 MSS 专用参数）。

pbai