如何使用Zeos数据库连接池

本篇内容主要讲解"如何使用Zeos数据库连接池"，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习"如何使用Zeos数据库连接池"吧!

unit ZeosConPool;interfaceuses  SysUtils, Windows, Classes, IniFiles, DB,  ZAbstractRODataset, ZDataset, ZAbstractConnection, ZConnection, ZCompatibility;type  TSQLConntionRecord = record    HostName: string;    Port: Integer;    UserName: string;    DBName: string;    MyDataBase: string;    Password: string;  end;  TSQLConnectionPool = class  private    fDataBase: string;    fServer: string;    fPort: integer;    fUserName: string;      // 数据库用户    fPassWord: string;      // 密码    FConList: TThreadList;  // 池容器    function TestConnection(con: TzConnection): boolean;    function CreateNewConnection: TZConnection;    function GetConnectionRecord: TSQLConntionRecord;  public        function Pop: TZConnection;    procedure Push(con: TZConnection);    constructor Create;    destructor Destroy; override;  end;  TQryPool = class  private    function GetQry: TZQuery;    procedure con(qry: TZQuery);    procedure discon(qry: TZQuery);  public    function Require: TZQuery;    procedure Return(qry: TZQuery);  end;  function GetQueryJsonData(sql: string): string;var  ConnectionPools: TSQLConnectionPool;  QryPools: TQryPool;implementationfunction _DataSetToJson(ADataset: TDataSet): string;// [{"CityId":"18","CityName":"西安"},{"CityId":"53","CityName":"广州"}]var  LRecord: string;  LField: TField;  i: integer;begin  Result := '';  if (not ADataset.Active) or (ADataset.IsEmpty) then Exit;  Result := '[';  ADataset.DisableControls;  ADataset.First;  while not ADataset.Eof do  begin    for i := 0 to ADataset.FieldCount - 1 do    begin      LField := ADataset.Fields[i]; // 取得当前字段      if LRecord = '' then        LRecord := '{"' + LField.FieldName + '":"' + LField.Text + '"'      else        LRecord := LRecord + ',"' + LField.FieldName + '":"' + LField.Text + '"';      if i = ADataset.FieldCount - 1 then      begin        LRecord := LRecord + '}';        if Result = '[' then          Result := Result + LRecord        else          Result := Result + ',' + LRecord;        LRecord := '';      end;    end;    ADataset.Next;  end;  ADataset.EnableControls;  Result := Result + ']';end;{ TSQLConnectionPool }constructor TSQLConnectionPool.Create;begin  FConList := TThreadList.Create;end;destructor TSQLConnectionPool.Destroy;var  i: Integer;begin  with FConList.LockList do    try      for i := Count - 1 downto 0 do      begin        TZConnection(Items[i]).Disconnect;        TZConnection(Items[i]).Free;      end;    finally      FConList.UnlockList;    end;  FConList.Free;end;//获取SQL连接对象function TSQLConnectionPool.CreateNewConnection: TZConnection;var  con: TZConnection;  RecCon: TSQLConntionRecord;begin  Result := nil;  try    con := TZConnection.Create(nil);    RecCon := GetConnectionRecord;    try      with con do      begin        Protocol := 'MySQL';                                 // 数据库驱动类型        LibraryLocation := 'libmysql.dll';        ClientCodepage := 'utf8';        LoginPrompt := False;        HostName := RecCon.HostName;        User := RecCon.UserName;        Password := RecCon.Password;        Database := RecCon.DBName;        Port := RecCon.Port;        Connect;      end;      Result := con;    except      on E: exception do      begin        Result := nil;        con.Free;        // 打印日志。。。。      end;    end;  except  end;end;//获取配置SQL连接参数function TSQLConnectionPool.GetConnectionRecord: TSQLConntionRecord;var  dbIni: TIniFile;begin  dbIni := TIniFile.Create(ExpandFileName(ExtractFilePath(ParamStr(0)) +    '\DataBase.ini'));  try    with Result do    begin      HostName := dbIni.ReadString('Database', 'Host', '127.0.0.1');      Port := dbIni.ReadInteger('Database', 'Port', 3306);      UserName := dbIni.ReadString('Database', 'UID', 'root');      DBName := dbIni.ReadString('Database', 'Database', 'klys');      MyDataBase := UpperCase(dbIni.ReadString('Database', 'DataBaseType', 'MySql'));      Password := dbIni.ReadString('Database', 'Password', '1234567');          end;  finally    dbIni.Free;  end;end;//弹出SQL连接对象function TSQLConnectionPool.Pop: TZConnection;begin  with FConList.LockList do    try      if Count > 0 then      begin        Result := TZConnection(Items[Count-1]);             Delete(Count-1);           {        if not TestConnection(Result) then        begin          Result.Free;          Result := Pop; // 递归        end;        }      end      else      begin        Result := CreateNewConnection;      end    finally      FConList.UnlockList;    end;end;//回收SQL连接对象procedure TSQLConnectionPool.Push(con: TZConnection);begin  if con <> nil then    with FConList.LockList do      try        // Insert(0, con);        Add(con);      finally        FConList.UnlockList;      end;end;//测试连接池中的SQL对象是否存活function TSQLConnectionPool.TestConnection(con: TZConnection): boolean;begin  Result := false;  try    // con.ExecuteDirect('delete from zd_user where 1<>1');    Result := true;  except    on E: exception do    begin      // 实际应用，一定要打印日志    end;  end;end;{ TQryPool }//qry 关联SQL Connectionprocedure TQryPool.con(qry: TZQuery);var  sqlcon: TZConnection;begin  sqlcon := ConnectionPools.Pop;  qry.Connection := sqlcon;end;//回收SQL Connetion 对象procedure TQryPool.discon(qry: TZQuery);begin  ConnectionPools.Push(TZConnection(qry.Connection));end;//获取对象function TQryPool.GetQry: TZQuery;var  qry: TZQuery;begin  qry := TZQuery.Create(nil);  con(qry);  Result := qry;end;//弹出Qry对象function TQryPool.Require: TZQuery;begin  Result := GetQry;end;//获取Qry对象procedure TQryPool.Return(qry: TZQuery);begin  if qry <> nil then  begin    qry.Close;    ConnectionPools.Push(TZConnection(qry.Connection));    qry.Free;  end;end;function GetQueryJsonData(sql: string): string;var  qry: TZQuery;  uid: integer;  susername, spw: string;  str:String;begin  qry := QryPools.Require;  try    qry.SQL.Text := sql;    qry.Open;    result := _DataSetToJson(qry);  finally    QryPools.Return(qry);  end;end;initializationConnectionPools := TSQLConnectionPool.Create();QryPools := TQryPool.Create;finalization  QryPools.Free;  ConnectionPools.Free;   end.

到此，相信大家对"如何使用Zeos数据库连接池"有了更深的了解，不妨来实际操作一番吧！这里是网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！