多层数据库开发实例--九种多层数据库开发例子

分布式多层数据库开发 第一节 分布式多层数据库开发简介 第二节 服务器端程序 服务器端程序实际上是个COM 工程，它本身连接数据源，再通过接口与 客户端联系，这个COM 工程必须注册在服务器上。 首先建立一个空白的工程。 file -> New -> Other -> Multitier -> Remote Data Module(远程数据模块) 对话框： Coclass Name : COM程序的名称，前台依据这个名字查找COM程序 （Project121） Instancing :执行模式，大部分用Multiple Instance（多重实例） Threading Model：线程模式，建议用Apartment（单元） 下面我们就会对这几个选择详加说明。 OK，产生一个窗口，在这个窗口里，可以放入数据控件。 在Viwe -> Type Libray 中，我们可以看到这个COM 的一些特性。我们 也可以记下系统提供的GUID，以备后来使用。 加入一个ADOTable，并设置其指向一个数据库。 再设置一个DataSetProvider指向ADOTable 这就完成了服务器端的程序设计。 保存，编译，注册。 这里需要做几个说明： 1） 在客户端，数据控件一般要和Datasource相连，但在服务器端，主 要要考虑数据和接口相连，Delphi 5.0以上版本规定，使用DataSetProvider 就不需要再针对每个控件做Export（导出）操作，而是由应用程序服务器自 动帮前台查找这就简化了程序和维护量。但是，前台每个DataSet 必须有个 对应的DataSetProvider 才行。 2）关于建立COM 是的几个选项现在说明一下： A) Instancing : Multiple Instance: 一个应用程序可以被多个前台程序调用使 用，启动和执行的效率比较高，不耗费服务器太多的 资源，管理上也比较方便。 Single Instance: 一个应用程序只能被一个前台程序调用，由 于没有排队问题，所以当某个查询崩溃时，不会影响 其它的查询，但是，一个前台调用必然在服务器上建 立一个应用程序服务器的Process （进程），占用资 源比较多，影响服务器整体执行效率。 Internal： 建立一个In-Process的COM 程序（也就是DLL文件 的格式），由于Mult-Tier 结构中，应用程序服务器 和前台程序是放在不同的地方的，两台机器的两个程 序就无法共享同一个Process，所以很少设置成Internal 模式的。 B) Threading Model: Apartment: 每个实例一次只能处理一个前台发出的Request（请 求），如果同时建立多个In-Process COM 程序，那每 个COM 程序就会有一个现程服务，所以数据是安全的， 当然要注意某些共享变量的冲突。 Single: 单线程，循环工作，不会出现多任务的问题。 Free : 可以让Remote Data Module自己处理多线程问题，客 户端程序需要用多线程方法来处理。 Both : 和Free几乎相同，但对应前台界面的Callback都是连 续的。 如果注册后无法确认是否注册成功，可以用C:\WINNT\Regedit.exe检查。 第三节 客户端程序 在Two-Tier模式中，客户端(Client)程序是直接和服务器的数据源相连的， 而Multi-Tier模式，多个客户端连接的是一个应用程序服务器，因为收费是按 客户端数计算的，所以，数据库的使用费用比较低。 下面的例子只提供了数据库操作的最基本的功能，主要说明数据源的连接 方法。 1）建立一个普通的工程。 2）放置一个TDCOMConnrction控件（在Datasnap页），属性： ComputerName：服务器名（自动给出网上邻居） ServerName:应用程序服务器注册名（project121.Test121server） 必要时ServerGUID输入GUID值。 Connected=true 为激活 说明：在调试的时候，如果是在Windows 2000本机的情况，可以先运行 project121.exe，然后就可以在ServerName中找到project121.Test121server 了，然后Connected=true 激活。 3）放置一个TClientDataSet控件（在Data Access页），属性： Name:cdsCustomer（重新起名） RemoteServer: DCOMConnrction1 ProviderName: DataSetProvider1（服务器端将被激活） Active:true （激活后将能正常连接） 4）放置TDataSource，属性： Dataset:指向cdsCustomer。 其余犹如普通的数据库设计。注意到这里使用了TActionList控件，其中 写入和退出在Standard Action 内找不到，需要自己编写： procedure TForm1.ApplyUpdateExecute(Sender: TObject); begin cdsCustomer.ApplyUpdates(-1); ShowMessage('已经正确地写入数据库中!!'); end; procedure TForm1.CloseActionExecute(Sender: TObject); begin Close; end; 只要服务器端正确的注册，这个程序使用是没有问题的。 第四节 客户端实现SQL 查询 由于在客户端不存在TQuery控件，似乎客户服务器模式是无法做SQL 查询的。但是，Delphi很好的解决了这个问题。事实上，只要客户端连接上 服务端应用程序，客户端的TClientDataSet就包含了一个名字为Provider 的属性，对应到服务器端DataSetProvider的所有默认属性和方法，其中 DataSetProvider有一个Options属性，只要让其中的poAllowCommandText =true， 那么，DataSetProvider的poAllowCommandText就可以接受前台来 的SQL 命令，并传送给TQuery。 可以看出，真正传递数据的是DataSetProvider的接口，所以，用这个 接口搭建传递SQL 的桥梁是必需的。 客户端进行SQL 查询的方法是： ClientDataSet.Close; ClientDataSet.CommandText := 'SQL语句'; ClientDataSet.Open; 第五节 客户端查询服务器端的别名集 在SQL 查询以前，用户往往需要制定查询哪个数据库，所以需要把服 务器上BDE 数据库别名（Alias ）设置数据抓到前台程序来 具体做法是： 首先，在服务器端建立一个TSession和一个TDataBase Session1属性： SessionName=Session1_4 DataBase1属性： DataBaseName: 连接数据库名 SessionName: Session1_4 （SessionName值） TQurey 增加个属性 SessionName: Session1_4 这样就可以用Session对象来管理数据源的信息了。 为了传给客户端值 View -> Type Library 显示接口窗口。 右键 ITest125Server（具体根据设置名不同而不同） -> New -> 建立两个方法： GetDatabaseNames ，用以传下别名数据，其接口信息为： Return type :HRESULT Parameters name type modifier Param VARIANT* [out,retval] SetDatabaseName ， 用以接受客户机来的信息，其接口信息要求传入 三个信息。 Return type :HRESULT Parameters name type modifier DBName BSTR [in] ----传上来的别名 UserName BSTR [in] Password BSTR [in] 刷新（Refresh Implementation）以后，就产生两个函数 function TTest125Server.GetDatabaseNames: OleVariant; var I: Integer; DBNames: TStrings; begin // 建立一个字符串数组存放BDE所有的数据库别名数据。 DBNames := TStringList.Create; try // 利用Session控件取得当前BDE所有的数据库别名数据。 Session1.GetDatabaseNames(DBNames); /// 建立一个变量数组给函数返回变量Result。 Result := VarArrayCreate([0, DBNames.Count - 1], varOleStr); // 最后再把数据库别名数据指定给该变量数组。 for I := 0 to DBNames.Count - 1 do Result[I] := DBNames[I]; finally DBNames.Free; end; end; 上面的函数的关键除了取得BDE 数据库别名以外，还声明了一个变量数 组来存放数据库别名数据，所以用VarArrayCreate函数建立一个变量数组， 其中 参数1： 指定数组范围 参数2： 数组数据类型，由于别名要通过DCOM传给前台，数据类型必 须设成varOleStr 才有效。 第二个过程是客户机提供上来的联机数据。 procedure TTest125Server.SetDatabaseName(const DBName, UserName, Password: WideString); begin try // 把前台传来的数据库别名、用户上线名称、用户上线密码 // 等三项数据指定给TDatabase控件，并且执行联机的操作。 Database1.Close; Database1.AliasName := DBName; if (UserName<>'') and (Password<>'') then begin Database1.Params.Values['PASSWORD'] := Password; Database1.Params.Values['USER NAME'] := UserName; end; Database1.Open; except // 如果联机时发生错误，则产生一个exception给前台程序 // 前台程序将会利用到这个exception来判断是否要把输入上 // 线数据的窗口激活。 on E: EDBEngineError do raise Exception.Create('Password Required') ; end; end; 第六节 服务器端进行客户计数