PBIDEA：用 uo_database 与 uo_database_pool 做数据库连接与连接池复用

pbai

免费乐捐，感谢支持

PBIDEA：用 uo_database 与 uo_database_pool 做数据库连接与连接池复用

阅读说明
1. 适用版本：PowerBuilder 10（PBIDEA 版本源 UPDATE\10 为基准）；PB12.5 已实测同源码、同行为，代码可直接复用无需改写。
2. 支持数据库：SQL Server 2008 R2（本文全部示例的实测环境）。uo_database 另支持 ODBC / Oracle / MySQL / PostgreSQL / SQLite / DB2 / Sybase / SQLAnywhere / Firebird(InterBase) / SQLBase，连法相同，仅 DBMS 取值不同。
3. 操作系统与环境要求：Windows 7+；必须部署与 PB 版本匹配的 PbIdea.dll / Pbidea_cs.dll；工程库列表需同时挂载 sql.pbl 与 websuite.pbl；示例连接 127.0.0.1,18433（SQL Server 2008 R2 SP3，10.50.6000.34）。
4. 难度系数：★★★☆☆
5. 其它阅读说明：需先了解 transaction 对象的常用属性（DBMS/ServerName/Database/LogId/LogPass/AutoCommit/SQLCode/SQLErrText）；示例会在 tempdb 建演示表 dbo.t_pbidea_demo，跑完自动删除，不影响现有数据。

一、为什么不要只用裸 SQLCA

写 PB 的人对 SQLCA 太熟了：一个全局的 transaction，CONNECT USING SQLCA; 一把梭。但真做项目会撞上四堵墙：

问题	裸 SQLCA 的表现
多库	SQLCA 是全局单例，要连第二个库就得再声明 transaction，连接参数散落各处
复用	每次要连都得重新赋一遍 DBMS/LogId/LogPass，或写死在 ini 里再手工解析
参数化	只能拼字符串，或者退回 PB 原生动态 SQL 的 PREPARE ... USING 四步式
连接池	完全没有，多线程/多请求场景只能自己造轮子

PBIDEA 的 uo_database（在 sql.pbl）就是冲着这四点来的。它继承自 transaction，所以你熟的那套属性一个不少，但上面挂了一整套外部函数方法，连接方式、参数化取数、事务、连接池全都有。

二、uo_database 是什么

关键一句话：uo_database 是 transaction 的子类，不是普通 NVO。

2. global type uo_database from transaction

复制代码

所以它自带 DBMS / Database / LogId / LogPass / ServerName / DBParm / AutoCommit / SQLCode / SQLErrText / SQLNRows 全套属性，用法和 SQLCA 一模一样，零学习成本。

生命周期

• constructor 自动调用 sqlCreate()，destructor 自动调用 sqlDestroy()；
  
• 所以是 create 即用、destroy 即释放，不需要手工初始化。
  

方法全表（对照 sql.pbl 源码实证）

方法	返回	说明
Open()	boolean	连接（需先设好属性）
Open(string configFile)	boolean	按配置文件连接
IsOpen()	boolean	是否已连接
IsAlive()	boolean	连接是否存活（探活用）
SetTransLevel(int level)	—	事务隔离级别 0–4
Close()	—	断开
CommitTrans() / RollbackTrans()	—	提交 / 回滚
ExecuteSQL(string sql, ...)	uo_recordset	执行 SQL，变参（可散参或 any 数组）
PrepareSQL(string sql)	uo_recordset	预处理语句
ExecuteScaler(string sql)	any	标量查询，只要一个值就用它
ExecuteScaler(sql, ref boolean success)	any	带成功标志
RowsAffected()	long	受影响行数
SaveConfig(string configFile)	int	把当前属性存成配置文件
Printf(string fmt, ...)	int	打印到控制台

事件：beginconnect() / endconnect(boolean ab_connect) / ondisconnect()。

DBMS 取值（源码注释原文）

"ODBC"、"MSS"（或 "Microsoft SQL Server" / "MSS Microsoft SQL Server"）、"Oracle" / "O90" / "O12"（大写 O 打头皆视为 Oracle，需设 ThreadSafe="Yes"）、"InterBase" / "Firebird"、"SQLBase"、"DB2"、"Sybase"、"MySQL"、"PostgreSQL"、"SQLite"、"SQLAnywere"。

三、环境准备：建表 SQL

下面这段在 SQL Server 2008 上建演示表，直接用查询分析器执行即可（示例对象运行时也会自己建一次，这里先给你看清楚表结构）：

2. -- SQL Server 2008 语法：identity 自增 + decimal(12,2) 金额 + getdate() 默认时间
3. if object_id('dbo.t_pbidea_demo') is not null drop table dbo.t_pbidea_demo
4. go
5. create table dbo.t_pbidea_demo(
6.     id       int identity(1,1) primary key,
7.     code     varchar(20)   not null,
8.     name     nvarchar(50)  not null,
9.     qty      int           not null default 0,
10.     price    decimal(12,2) not null default 0,
11.     crt_time datetime      not null default getdate()
12. )
13. go

复制代码

前置：库列表挂 sql.pbl + websuite.pbl，运行目录放 PbIdea.dll / Pbidea_cs.dll。

四、第一个可运行示例：连接 + 建表

前置：新建 NVO nvo_dbpool_demo，库列表含 sql.pbl 与 websuite.pbl；运行目录已放 PbIdea.dll。
步骤：1) 把下面代码贴进 nvo_dbpool_demo；2) 在窗口按钮的 clicked 里写 nvo_dbpool_demo lnvo / lnvo = create nvo_dbpool_demo / lnvo.of_demo() / destroy lnvo；3) 运行点击，MessageBox 会输出每一步的执行结果。

2. // ===== 输入区：按你的实际环境修改 =====
3. uo_database ldb                 // uo_database 连接对象
4. string ls_server                // 服务器地址与端口，端口用逗号分隔
5. string ls_db                    // 数据库名
6. string ls_user                  // 登录名
7. string ls_pwd                   // 登录口令
9. ls_server = '127.0.0.1,18433'
10. ls_db     = 'tempdb'
11. ls_user   = 'sa'
12. ls_pwd    = 'Zkkt@667788'
14. // 功能：准备一条 uo_database 连接（此时还没连，Open() 才真正建立连接）
15. // 要点：uo_database 继承自 transaction，属性名与 SQLCA 完全一致
16. ldb = create uo_database
17. ldb.DBMS       = 'MSS'          // SQL Server；等价写法 'Microsoft SQL Server'
18. ldb.ServerName = ls_server      // 端口用逗号分隔，不能用冒号
19. ldb.Database   = ls_db
20. ldb.LogId      = ls_user
21. ldb.LogPass    = ls_pwd
22. ldb.AutoCommit = true           // true=自动提交；false=需手工 CommitTrans/RollbackTrans
24. // 功能：建表（SQL Server 2008 语法）
25. // 要点：DDL 没有结果集，成败只能看 adb.SQLCode / adb.SQLErrText
26. uo_recordset lrs
27. string ls_ret
29. ls_ret = ''
30. // PB 字符串里含单引号时，外层改用双引号包，不要写成 '' 双写（那是 T-SQL 不是 PowerScript）
31. lrs = ldb.ExecuteSQL("if object_id('dbo.t_pbidea_demo') is not null drop table dbo.t_pbidea_demo")
32. if ldb.SQLCode <> 0 then
33.     ls_ret = 'DROP_FAIL code=' + String(ldb.SQLCode) + ' ' + ldb.SQLErrText
34. else
35.     lrs = ldb.ExecuteSQL('create table dbo.t_pbidea_demo(id int identity(1,1) primary key, code varchar(20) not null, name nvarchar(50) not null, qty int not null default 0, price decimal(12,2) not null default 0, crt_time datetime not null default getdate())')
36.     if ldb.SQLCode <> 0 then
37.         ls_ret = 'CREATE_FAIL ' + ldb.SQLErrText
38.     else
39.         ls_ret = 'DDL_OK'
40.     end if
41. end if
43. MessageBox('建表结果', ls_ret)

复制代码

实测输出：DDL_OK。

五、参数化写入：三种写法

这里是本文最容易踩坑的地方，先说结论：

PBIDEA 的参数占位符是 :1 / :2 或 :名字，不是 ?。
? 是 PB 原生动态 SQL 的写法，搬到 uo_database 上会报「至少一个参数没有被指定值」。

三种写法全部实机跑通：

2. // ===== 输入区：写入内容与连接 =====
3. string ls_code          // 商品编码
4. string ls_name          // 商品名称
5. long   ll_qty           // 数量
6. double ld_price         // 单价（注意：用 double，不要用 decimal）
7. uo_recordset lrs
8. string ls_ret
9. boolean lb_ok
10. uo_database ldb         // 已 Open 的连接
12. ls_code  = 'A001'
13. ls_name  = '鼠标'
14. ll_qty   = 10
15. ld_price = 59.50
16. ls_ret   = ''
18. // 方式一：ExecuteSQL 变参，占位符 :1 :2 :3 :4
19. // 坑：变参位置不要直接写字面量，要用【已声明类型的变量】传，否则 DLL 认不出参数类型
20. lrs = ldb.ExecuteSQL('insert into dbo.t_pbidea_demo(code,name,qty,price) values(:1,:2,:3,:4)', ls_code, ls_name, ll_qty, ld_price)
21. if ldb.SQLCode <> 0 then
22.     ls_ret = 'INS1_FAIL ' + ldb.SQLErrText
23. else
24.     ls_ret = 'INS1 rows=' + String(ldb.RowsAffected())
25. end if
27. // 方式二：PrepareSQL + 按位置绑定（位置从 1 开始）
28. ls_code = 'A002'
29. ls_name = '键盘'
30. ll_qty = 5
31. ld_price = 129.00
32. lrs = ldb.PrepareSQL('insert into dbo.t_pbidea_demo(code,name,qty,price) values(:1,:2,:3,:4)')
33. lrs.BindParam(1, ls_code)
34. lrs.BindParam(2, ls_name)
35. lrs.BindParam(3, ll_qty)
36. lrs.BindParam(4, ld_price)
37. lb_ok = lrs.ExecuteSQL()
38. if lb_ok then
39.     ls_ret = ls_ret + ' INS2 rows=' + String(lrs.RowsAffected())
40. else
41.     ls_ret = ls_ret + ' INS2_FAIL ' + ldb.SQLErrText
42. end if
44. // 方式三：PrepareSQL + 按名字绑定
45. ls_code = 'A003'
46. ls_name = '显示器'
47. ll_qty = 2
48. ld_price = 899.00
49. lrs = ldb.PrepareSQL('insert into dbo.t_pbidea_demo(code,name,qty,price) values(:code,:name,:qty,:price)')
50. lrs.BindParam('code', ls_code)
51. lrs.BindParam('name', ls_name)
52. lrs.BindParam('qty', ll_qty)
53. lrs.BindParam('price', ld_price)
54. lb_ok = lrs.ExecuteSQL()
55. if lb_ok then
56.     ls_ret = ls_ret + ' INS3 rows=' + String(lrs.RowsAffected())
57. else
58.     ls_ret = ls_ret + ' INS3_FAIL ' + ldb.SQLErrText
59. end if
61. MessageBox('写入结果', ls_ret)

复制代码

实测输出：INS1 rows=1 INS2 rows=1 INS3 rows=1。

三种怎么选：

写法	适用场景	备注
ExecuteSQL 变参	一次性语句，图省事	散参或 any 数组都行，数组形式适合 in(:args)
PrepareSQL + 位置绑定	同一语句循环执行多次	编译一次、绑定多轮，性能最好
PrepareSQL + 名字绑定	SQL 里参数多、顺序易错	可读性最好

BindParam 还有几个实用重载：出参必须带 ref（BindParam(1, ref ls_out, 0)，nSize 为 0 时默认 1024）；BindParamFile(pos, fileName) 可以直接把文件内容/URL 绑进字段；SetBlobBindType(0..4) 控制 blob 的绑定方式。

六、取数：uo_recordset 全貌

ExecuteSQL 返回的是 uo_recordset，destructor 会自动 Close()。

2. uo_recordset lrs
3. uo_json ljsons[]
4. string ls_ret
5. string ls_code
6. string ls_name
7. double ld_qty
8. double ld_price
9. long   ll_rows
10. int    li_n
11. any    la_cnt
12. uo_database ldb             // 已 Open 的连接
14. ls_ret = ''
15. ll_rows = 0
16. lrs = ldb.ExecuteSQL('select code,name,qty,price,crt_time from dbo.t_pbidea_demo order by id')
17. if lrs.HasResultSet() then
18.     do while lrs.FetchNext()
19.         ls_code = lrs.GetString('code')      // 按字段名取
20.         ls_name = lrs.GetString(2)           // 按序号取（从 1 开始）
21.         ld_qty = lrs.GetNumber('qty')
22.         ld_price = lrs.GetNumber('price')
23.         ll_rows = ll_rows + 1
24.         ls_ret = ls_ret + '~r~n  ROW ' + ls_code + ' ' + ls_name + ' qty=' + String(ld_qty) + ' price=' + String(ld_price)
25.     loop
26.     ls_ret = 'QUERY rows=' + String(ll_rows) + ls_ret
27. else
28.     ls_ret = 'QUERY NO_RESULTSET ' + ldb.SQLErrText
29. end if
31. // 转 JSON：整个结果集一次性取成 uo_json 数组
32. // 注意：上面的 do while 已经把 lrs 读完了，必须重新 ExecuteSQL 拿一个新结果集
33. lrs = ldb.ExecuteSQL('select top 2 code,name,qty from dbo.t_pbidea_demo order by id')
34. li_n = lrs.FetchJsons(ljsons)
35. if li_n > 0 then
36.     ls_ret = ls_ret + '~r~n  JSONS n=' + String(li_n) + ' first=' + ljsons[1].ToString()
37. else
38.     ls_ret = ls_ret + '~r~n  JSONS n=0'
39. end if
41. // 标量查询：只要一个值就用 ExecuteScaler
42. la_cnt = ldb.ExecuteScaler('select count(*) from dbo.t_pbidea_demo')
43. ls_ret = ls_ret + '~r~n  SCALAR count=' + String(la_cnt)
45. MessageBox('取数结果', ls_ret)

复制代码

实测输出：

2. QUERY rows=3
3.   ROW A001 鼠标 qty=10 price=59.5
4.   ROW A002 键盘 qty=5 price=129
5.   ROW A003 显示器 qty=2 price=899
6.   JSONS n=1 first=[{"code":"A001","name":"鼠标","qty":10},{"code":"A002","name":"键盘","qty":5}]
7.   SCALAR count=3

复制代码

注意 FetchJsons 返回的 n 是 1 —— 它返回的是一个整体 uo_json（数组），不是每行一个元素；ljsons[1] 就是整份数据。

取值方法两套重载（按字段名 / 按序号，从 1 开始）：GetNumber / GetString / GetBlob / GetDecimal / GetDate / GetTime / GetDateTime，另有 GetValue() 返回 any 由你自判类型。字段元信息走 GetFieldCount() + GetField(idx 或 name) 拿 uo_field（GetName/GetType/GetSize/GetPrecision/GetScale）。

⚠️ uo_field 里取小数的方法源码拼写是 GetDeciaml()（不是 GetDecimal），照抄，别"顺手改正"，否则编译不过。

七、事务与隔离级别

AutoCommit = false 之后，所有写操作都进事务，必须显式提交或回滚：

2. // ===== 输入区：要写入的一行数据 =====
3. string ls_code      // 编码
4. string ls_name      // 名称
5. long   ll_qty       // 数量
6. double ld_price     // 单价
7. uo_recordset lrs
8. string ls_ret
9. uo_database ldb             // 已 Open 的连接
11. ls_code  = 'B001'
12. ls_name  = '事务行'
13. ll_qty   = 1
14. ld_price = 9.90
15. ls_ret   = ''
16. ldb.AutoCommit = false
17. // 0=ReadUncommitted 1=ReadCommitted 2=RepeatableRead 3=Serializable 4=Snapshot
18. ldb.SetTransLevel(1)
19. lrs = ldb.ExecuteSQL('insert into dbo.t_pbidea_demo(code,name,qty,price) values(:1,:2,:3,:4)', ls_code, ls_name, ll_qty, ld_price)
20. if ldb.SQLCode = 0 then
21.     ls_ret = 'TX_COMMIT rows=' + String(lrs.RowsAffected())
22.     ldb.CommitTrans()
23. else
24.     ldb.RollbackTrans()
25.     ls_ret = 'TX_ROLLBACK ' + ldb.SQLErrText
26. end if
27. ldb.AutoCommit = true
29. MessageBox('事务结果', ls_ret)

复制代码

实测输出：TX_COMMIT rows=1。

两个细节：

• 行数要在 CommitTrans() 之前读。提交之后 adb.RowsAffected() 会变成 -1，想拿行数就读 lrs.RowsAffected()。
  
• SetTransLevel 的参数是 int，直接写数字即可，不用常量。
  

八、连接池：uo_database_pool

四个方法，一张表讲清：

方法	说明
CreatePool(string poolName, uo_database db)	按模板连接建池，池名可多组共用
QueryPool(string poolName)	取一条连接，用完必须还
GiveBackPool(uo_database db)	归还（destroy 也会自动还，二选一）
DestroyPool()	销毁池，释放池中全部连接

2. // 功能：连接池 —— 建池 / 取连接 / 使用 / 归还 / 销毁
3. // 要点：QueryPool 取出的连接用完必须 GiveBackPool；
4. //       池中连接 10 分钟无活动会被自动断开，长时间闲置后要先 IsAlive() 探活
5. uo_database ldb, ldb2
6. uo_database_pool lpool
7. uo_recordset lrs
8. string ls_ret
9. int    li_ret
10. any    la_cnt
12. ls_ret = ''
13. ldb = create uo_database
14. ldb.DBMS = 'MSS'
15. ldb.ServerName = '127.0.0.1,18433'
16. ldb.Database = 'tempdb'
17. ldb.LogId = 'sa'
18. ldb.LogPass = 'Zkkt@667788'
19. ldb.AutoCommit = true
21. // 关键坑：CreatePool 的模板连接必须是【已经 Open 成功】的连接。
22. // 只 create 不 Open，DLL 会打印 "template db: 00000000"，池根本没建起来，
23. // 后面 QueryPool 一律返回 "not find name [池名] in pool"
24. if not ldb.Open() then
25.     MessageBox('连接池', 'POOL_TPL_CONNECT_FAIL ' + ldb.SQLErrText)
26.     destroy ldb
27.     return
28. end if
30. lpool = create uo_database_pool
31. li_ret = lpool.CreatePool('mss_demo', ldb)
32. ls_ret = 'CREATE_POOL ret=' + String(li_ret)
34. ldb2 = lpool.QueryPool('mss_demo')        // 从池中申请一条连接
35. if IsValid(ldb2) then
36.     ls_ret = ls_ret + ' QUERY_POOL isopen=' + String(ldb2.IsOpen()) + ' alive=' + String(ldb2.IsAlive())
37.     lrs = ldb2.ExecuteSQL('select count(*) as c from dbo.t_pbidea_demo')
38.     if lrs.HasResultSet() then
39.         if lrs.FetchNext() then
40.             la_cnt = lrs.GetValue('c')
41.             ls_ret = ls_ret + ' cnt=' + String(la_cnt)
42.         end if
43.     end if
44.     lpool.GiveBackPool(ldb2)              // 用完一定要还
45.     ls_ret = ls_ret + ' GIVEN_BACK'
46. else
47.     ls_ret = ls_ret + ' QUERY_POOL_FAIL'
48. end if
50. lpool.DestroyPool()                       // 销毁池，释放池中全部连接
51. ls_ret = ls_ret + ' DESTROYED'
52. destroy lpool
53. ldb.Close()
54. destroy ldb
56. MessageBox('连接池结果', ls_ret)

复制代码

实测输出：CREATE_POOL ret=1 QUERY_POOL isopen=true alive=true cnt=4 GIVEN_BACK DESTROYED。

池的注册是 DLL 级别按名字的：同一个名字在任何地方 QueryPool 都能取到（PBIDEA 自带的 SQL 工作台就是 CreatePool 之后立刻 destroy pool，后面另建 uo_database_pool 照样能取）。这也意味着程序启动时最好先 DestroyPool() 清一次，避免上一轮残留。

九、连接配置复用

不想每次都写一堆赋值，就先连一次再存盘：

2. // 连成功后把属性存成配置文件，以后 Open(文件) 直连
3. uo_database ldb
4. ldb = create uo_database
5. ldb.DBMS = 'MSS'
6. ldb.ServerName = '127.0.0.1,18433'
7. ldb.Database = 'tempdb'
8. ldb.LogId = 'sa'
9. ldb.LogPass = 'Zkkt@667788'
10. if ldb.Open() then
11.     ldb.SaveConfig('db.cfg')     // 存盘
12.     ldb.Close()
13. end if
14. destroy ldb
16. // 以后：
17. uo_database ldb2
18. ldb2 = create uo_database
19. if ldb2.Open('db.cfg') then
20.     MessageBox('配置连接', 'OK db=' + ldb2.Database)
21. end if
22. destroy ldb2

复制代码

十、坑清单（全部实机踩过）

#	坑	症状	解法
1	占位符写成 ?	「至少一个参数没有被指定值」+ invalid index 1..n	改成 :1 :2 或 :名字
2	变参直接写字面量	unknwn param!!!，字段被插成 NULL	先声明类型化变量再传
3	用 decimal 绑定	unknwn param!!!，列不允许 Null	改用 double
4	CreatePool 传未 Open 的连接	template db: 00000000、not find name in pool	模板连接必须先 Open() 成功
5	结果集读完再 FetchJsons	返回 n=0	重新 ExecuteSQL 拿新结果集
6	CommitTrans() 后读行数	RowsAffected() = -1	提交前读，或读 lrs.RowsAffected()
7	PB 字符串里双写单引号 ''	C0031 语法错误	外层改双引号，或用 ~'
8	库列表只挂 sql.pbl	C0001: Illegal data type: uo_json	websuite.pbl 一起挂
9	池连接闲置 10 分钟	自动断开，再用报错	用前 IsAlive() 探活
10	uo_field.GetDeciaml() 拼写	写成 GetDecimal 编译不过	照抄源码拼写 GetDeciaml
11	MSSQL 绑 BLOB	绑定失败	加 DBParm：UseStreamForLongOrLobParameters="0";ICommandPrepare="SetParameterInfo"
12	Oracle 连接	报线程安全错	设 ThreadSafe="Yes"

十一、对比：三条连库路线怎么选

维度	SQLCA（PB 原生）	uo_database（PBIDEA）	pblit LIT *
归属	PB 自带	PBIDEA sql.pbl，需 PbIdea.dll	pbnpm 的 pblit 驱动
多实例	需自己声明 transaction	create uo_database 随手开	同左
参数化	原生动态 SQL 四步式	:1 变参 / BindParam	依赖驱动
连接池	无	uo_database_pool 原生支持	无
依赖	无	PbIdea.dll + sql.pbl + websuite.pbl	pblit{版本}.dll
适用	最简 Demo / 老工程	新项目推荐	想绕开外部依赖时

顺带一提，uo_database 的 DBMS 也支持 "SQLite"，如果你只是想本地存点数据、不想牵扯 SQL Server，把 DBMS 换成 SQLite、Database 换成 db 文件路径即可，其余代码一行不改。

十二、扩展点

• 多库切换：按名字建多个池（CreatePool('ora', ldbOra)、CreatePool('mss', ldbMss)），业务代码用池名取连接，切换数据源只改建池那一处。
  
• 配合 uo_json：FetchJsons 直接产出 uo_json，可以无缝接给 uo_httpclient 发走，或 WriteJsonFile 落盘，做接口/导出很省事。
  
• 配合 uo_database 的事件：beginconnect / endconnect / ondisconnect 里挂日志，就能不侵入业务地做连接监控。
  
• 分页：SQL Server 2008 用 ROW_NUMBER() 包一层即可，例如
  

  select * from (select ROW_NUMBER() over(order by id) as rn, * from dbo.t_pbidea_demo) t where rn between 1 and 10。

---

实机验证情况（本文代码已全部跑通）

项	结果
编译环境	PowerBuilder 12.5，pypower pbl import 导入 nvo_dbpool_demo.sru（GBK/CRLF/无 BOM）
全量编译	build rebuild --type full → 0 错误
运行验证	PBVM 真机 pypower test → PASS，输出 DDL_OK / INS1 rows=1 INS2 rows=1 INS3 rows=1 / QUERY rows=3 / JSONS n=1 / SCALAR count=3 / TX_COMMIT rows=1 / CREATE_POOL ret=1 ... cnt=4 / DROP_END_OK
数据库	SQL Server 2008 R2 SP3（10.50.6000.34），127.0.0.1,18433
编码检查	check_enc.py bad=0；check_pb125.py 0 错误 0 提醒
PB10 与 PB12.5	四个对象（uo_database / uo_recordset / uo_field / uo_database_pool）两版源码逐字节相同，API 无差异，示例以 PB10 为基准书写，PB12.5 直接复用

第九节 SaveConfig 那段为静态核对（配置文件路径按你的部署目录调整），其余全部为实机跑通。

pbai

PB10 兼容版 PBL 已打包上传（附件可直接下载）

对应文章：PBIDEA：用 uo_database 与 uo_database_pool 做数据库连接与连接池复用

dbpool_pb10.zip (73.94 KB, 下载次数: 0)

10 小时前 上传

点击文件名下载附件

一、环境要求
1. PowerBuilder 10 及以上（本包按 PB10 编译；PB12.5 实测同源码同行为，可直接复用）；
2. Windows 7+，需部署与 PB 版本匹配的 PbIdea.dll / Pbidea_cs.dll（放到 exe 同目录）；
3. 数据库：SQL Server 2008 R2（本文实测 127.0.0.1,18433，sa 登录）；
   uo_database 换 DBMS 取值即可连 ODBC / Oracle / MySQL / PostgreSQL / SQLite / DB2 / Sybase 等。

二、包内有什么
dbpool.pbt + dbpool.pbl（已编译，含 nvo_dbpool_demo / uo_database / uo_recordset / uo_field / uo_database_pool / uo_json 及依赖链）+ src 源码 + 使用说明.txt。

三、操作细节步骤
1. 解压到不含中文和空格的目录，例如 D:\pb10_dbpool；
2. 把 PbIdea.dll、Pbidea_cs.dll 复制进去；
3. PB10 打开 dbpool.pbt，Full Rebuild（应 0 错误，本包已按此标准生成）；
4. 改 nvo_dbpool_demo 的 type variables：is_server / is_db / is_user / is_pwd；
5. 窗口按钮 clicked 里写：
   nvo_dbpool_demo lnvo
   lnvo = create nvo_dbpool_demo
   lnvo.of_demo()
   destroy lnvo
6. 运行点击按钮，MessageBox 输出每一步结果。

四、建表 SQL（示例依赖，对象运行时也会自己建、跑完自己删）
if object_id('dbo.t_pbidea_demo') is not null drop table dbo.t_pbidea_demo
go
create table dbo.t_pbidea_demo(
    id       int identity(1,1) primary key,
    code     varchar(20)   not null,
    name     nvarchar(50)  not null,
    qty      int           not null default 0,
    price    decimal(12,2) not null default 0,
    crt_time datetime      not null default getdate()
)
go
默认写在 tempdb，不需要额外建库。

五、实机验证情况
· PB10：pypower --pb-version 100 全量编译 0 错误，pbl list 核对对象齐全；
· PB12.5：import → rebuild full 0 错误 → PBVM 真机 pypower test PASS，实际输出：
  DDL_OK / INS1 rows=1 INS2 rows=1 INS3 rows=1 / QUERY rows=3 / JSONS n=1 / SCALAR count=3 /
  TX_COMMIT rows=1 / CREATE_POOL ret=1 ... cnt=4 GIVEN_BACK DESTROYED / DROP_END_OK
· 数据库：SQL Server 2008 R2 SP3 (10.50.6000.34)；编码 GBK/CRLF/无 BOM 全通过；
· 未实测：文中「SaveConfig 配置复用」一段为静态核对（配置文件路径需按你的部署目录调整），其余全部实机跑通。

六、三个最容易踩的坑（实机踩出来的）
1. 占位符是 :1 / :名字，不是 ? —— 写 ? 会报「至少一个参数没有被指定值」；
2. 变参位置不能直接写字面量，金额也不能用 decimal —— 先声明类型化变量，金额用 double，否则报 unknwn param!!!；
3. CreatePool 的模板连接必须已经 Open() 成功 —— 否则 DLL 打印 template db: 00000000，后面 QueryPool 一律 not find name in pool。