【问题标题】：Return Two Datasets from DataSnap Server in One Request在一个请求中从 DataSnap 服务器返回两个数据集
【发布时间】：2011-11-05 05:52:17
【问题描述】：

2012-06-27 评论

原帖有一些有用的代码，但并没有真正说明如何在来自客户端应用程序的一个请求中从 DataSnap 服务器返回多个数据集。要查看如何执行此操作的示例，请查看页面底部标记为正确的 Answer。

2011-08-31 评论

多亏了 Gunny，我重新审视了一切。令人烦恼的问题是我自己的错误，现在已修复。我可以通过在每个数据库查询之间创建/销毁 TSQLQuery 组件，在单个客户端到服务器请求中在 DataSnap 服务器上执行多个 SQL 语句。

当我尝试解决一个众所周知的问题时，我的问题发生在我的存储过程中留下了一行调试代码，该问题阻止您在调用 TSQLStoredProc.Open (http://qc.embarcadero.com/wc/qcmain.aspx?d=90211) 后访问 output 参数。

所以即使我的问题解决了，原来的问题仍然存在——你不能调用Open方法来拉数据然后访问output参数，你不能访问多个数据集从单个存储过程返回。

再次感谢 Gunny 的建议。

原帖

我试图在一个请求中从 DataSnap 服务器返回两个不同的数据集。两者都来自同一个数据库。一个是单字段/单记录值，另一个是多字段/多记录数据集。

DataSnap服务器有以下方法：

function TDSSvrMethods.GetData(const SQL: string; var Params: OleVariant; var Key: string): OleVariant;
var qry: TSQLQuery; cds: TClientDataSet;
begin
  // create TSQLQuery & TClientDataSet
  // Link the two components via cds.SetProvider(qry);
  // run first query, set 'Key' to the result <-- this works
  qry.Close;
  // run second query <-- I see this hit the database
  // return dataset via 'Result := cds.Data;'
  // destory TSQLQuery & TClientDataSet
end;

这不起作用。即使我可以看到两个单独的请求都命中了数据库，但我无法访问第二个结果集。当我尝试时，（再次）返回第一个结果集而不是第二个结果集。

在我创建/销毁查询组件（每个客户端到服务器请求）之前，所有后续客户端到服务器请求都将返回第一个数据集。非常令人沮丧。创建/销毁查询组件解决了这个问题，但现在我在一个客户端执行多个查询到服务器请求，问题又回来了——即使执行了新查询，也会返回第一个数据集。

我尝试了几种方法：

ONE：为第一个请求动态创建TSQLQuery组件，拉取db值，销毁TSQLQuery，创建一个新的TSQLQuery并拉取第二个数据集。那没有帮助。我可以使用 SQL Server Profiler 并观察两个命令都命中数据库，但第一个结果集显示为两个查询的数据集。

TWO：与 #1 一样，但使用 TSQLStoredProcedure 而不是 TSQLQuery。结果是一样的。

三个：使用 TSQLStoredProcedure 并从同一个存储过程中返回两个数据集，如下所示：

create procedure sp_test_two_datasets
as
  select 'dataset1' as [firstdataset]
  select * from sometable -- 2nd dataset
go

由于TSQLStoredProcedure 有NextRecordSet，我曾希望访问这两个数据集，但不高兴。当我调用NextRecordSet 时，它返回nil。

FOUR：使用数据集和output 参数一次调用TSQLStoredProcedure 返回两个值：

create procedure sp_another_test
  @singlevalue varchar(255) output
as
  select * from sometable
go

Delphi 代码如下所示：

var sp: TSQLStoredProc; cds: TClientDataSet;
...
cds.SetProvider(sp);
...
sp.CommandText := 'sp_another_test :value output';
sp.Params.ParamByName('value').Value := Key; // in/out method parameter from above
sp.Open;
Key := sp.Params.ParamByName('value').Value; // single string value
Result := cds.Data; // dataset
...

我检查 sp.Params 并且有一个名为 value 的输入/输出参数。当还返回数据集时，我无法访问 output 参数。这是一个已知的错误（多年以来）：http://qc.embarcadero.com/wc/qcmain.aspx?d=90211

结论：

由于 DataSnap 服务器与所有连接的客户端共享其主要的 TSQLConnection，并且因为 TSQLQuery（或 TSQLStoredProc）和 TClientDataSet 组件都是随每个请求创建/释放的，所以只剩下可以保留先前数据集并将其返回到TSQLQuery 和TSQLStoredProc 组件的是TSQLConnection 组件。我尝试在关闭和释放TSQLQuery（或TStoredProc）组件之前调用TSQLConnection.CloseDataSets，但这也无济于事。

也许仔细查看TSQLConnection 会有所帮助。这是它在.dfm 文件中的样子：

object sqlcon: TSQLConnection
  DriverName = 'MSSQL'
  GetDriverFunc = 'getSQLDriverMSSQL'
  LibraryName = 'dbxmss.dll'
  LoginPrompt = False
  Params.Strings = (
    'SchemaOverride=%.dbo'
    'DriverUnit=DBXMSSQL'

      'DriverPackageLoader=TDBXDynalinkDriverLoader,DBXCommonDriver150.' +
      'bpl'

      'DriverAssemblyLoader=Borland.Data.TDBXDynalinkDriverLoader,Borla' +
      'nd.Data.DbxCommonDriver,Version=15.0.0.0,Culture=neutral,PublicK' +
      'eyToken=91d62ebb5b0d1b1b'

      'MetaDataPackageLoader=TDBXMsSqlMetaDataCommandFactory,DbxMSSQLDr' +
      'iver150.bpl'

      'MetaDataAssemblyLoader=Borland.Data.TDBXMsSqlMetaDataCommandFact' +
      'ory,Borland.Data.DbxMSSQLDriver,Version=15.0.0.0,Culture=neutral' +
      ',PublicKeyToken=91d62ebb5b0d1b1b'
    'GetDriverFunc=getSQLDriverMSSQL'
    'LibraryName=dbxmss.dll'
    'VendorLib=sqlncli10.dll'
    'HostName=localhost'
    'Database=Database Name'
    'MaxBlobSize=-1'
    'LocaleCode=0000'
    'IsolationLevel=ReadCommitted'
    'OSAuthentication=False'
    'PrepareSQL=True'
    'User_Name=user'
    'Password=password'
    'BlobSize=-1'
    'ErrorResourceFile='
    'OS Authentication=False'
    'Prepare SQL=False')
  VendorLib = 'sqlncli10.dll'
  Left = 352
  Top = 120
end

在运行时，我做了一些事情，这样我就不必为 DBX 驱动程序部署 .INI 文件。首先，让我注册自己的无 INI 驱动程序的单元：

unit DBXRegDB;

interface

implementation

uses
  DBXCommon, DBXDynalinkNative;

type
  TDBXInternalDriver = class(TDBXDynalinkDriverNative)
  public
    constructor Create(DriverDef: TDBXDriverDef); override;
  end;

  TDBXInternalProperties = class(TDBXProperties)
  private
  public
    constructor Create(DBXContext: TDBXContext); override;
  end;

{ TDBXInternalDriver }

constructor TDBXInternalDriver.Create(DriverDef: TDBXDriverDef);
begin
  inherited Create(DriverDef, TDBXDynalinkDriverLoader);
  InitDriverProperties(TDBXInternalProperties.Create(DriverDef.FDBXContext));
end;

{ TDBXInternalProperties }

constructor TDBXInternalProperties.Create(DBXContext: TDBXContext);
begin
  inherited Create(DBXContext);

  Values[TDBXPropertyNames.SchemaOverride]         :=       '%.dbo';
  Values[TDBXPropertyNames.DriverUnit]             :=       'DBXMSSQL';
  Values[TDBXPropertyNames.DriverPackageLoader]    :=       'TDBXDynalinkDriverLoader,DBXCommonDriver150.bpl';
  Values[TDBXPropertyNames.DriverAssemblyLoader]   :=       'Borland.Data.TDBXDynalinkDriverLoader,Borland.Data.DbxCommonDriver,Version=15.0.0.0,Culture=neutral,PublicKeyToken=91d62ebb5b0d1b1b';
  Values[TDBXPropertyNames.MetaDataPackageLoader]  :=       'TDBXMsSqlMetaDataCommandFactory,DbxMSSQLDriver150.bpl';
  Values[TDBXPropertyNames.MetaDataAssemblyLoader] :=       'Borland.Data.TDBXMsSqlMetaDataCommandFactory,Borland.Data.DbxMSSQLDriver,Version=15.0.0.0,Culture=neutral,PublicKeyToken=91d62ebb5b0d1b1b';
  Values[TDBXPropertyNames.GetDriverFunc]          :=       'getSQLDriverMSSQL';
  Values[TDBXPropertyNames.LibraryName]            :=       'dbxmss.dll';
  Values[TDBXPropertyNames.VendorLib]              :=       'sqlncli10.dll';
  Values[TDBXPropertyNames.HostName]               :=       'ServerName';
  Values[TDBXPropertyNames.Database]               :=       'Database Name';
  Values[TDBXPropertyNames.MaxBlobSize]            :=       '-1';
  Values['LocaleCode']                             :=       '0000';
  Values[TDBXPropertyNames.IsolationLevel]         :=       'ReadCommitted';
  Values['OSAuthentication']                       :=       'False';
  Values['PrepareSQL']                             :=       'True';
  Values[TDBXPropertyNames.UserName]               :=       'user';
  Values[TDBXPropertyNames.Password]               :=       'password';
  Values['BlobSize']                               :=       '-1';
  Values[TDBXPropertyNames.ErrorResourceFile]      :=       '';
  Values['OS Authentication']                      :=       'False';
  Values['Prepare SQL']                            :=       'True';
  Values[TDBXPropertyNames.ConnectTimeout]         :=       '30';

  // Not adding connection pooling to the default driver parameters
end;

var
  InternalConnectionFactory: TDBXMemoryConnectionFactory;

initialization
  TDBXDriverRegistry.RegisterDriverClass('MSSQL_NoINI', TDBXInternalDriver);
  InternalConnectionFactory := TDBXMemoryConnectionFactory.Create;
  InternalConnectionFactory.Open;
  TDBXConnectionFactory.SetConnectionFactory(InternalConnectionFactory);

end.

上述方法包含在项目（.dpr 文件）中，并自行注册驱动程序。下一个方法利用它在运行时（DataSnap 服务器启动时）设置TSQLConnection (sqlcon)：

procedure SetupConnection(const hostname, port, dbname, username, password, maxcon: string);
begin
  if sqlcon.Connected then
    Exit;

  // Our custom driver -- does not use DBXDrivers.ini
  sqlcon.Params.Clear;
  sqlcon.DriverName := 'MSSQL_NoINI';
  sqlcon.VendorLib := sqlcon.Params.Values[TDBXPropertyNames.VendorLib];
  sqlcon.LibraryName := sqlcon.Params.Values[TDBXPropertyNames.LibraryName];
  sqlcon.GetDriverFunc := sqlcon.Params.Values[TDBXPropertyNames.GetDriverFunc];

  sqlcon.Params.Values[TDBXPropertyNames.HostName]           := hostname;
  sqlcon.Params.Values[TDBXPropertyNames.Port]               := port;
  sqlcon.Params.Values[TDBXPropertyNames.Database]           := dbname;
  sqlcon.Params.Values[TDBXPropertyNames.UserName]           := username;
  sqlcon.Params.Values[TDBXPropertyNames.Password]           := password;
  sqlcon.Params.Values[TDBXPropertyNames.DelegateConnection] := DBXPool.sDriverName;
  sqlcon.Params.Values[DBXPool.sDriverName + '.' + TDBXPoolPropertyNames.MaxConnections]    := maxcon;
  sqlcon.Params.Values[DBXPool.sDriverName + '.' + TDBXPoolPropertyNames.MinConnections]    := '1';
  sqlcon.Params.Values[DBXPool.sDriverName + '.' + TDBXPoolPropertyNames.ConnectTimeout]    := '1000';
  sqlcon.Params.Values[DBXPool.sDriverName + '.' + 'DriverUnit']                            := DBXPool.sDriverName;
  sqlcon.Params.Values[DBXPool.sDriverName + '.' + 'DelegateDriver']                        := 'True';
  sqlcon.Params.Values[DBXPool.sDriverName + '.' + 'DriverName']                            := DBXPool.sDriverName;
end;

这些设置是否可能会弄乱TSQLConnection 组件并使其缓存数据集并返回它们而不是最新的TSQLQuery 组件执行的那个？

任何帮助将不胜感激。如您所知，这让我发疯了！

谢谢，詹姆斯

【问题讨论】：

我已经好几年没用过Delphi了，但怀疑问题出在CD上。如果你混合两个语句的顺序，你总是得到第一个语句的结果吗？是否有可以在查询之间调用的显式 cds.clear 方法？
好问题... 结果是，在尝试解决其他现有的 Embarcadero 错误时，我引入了自己的错误，这导致它看起来像是在缓存第一个结果集。感谢您抽出宝贵时间回复。
很高兴您找到了解决方案。在中断了 7-8 年之后，我最近才拿起了 Delphi。我从 D5E 转到 D2010 Pro。我得到了 Marco Cantu 的所有书籍，所以我对每个版本的变化都有一个审计跟踪，但过程很艰难。 SO 是个闲逛的好地方。
XE2 即将发布（最新版本的 Delphi）。它拥有 64 位编译器、Windows 和 Mac 上的交叉编译以及手持设备工具。从 D5 升级到 D2009 最困难的部分是 Unicode。我不得不隐藏我所有的旧代码，这花了很长时间。
请注意QualityCentral has now been shut down，因此您无法再访问qc.embarcadero.com 链接。如果您需要访问旧的 QC 数据，请查看 QCScraper。

标签： delphi dataset sqlconnection datasnap

【解决方案1】：

如果你也关闭 CDS 会发生什么？

function TDSSvrMethods.GetData(const SQL: string; var Params: OleVariant; var Key: string): OleVariant; 
var qry: TSQLQuery; cds: TClientDataSet; 
begin 
  // create TSQLQuery & TClientDataSet
  // Link the two components via cds.SetProvider(qry);
  // run first query, set 'Key' to the result <-- this works
  qry.Close;
  cds.Close;
  // run second query <-- I see this hit the database
  cds.Open
  // return dataset via 'Result := cds.Data;'
  // destory TSQLQuery & TClientDataSet end;

【讨论】：

我试过了，但没有帮助。然而，它确实让我仔细检查了一切，我发现了问题。我会将其发布为答案。谢谢，为您的帮助 +1。

【解决方案2】：

如前所述，在尝试解决两个 DBX 框架错误时，我引入了一个错误，它使 TSQLConnection 看起来像是在为后续数据请求交回先前的数据集。一旦我修复了我的错误，我只需要解决两个 DBX 框架错误（因为我们不能自己修复/重新编译框架）：

ONE：您不能调用Open 方法并访问output 参数。

两个：您无法访问从单个存储过程返回的多个数据集。

解决方法：我只需执行两个从 DataSnap 服务器到数据库的查询，然后处理/打包各个数据集以发送回客户端（在一个响应中）。

2012-06-27 评论

由于该线程有多个视图，我想我应该解释一下如何将多个数据集打包到来自 DataSnap 服务器的单个响应中。

DataSnap 可以将OleVariant 返回到客户端应用程序。很容易创建一个OleVariant，它是一个OleVariant 的数组。由于TClientDataSet.Data 属性是OleVariant，我们可以创建一个数据集数组以传回客户端。此示例返回 5 个数据集。假设 DataSnap 服务器中存在这些方法：

function TServerMethods1.GetData(SQL: string): OleVariant;
var cds: TClientDataSet;
begin
  cds := TClientDataSet.Create(nil);
  try

    { setup 'cds' to connect to database }
    { pull data }

    Result := cds.Data;
  finally
    FreeAndNil(cds);
  end;
end;

function TServerMethods1.GetMultipleDataSets: OleVariant;
begin
  Result := VarArrayCreate([0, 4], varVariant);
  Result[0] := GetData('select * from Table1');
  Result[1] := GetData('select * from Table2');
  Result[2] := GetData('select * from Table3');
  Result[3] := GetData('select * from Table4');
  Result[4] := GetData('select * from Table5');
end;

您可以通过在表单上放置 5 个TClientDataSet 组件并将它们的Data 属性分配给来自OleVariant 的元素来在客户端分配数据。

procedure X;
var DataArray: OleVariant;
begin
  try
    with ProxyMethods.TServerMethods1.Create(SQLConnection1.DBXConnection, True) do
    try
      DataArray := GetMultipleDataSets;
    finally
      Free;
    end;

    ClientDataSet1.Data := DataArray[0];
    ClientDataSet2.Data := DataArray[1];
    ClientDataSet3.Data := DataArray[2];
    ClientDataSet4.Data := DataArray[3];
    ClientDataSet5.Data := DataArray[4];
  finally
    VarClear(DataArray);
  end;
end;

（我在没有测试的情况下输入了这个示例。我的实际代码包括变量数组边界检查和其他动态元素。）

【讨论】：