马上周末了，趁着下午这会儿回顾一下这几天对旧项目的升级过程，一些重要但不常用的东西记录下来是很有必要的。其中一个项目中对KBMMW的远程数据通讯方式做了改进，利用SampleService/SampleClient方式传输数据集，以增加对底层数据通讯的可控性。
服务端代码示例：
|
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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
type TkbmMWSimpleService1 = class(TkbmMWSimpleService) private { Private declarations } protected { Protected declarations } function ProcessRequest(const Func:string; const ClientIdent:TkbmMWClientIdentity; const Args:array of Variant):Variant; override; function PerformOpenSQL(ClientIdent:TkbmMWClientIdentity; const Args:array of Variant):Variant; virtual; public { Public declarations }{$IFNDEF CPP}class{$ENDIF} function GetFlags:TkbmMWServiceFlags; override; end;//...省略function TkbmMWSimpleService1.ProcessRequest(const Func:string; const ClientIdent:TkbmMWClientIdentity; const Args:array of Variant):Variant;var AFunc:string;begin AFunc:=UpperCase(Func); if AFunc='OPENSQL' then Result:=PerformOpenSQL(ClientIdent,Args) else Result:=inherited ProcessRequest(Func,ClientIdent,Args);end;function TkbmMWSimpleService1.PerformOpenSQL(ClientIdent:TkbmMWClientIdentity; const Args:array of Variant):Variant;var sqlStr: string; aQuery: TUniQuery; aconn: TkbmMWUNIDACConnection; memTable: TkbmMemTable; aStreamFormat: TkbmBinaryStreamFormat;begin Result := 0; sqlStr:=args[0]; aQuery := TUniQuery.Create(nil);//uniquery，和两层的用法一样 aQuery.Options.QueryRecCount := True; aconn := TkbmMWUNIDACConnection(DMunt.kbmMWUNIDACConnectionPool1.GetBestConnection(True,0,nil,10000));//取连接池中的连接 if aconn = nil then begin kbmMWRaiseServerException('无可用的数据库连接'); Exit; end; aQuery.Connection := aconn.Database; aQuery.SQL.Text := sqlStr; if (mainform.PAL_mode_01.Visible) then LogIOer.AddShow(ClientIdent.Username+'执行SQL查询:'+aQuery.SQL.Text,0); memTable := TkbmMemTable.Create(nil); aStreamFormat := TkbmBinaryStreamFormat.Create(nil); memTable.DefaultFormat := aStreamFormat; memTable.IndexFieldNames := ''; memTable.SortFields := ''; memTable.MasterSource := nil; try try aQuery.Open;//查询 Result := aQuery.RecordCount;//返回记录条数 except on E:Exception do begin kbmMWRaiseServerException(E.Message+',异常语句:'+aQuery.SQL.Text);//抛异常到客户端 Exit; end; end; memTable.LoadFromDataSet(aQuery,[mtcpoStructure,mtcpoProperties]); //复制数据集进KbMemTable memTable.SaveToStreamViaFormat(ResultStream,aStreamFormat); //按照指定流格式存入结果流ResultStream finally aconn.UnlockConnection; aQuery.Free; memTable.Free; aStreamFormat.Free; end;end; |
客户端代码:
|
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
|
function openSql(Sqlstr:string;var Ds:TDataSet;var Rs:string):integer;stdcall; var args: array[0..1] of Variant; begin Result := 0; Rs := '执行成功'; if assigned(kbmMWSimpleClient1) then begin try args[0]:= Sqlstr;//SQL语句 Result := kbmMWSimpleClient1.Request('TkbmMWSimpleService1','','openSql',args);//SimpleClient执行请求 kbmMemTable.EmptyTable;//清空内存表 kbmMemTable.LoadFromStreamViaFormat(kbmMWSimpleClient1.ResultStream,aStreamFormat);//将结果流复制进内存表 ds := kbmMemTable;//返回dataset（kbmMemTable继承自Tdataset） except on E:Exception do begin Result := -1; rs := errorInfo(E.Message); if FIsLog then Writelog(rs); end; end; end else begin Result := -1;//未执行初始化操作 Rs := '远程数据通讯接口未执行初始化操作' end; end; |
核心代码就这些，相信用到的人能够看明白。同理，可以利用这种方式实现二进制文件流（如：图像等）的传输，不再赘述。
另外，有一个小问题折磨了我一下午，提醒大家一下，希望大家不要像我一样粗心：
有两个类：TkbmBinaryStreamFormat（kbmMemBinaryStreamFormat.pas）、TkbmMWBinaryStreamFormat(kbmMWBinaryStreamFormat.pas)很容易混淆（正确用法见上述代码），而且一旦混淆，会造成KbmMeMTable在流的处理过程中出错。
http://www.pfeng.org/archives/385