DataSnap資料庫連接配接池，資料集對象池的應用

    傳統的應用伺服器的開發往往是在ServerMethods單元中拖放一堆TDataSet, TDaTaSetProvider控件，這是一個最簡單粗暴的開發方向，往往會造成服務端程式檔案的臃腫、服務運作期間記憶體資源消耗過大的問題。是以這種往應用伺服器中拖放一堆TDataSet, TDaTaSetProvider控件的做法，非常的笨拙。

    當然了，如果我們的系統采用的是以短連接配接的方式的話，那就可以每次直接TDataSet.Create(nil);然後Free;但是這種方法對伺服器的開銷很大，因為每執行一個服務都需要重複開辟記憶體空間，銷毀記憶體空間等。

    為此，我們可以通過使用對象池方法來改進之。

unit DSServerContainer;

interface

uses
  SysUtils, Classes,
  DSTCPServerTransport,
  DSServer, DSCommonServer, DSAuth, DB, ADODB, Generics.Collections, DSService,
  DBXDataSnap, DBXCommon, DSHTTPLayer, DBXinterbase, Forms;

type
  TServerContainer1 = class(TDataModule)
    DSServer1: TDSServer;
    DSTCPServerTransport1: TDSTCPServerTransport;
    DSServerClass1: TDSServerClass;
    procedure DSServerClass1GetClass(DSServerClass: TDSServerClass;
      var PersistentClass: TPersistentClass);
    procedure DataModuleCreate(Sender: TObject);
    procedure DSServer1Disconnect(DSConnectEventObject: TDSConnectEventObject);
  private
    { Private declarations }
    ListofConnection : TDictionary<Integer,TadoConnection>;
  public
    function getConnection : TAdoConnection;
  end;

var
  ServerContainer1: TServerContainer1;

implementation

uses Windows, ServerMethodsUnit1,uConst;

{$R *.dfm}

procedure TServerContainer1.DataModuleCreate(Sender: TObject);
begin
  ListofConnection := TDictionary<Integer, TadoConnection>.Create;
end;

procedure TServerContainer1.DSServer1Disconnect(
  DSConnectEventObject: TDSConnectEventObject);
begin
  if getConnection <> nil then
     getConnection.Close;
end;

procedure TServerContainer1.DSServerClass1GetClass(
  DSServerClass: TDSServerClass; var PersistentClass: TPersistentClass);
begin
  PersistentClass := ServerMethodsUnit1.TServerMethods1;
end;

function TServerContainer1.getConnection: TAdoConnection;
var
  dbconn : TAdoConnection;
begin
  if ListofConnection.ContainsKey(TDSSessionManager.GetThreadSession.Id) then
     Result := ListofConnection[TDSSessionManager.GetThreadSession.Id]
  else
  begin
    if ListofConnection.Count <= g_MaxPoolSize then
    begin
      dbconn := TadoConnection.Create(Self);
      dbconn.Name := 'con'+ IntToStr(TDSSessionManager.GetThreadSession.Id);
      dbconn.LoginPrompt := false;
      dbconn.ConnectionString := 'FILE NAME=' + extractfilepath(application.ExeName) + 'connect.udl';
      ListofConnection.Add(TDSSessionManager.GetThreadSession.Id, dbconn);
      Result := dbconn;
    end;
  end;
end;

end.      

unit ServerMethodsUnit1;

interface

uses
  SysUtils, Classes, DSServer, DB, Generics.Collections, DSService, Provider,
  ADODB;

type
  TServerMethods1 = class(TDSServerModule)
    procedure DSServerModuleCreate(Sender: TObject);
  private
    { Private declarations }
    ListofQuery : TDictionary<Integer,TAdoQuery>;
    ListofProvider : TDictionary<Integer,TDatasetProvider>;
    function _GetQuery(sql: string; exeNo: Integer) : TAdoquery;
    function _GetPrv(sql: string; exeNo: Integer) : TDatasetProvider;
  public
    { Public declarations }
    function GetProviderName(sql: string; exeNo: Integer): string;
  end;

implementation

{$R *.dfm}

uses StrUtils, DSServerContainer, uConst;

procedure TServerMethods1.DSServerModuleCreate(Sender: TObject);
begin
  Listofquery := TDictionary<Integer, Tadoquery>.Create;
  Listofprovider := TDictionary<Integer, Tdatasetprovider>.Create;
end;

function TServerMethods1._GetPrv(sql: string; exeNo: Integer): TDatasetProvider;
var
  dbprv : Tdatasetprovider;
begin
  if ListofProvider.ContainsKey(exeNo) then
     Result := ListofProvider[exeNo]
  else
  begin
    if ListofProvider.Count <= g_MaxPoolSize then
    begin
      dbprv := TDataSetProvider.Create(Self);
      dbprv.Name := 'dsp'+ IntToStr(exeNo);
      dbprv.DataSet := _GetQuery(sql, exeNo);
      ListofProvider.Add(exeNo, dbprv);
      Result := dbprv;
    end;
  end;
end;

function TServerMethods1._GetQuery(sql: string; exeNo: Integer): TAdoQuery;
var
  qry : TADOQuery;
begin
  if Listofquery.ContainsKey(exeNo) then
     Result := ListofQuery[exeNo]
  else
  begin
    if ListofQuery.Count <= g_MaxPoolSize then
    begin
      qry := TADOQuery.Create(Self);
      with qry do
      begin
        Connection := ServerContainer1.getConnection;
        Name := 'qry'+ IntToStr(exeNo);
        close;
        sql.Clear;
        sql.Text := sql;
        open;
      end;
      ListofQuery.Add(exeNo, qry);
      Result := qry;
    end;
  end;
end;

function TServerMethods1.GetProviderName(sql: string; exeNo: Integer): string;
begin
  Result := _GetPrv(sql, exeNo).Name;
end;

end.