本篇内容主要讲解“如何使用Zeos数据库连接池”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“如何使用Zeos数据库连接池”吧!
创新互联公司是专业的资源网站建设公司，资源接单;提供网站制作、做网站,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行资源网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!
unit ZeosConPool;
interface
uses
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;
implementation
function _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 Connection
procedure 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;
initialization
ConnectionPools := TSQLConnectionPool.Create();
QryPools := TQryPool.Create;
finalization
QryPools.Free;
ConnectionPools.Free;
end.到此，相信大家对“如何使用Zeos数据库连接池”有了更深的了解，不妨来实际操作一番吧！这里是创新互联网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！