请问如何在线程中使用ClientDataSet???(200分)

请教如何在使用socketConnection连接服务端时，在线程中使用clientDataSet进行数据库查询？

请大侠举个例子，小弟刚接触线程，很多都不懂

在线程中动态建立

unit UQueryThread;
interface
uses
Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs,
dbclient,db,dbtables,dbgrids,ActiveX;
type
TQueryThread = class(TThread)
private
FCDS:TClientDataSet;
public
constructor Create(CDS1:TClientDataSet);
protected
procedure Execute;override;
end;

implementation
{ TQueryThread }

constructor TQueryThread.Create(CDS1:TClientDataSet);
begin
inherited Create(False);
FreeOnTerminate:=True;
FCDS:=TClientDataSet.Create(application);
FCDS.CommandText:='select * from jinduxinxiView';
FCDS.RemoteServer:=CDS1.RemoteServer;
FCDS.ProviderName:=CDS1.ProviderName;
end;

procedure TQueryThread.Execute;
begin
//CoInitialize(nil);
try
FCDS.Open;
finally
//CoUninitialize;
end;
end;

end.

我是这样做的，但总是在open时提示“Variant is not a array”

注意 Synchronize 的使用
Delphi中实现多线程同步查询
（加入日期:2001-6-13 点击数:1300）
电信机房P4服务器·6999/年·送产权蓝芒系统
【对此文发表评论】 【编程爱好者论坛】 【保存文章至硬盘】 【打印文章】

优秀的数据库应用应当充分考虑数据库访问的速度问题。通常可以通过优化数据库、优化 查询语句、分页查询等途径收到明显的效果。即使是这样，也不可避免地会在查询时闪现一个带有 SQL符号的沙漏，即鼠标变成了查询等待。最可怜的是用户，他（她）在此时只能无奈地等待。遇到急性子的，干脆在此时尝试 Windows中的其它应用程序，结果致使你的数据库应用显示一大片白色的窗口。真是无奈！
本文将以简单的例子告诉你如何实现线程查询。还等什么，赶快打开Delphi对照着下面的完整源代码试试吧。 在查询时能够做别的事情或者取消查询，这只是基本的线程查询，在你阅读了Delphi有关线程帮助之后能立刻实现。这里介绍的是多个线程查询的同步进行。
在Delphi数据库应用中，都有一个缺省的数据库会话 Session。通常情况下，每个数据库应用中只有这一个会话。无论是查询函数修改数据，在同一时间内只能进行其中的一件事情， 而且进行这一件事情的时候应用程序不能响应键盘、鼠标以及其它的 Windows消息。这就是在 窗口区域会显示一片空白的原因所在。当然，只要将查询或数据操纵构造成线程对象，情况会好一些，至少可以接受窗口消息，也可以随时终止查询或数据操纵，而不会在屏幕上显示出太难看的白色。不过，这只是解决了问题的一部分。假如在进行一个线程查询的时候，用户通过 按钮或菜单又发出了另一个查询的命令，这可如何是好，难道终止正在执行的数据库访问吗？ 解决之道就是：多线程同步查询。
实现多线程同步查询的基本思想是，为每一个查询组件（如TQuery组件）创建一个独占的 数据库会话，然后各自进行数据库访问。需要特别注意的是，因为Delphi中的 VCL组件大多都 不是线程安全的，所以应当在线程查询结束后再将DataSource组件与查询组件关联，从而显示 在DBGrid组件中。
下面的例子只实现了静态的线程同步查询，即线程对象是固定的，并随窗体的创建和销毁 而创建和销毁。你可以就此进行改进，为每一个数据查询或数据操纵命令创建一个单独的线程对象，从而达到多线程同步查询的目的。
注意：应用程序中的线程不是越多越好，因为线程将严重吞噬CPU资源，尽管看上去并不明显。谨慎创建和销毁线程将避免你的应用程序导致系统资源崩溃。
下面的例子给出了同时进行的两个线程查询。第一次按下按钮时，线程开始执行；以后每次按下按钮时，如果线程处于挂起状态则继续执行，否则挂起线程；线程执行完毕之后将连接 DataSource，查询结果将显示在相应的DBGrid中。
{ 这里的多线程同步查询演示程序仅包括一个工程文件和一个单元文件 }
{ 窗体中放置的组件有： }
{ 两个Session组件 }
{ 两个Database组件 }
{ 两个Query组件 }
{ 两个DataSource组件 }
{ 两个DBGrid组件 }
{ 一个Button组件 }
{ 除非特别说明，否则上述各组件的属性都取默认值（见各组件注释） }
{ 对于Database组件，就和一般设置一样，有一个正确的连接即可 }
{ 对于Query 组件，需要在各自的属性 SQL中添加一些查询语句，为了 }
{ 看得更清除，建议不要在两个Query 组件中填写相同的查询语句。 }
unit Unit1;

interface
uses
Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs,
Db, DBTables, Grids, DBGrids, StdCtrls;

type
TForm1 = class(TForm)
Session1: TSession;
{ 属性SessionName填写为S1 }
Database1: TDatabase;
{ 属性SessionName选择为S1 }
Query1: TQuery;{ 属性Database选择为Database1；属性SessionName选择为S1 }
DataSource1: TDataSource;
{ 属性DataSet设置为空 }
DBGrid1: TDBGrid;
{ 属性DataSource选择为DataSource1 }
Session2: TSession;
{ 属性SessionName填写为S2 }
Database2: TDatabase;
{ 属性SessionName选择为S2 }
Query2: TQuery;{ 属性Database选择为Database2；属性SessionName选择为S2 }
DataSource2: TDataSource;
{ 属性DataSet设置为空 }
DBGrid2: TDBGrid;
{ 属性DataSource选择为DataSource2 }
BtnGoPause: TButton;
{ 用于执行和挂起线程 }
procedure FormCreate(Sender: TObject);
{ 创建窗体时创建线程对象 }
procedure FormDestroy(Sender: TObject);
{ 销毁窗体时销毁线程对象 }
procedure BtnGoPauseClick(Sender: TObject);
{ 执行线程和挂起线程 }
private
public
end;

TThreadQuery = class(TThread) { 声明线程类 }
private
FQuery: TQuery;
{ 线程中的查询组件 }
FDataSource: TDataSource;
{ 与查询组件相关的数据感知组件 }
procedure ConnectDataSource;{ 连接数据查询组件和数据感知组件的方法 }
protected
procedure Execute;
override;{ 执行线程的方法 }
public
constructor Create(Query: TQuery;
DataSource: TDataSource);
virtual;
{ 线程构造器 }
end;

var
Form1: TForm1;
Q1, { 线程查询对象1 }
Q2: TThreadQuery;
{ 线程查询对象2 }
implementation
{$R *.DFM}
{ TThreadQuery类的实现 }
{ 连接数据查询组件和数据感知组件}
procedure TThreadQuery.ConnectDataSource;
begin

FDataSource.DataSet := FQuery;{ 该方法在查询结束后才调用 }
end;

procedure TThreadQuery.Execute;{ 执行线程的方法 }
begin

try
FQuery.Open;
{ 打开查询 }
Synchronize(ConnectDataSource);{ 线程同步 }
except
ShowMessage('Query Error');
{ 线程异常 }
end;

end;

{ 线程查询类的构造器 }
constructor TThreadQuery.Create(Query: TQuery;
DataSource: TDataSource);
begin

FQuery := Query;
FDataSource := DataSource;
inherited Create(True);
FreeOnTerminate := False;
end;

{ 创建窗体时创建线程查询对象 }
procedure TForm1.FormCreate(Sender: TObject);
begin

Q1 := TThreadQuery.Create(Query1, DataSource1);
Q2 := TThreadQuery.Create(Query2, DataSource2);
end;

{ 销毁窗体时销毁线程查询对象 }
procedure TForm1.FormDestroy(Sender: TObject);
begin

Q1.Terminate;
{ 销毁之前终止线程执行 }
Q1.Destroy;
Q2.Terminate;
{ 销毁之前终止线程执行 }
Q2.Destroy;
end;

{ 开始线程、继续执行线程、挂起线程 }
procedure TForm1.BtnGoPauseClick(Sender: TObject);
begin

if Q1.Suspended then
Q1.Resume else
Q1.Suspend;

if Q2.Suspended then
Q2.Resume else
Q2.Suspend;

end;

end.

现在我在线程中把SockectConnect也创建了，可以完成FCDS的open过程了，但问题是我怎样把FCDS的数据发给原cds1呢？
unit UQueryThread;
interface
uses
Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs,
dbclient,db,dbtables,dbgrids,ActiveX, SConnect;
type
TQueryThread = class(TThread)
private
FCDS:TClientDataSet;
Fsoc: TSocketConnection;
public
Running:boolean;
constructor Create(CDS1:TClientDataSet;soc: TSocketConnection);
protected
procedure Execute;override;
end;

implementation
{ TQueryThread }
uses
Unit1;

constructor TQueryThread.Create(CDS1:TClientDataSet;soc: TSocketConnection);
begin
Running:=true;
FreeOnTerminate:=True;
Fsoc:=TSocketConnection.Create(application);
FSoc.Address:='192.168.168.8';
FSoc.Port:=211;
FSoc.ServerName:=soc.ServerName;
Fsoc.ServerGUID:=soc.ServerGUID;
FCDS:=TClientDataSet.Create(application);
FCDS.CommandText:='select * from jinduxinxiView';
FCDS.RemoteServer:=Fsoc;
FCDS.ProviderName:=CDS1.ProviderName;
inherited Create(False);
end;

procedure TQueryThread.Execute;
begin
//CoInitialize(nil);
try
Fsoc.Connected:=true;
FCDS.Open;
Running:=false;
finally
//CoUninitialize;
end;
end;

end.

其实没必要创建新的Connection
请参看
http://www.delphibbs.com/delphibbs/dispq.asp?lid=2280814
要把接口指针先传递到线程中才能够使用。
使用IAppserver的接口取数据是没有问题，但是我搞不出来如何用在中间层定义的接口取数据。

请教kkkchenA
你说的那个实例中有一句
FNewData :=
AppServer.AS_GetRecords (FCDS.ProviderName,
-1,RecsOut,MetaDataOption,'',Params,OwnerData);
中MetaDataOption是怎么来的？调试提示这个变量无效

谢谢各位的帮忙，这个问题总算搞定了

多人接受答案了。