ADO多线程

本人最近正在进行呼叫中心的座席端和服务器软件开发,座席端登录部分是进行提取主
机信息,然后使用SOCKET提交给远程服务器,服务器再在后台数据库中进行查找信息,进行
对比,看是否允许座席端主机登录,因为我的电脑中无法安装SQLSERVER,所以 ,后台数据
库暂时使用access小型数据库进行代替,到后期可以改为SQLSERVER数据库,,我在后台数据
库中使用了两个表,使用WORKMARK字段将其相关联,如果在第一个表中查找到信息以后马上
会进入第二个表中进行查找,如果第一个表中的信息符合,就返回个客户第二个表中的信息
,因为座席端主机有200多台,为了防止几台主机同时进行验证信息,引起冲突,我在服务器
端建立多线程,利用线程进行后台的查询,以及查找结果的回传,编写成功后进行测试,发
现当一个主机连接后可以测试成功,但是,当第二个或者以后的线程产生时,数据集在第一
个表中可以查到正确的信息,但是进入第二个表中时,会发现按照正确的查找条件进行查找
时,查到的信息都为NIL,而且经过跟踪,发现,其实ADO已经找到了正确的信息,而且已经
发送成功了,但是却无法接收到,当时我在论坛中发表了一个帖子寻求帮助,原贴内容:
http://expert.csdn.net/Expert/topic/1420/1420051.xml?temp=.3060114

有些朋友说可能ACCESS数据库不提供多线程访问,但是我听说很多的论坛中好像都使用
了ACCESS进行后台线程的查找的。翻看MSDN中关于COM的说明:发现我的线程中竟然缺少最重
要的两个函数过程

CoInitialize( nil );凡是访问com对象都应该使用。线程的关闭时应该使用CoUnInit
ialize;否则ADO肯定出错,我相信肯定有不少的朋友经历过这种问题的:

我的线程代码如下:

unit Unitquerythread;

interface

uses
windows,SysUtils,Classes, Dialogs,ADODB,db, NMMSG, ActiveX{必须要有};

type
QueryThread = class(TThread)
private
FComputerInfor,FIPaddressinfo: string; //传递的信息
FAdoQuery,FAdoQUserInfor:TadoQuery; //动态生成的表一,表2

Fadoconnection:Tadoconnection; //动态生成的连接
Fnmmsg,FNMretureMSG:TNMMSG;//用来发送返回信息的组件
filestream:tfilestream;
procedure ExtractInfor(TransInfo:string{自定义的从该提交信息中分离信息的过程});
procedure ShellexeQuery;
Destructor Destroy;

protected
procedure Execute; override;
public
constructor create(ComputerInfor:string;{传输来的计算机信息}
IPaddressinfo:string;{传输来的IP地址信息}
nmmsg,NMretureMSG:TNMMSG);
end;
var
ExtractDomainUser:string; //提取出来的域用户名
ExtractComputername:string;//提取出来的计算机名称
ExtractDomainname:string;//提取出来的域名
strlist:Tstringlist;
IPlist:Tstringlist;//保存查找到的本工作组的ip地址信息
const defeat=‘defeat‘; //验证失败,必须注销客户机,在数据库中重新进行写入

implementation

uses Unitsendthread;

constructor QueryThread.create(ComputerInfor, IPaddressinfo: string;
nmmsg,NMretureMSG:TNMMSG);
begin
CoInitialize( nil );//使用com对象必须要初始化
inherited create(false);
FreeOnTerminate:=true;
FComputerInfor:=ComputerInfor;
FIPaddressinfo:=IPaddressinfo;
IPlist:=Tstringlist.create;//创造ip列表
FAdoQuery:=TAdoQuery.Create(nil); //动态生成表一
FAdoQUserInfor:=TadoQuery.Create(nil);//动态生成表2
Fadoconnection:=Tadoconnection.Create(nil);//动态生成的连接
Fadoconnection.LoginPrompt :=false;
Fadoconnection.KeepConnection :=true;
Fadoquery.Connection:=Fadoconnection;
FAdoQUserInfor.Connection :=Fadoconnection;
Fadoconnection.ConnectionString :=
‘Provider=Microsoft.Jet.OLEDB.4.0;Data Source=PersonInformation.mdb; +
Mode=Read;Persist Security Info=False‘;

Fnmmsg:=nmmsg;
FNMretureMSG:=NMretureMSG;
strlist:=Tstringlist.Create;

end;

destructor QueryThread.Destroy;
begin
FAdoQuery.FREE;
FAdoQUserInfor.FREE;
Fadoconnection.Free;
strlist.Free;
iplist.free;
CoUnInitialize;//必须使用
inherited destroy;
end;

procedure QueryThread.Execute;
begin

try
begin
extractinfor(FComputerInfor); //进行信息提取
Synchronize(ShellexeQuery);//
end;
except

self.Terminate;

end;

end;

procedure QueryThread.ExtractInfor(TransInfo: string);
//改过程进行提取用#进行分割//的串里的各个字符串

integer;
j:array [1..2]of integer;//用来保存分割符的位置
H,L,M,N:integer;//进行组合字符串时的循环参数

begin

全局变量,首先清空
ExtractDomainUser:=‘‘;
ExtractDomainname:=‘‘;
ExtractComputername:=‘‘;
H:=1;

//=================================
try
begin
for i := 1 to length(TransInfo) do

if TransInfo[i]=‘#‘ then //找到了
begin
j[H]:=i;

inc(H);
continue; //跳出循环
end;

BEGIN
for L:=1 to j[1]-1 do
ExtractDomainUser:=ExtractDomainUser+TransInfo[L]; //提取的登陆域用户名
://showmessage(extractdomainuser);
for M:=j[1]+1 to j[2]-1 do
ExtractDomainname:=ExtractDomainname+TransInfo[M];//提取的域控制器名
//showmessage(extractdomainname);
for N:=j[2]+1 to length(trim(TransInfo)) do
ExtractComputername:=ExtractComputername+Transinfo[N];//提取的计算机名
//showmessage(extractcomputername);
END;
end;//进行异常处理
Except
// messagebox(0,‘信息提取出现错误!‘,‘提示信息‘,mb_iconinformation);
end;
end;
////////////////////////////////////////////////////////////////////////////////
procedure QueryThread.ShellexeQuery;
var
mark:string; //保存查找到的工号信息
SkillInfor:string;
RetureInformation:string; //返回个客户端的信息
WorkGroupUserInfor:Tstringlist;
filename:string;

begin
try
begin

FAdoQuery.Close;
Fadoquery.SQL.Clear;
FAdoQuery.SQL.Add (‘SELECT * From LOGON WHERE DomainUser=‘+
‘"‘+ExtractDomainUser+‘"‘+
‘and DomainName=‘+
‘"‘+ExtractDomainname+
‘"‘+‘and ComputerName=‘+
‘"‘+ExtractComputername+
‘"‘+‘and IPaddress=‘+
‘"‘+FIPaddressinfo+‘"‘);
FAdoQuery.Prepared :=true;
FAdoQuery.active:=true;
file://=====================================================================
if (FAdoQuery.fieldbyname(‘WorkMark‘).asstring =‘‘) or
(FAdoQuery.fieldbyname(‘Privilege‘).asstring=‘‘) then //没有查到工号信息
begin

Fnmmsg.Disconnect;
Fnmmsg.Host:=FIPaddressinfo;
Fnmmsg.Port :=6711;
Fnmmsg.FromName :=‘a‘;
Fnmmsg.PostIt(defeat); //没有找到权限和工号则发送错误消息
FAdoQuery.active:=false;
end

else //查询到了工号,和权限信息 ,从阶连表中得到所有信息
//@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
begin

strlist.Clear;
strlist.Add(FAdoQuery.fieldbyname(‘WorkMark‘).asstring);//把工号写入
mark:=FAdoQuery.fieldbyname(‘WorkMark‘).asstring; //将工号写入mark临时变量

FAdoQuery.close; //关闭第一个数据集
//===========进入第二个表进行查找===============================================
with FAdoQUserInfor do
begin
if active =true then close; //关闭数据集
sql.Clear;
sql.Add(‘Select * From WORKER Where WorkMark=‘+‘"‘+mark+‘"‘);
//该部分可能要求具体化内容
Prepared :=true;
open;
//连接第二个线程时这里出现问题
if (fieldbyname(‘Phone‘).asstring=‘‘)or (fieldbyname(‘Name‘).asstring=‘‘)or (fieldbyname(‘SkillLevel‘).asstring=‘‘)then
begin
showmessage(‘nil‘);
Fnmmsg.Disconnect;
Fnmmsg.Host:= FIPaddressinfo;
Fnmmsg.Port :=6711;
Fnmmsg.FromName :=‘b‘;
Fnmmsg.PostIt(defeat); //发送错误消息
close;
end
else //如果找到了电话号码
begin
strlist.add(fieldbyname(‘Name‘).asstring); //写入姓名
SkillInfor:=fieldbyname(‘SkillGroup‘).asstring;
strlist.add(fieldbyname(‘SkillGroup‘).asstring+‘业务处理=‘+fieldbyname(‘SkillLevel‘).asstring); //上海市业务处理=1
strlist.Add(fieldbyname(‘Phone‘).asstring); //写入电话号码
RetureInformation :=strlist.Strings[0]{工号}+
‘#‘+strlist.Strings[1]{姓名}+
‘#‘+strlist.Strings[2]+
‘#‘{技能信息}+strlist.strings[3]{电话号码};
//edit; //烦会给客户端的信息
// fieldbyname(‘IsLogon‘).asstring:=‘1‘; //登录成功,写入成功标志
// Post;
FNMretureMSG.Disconnect;
FNMretureMSG.Host :=FIPaddressinfo;
FNMretureMSG.Port:=6722; //回传信息远程端口为6722;
FNMretureMSG.PostIt(RetureInformation); //返回成功的信息

/·······························
{进行查询工作组信息,然后传送信息}
if active =true then close;
sql.clear;
SQL.Add(‘SELECT * FROM WORKER WHERE SkillGroup=‘+‘"‘+SkillInfor+‘"‘);
open;
WorkGroupUserInfor:=Tstringlist.create;
while not eof do
begin
WorkGroupUserInfor.Add(fieldByName(‘Name‘).asstring ); {index0 name}
WorkGroupUserInfor.Add(fieldByName(‘WorkMark‘).asstring );
{index1 workmark}
WorkGroupUserInfor.Add(fieldByName(‘Phone‘).asstring );
{index2 Phone}
WorkGroupUserInfor.Add(fieldByName(‘SkillGroup‘).asstring +
‘业务处理=‘+
fieldbyname(‘SkillLevel‘).asstring); {index3 SkillGroup}
IPlist.Add(fieldbyname(‘IPaddress‘).asstring);
://所有的ip地址保留到内存中
//showmessage(fieldbyname(‘IPaddress‘).asstring);
iplist.SaveToFile (fieldByName(‘SkillGroup‘).asstring+‘IPlst.INI‘);
next;
end;
WorkGroupUserInfor.SaveToFile(fieldByName(‘SkillGroup‘).asstring+‘.ini‘);
close;
end;
end;
end;
end;
except //防止查询失败
begin
FAdoQuery.close;
FAdoQUserInfor.close;
end;
end;

end;

end.
注意:使用这两个函数应该加上activex.pas单元,否则,无法运行。

我个人认为,如果开发基于ADO的多线程操作,最好在每个线程中放置一个连接,而数据
集和数据连接都使用动态生成,当然你必须要注意必须要保证线程能过正常的释放,否则你
的电脑很快就快死机了,呵呵,当然还有第二种方法,你可以生成一个数据模块,静态放置
数据集和ADOCONNECTION组件,然后使该数据模块不在程序开始时生成,而可以在线程中动态
的生成,这种方法也可以,有兴趣的朋友可以试一下二者之间的执行效率。

而对于ADO,我认为在开始情况下,如果不初始函数和后来的释放函数,却不能报错,应
该是一个BUG吧。

时间: 2024-12-29 22:45:17

ADO多线程的相关文章

ADO多线程数据库查询

ADO多线程数据库查询通常会出现3个问题: 1.CoInitialize 没有调用 (CoInitialize was not called):所以,在使用任何dbGo对象前,必须手 调用CoInitialize和CoUninitialize.调用CoInitialize失败会产生"CoInitialize was not called"例外. 2.画布不允许绘画 (Canvas does not allow drawing):所以,必须通过Synchronize过程来通知主线程访问主

Delphi多线程数据库查询(ADO)

ADO多线程数据库查询通常会出现3个问题: 1.CoInitialize 没有调用(CoInitialize was not called):所以,在使用任何dbGo对象前,必须手 调用CoInitialize和CoUninitialize.调用CoInitialize失败会产生"CoInitialize was not called"例外. 2.画布不允许绘画(Canvas does not allow drawing):所以,必须通过Synchronize过程来通知主线程访问主窗体

【转】Delphi多线程学习(9):多线程数据库查询(ADO)

原文:http://www.cnblogs.com/djcsch2001/articles/2382559.html ADO多线程数据库查询通常会出现3个问题: 1.CoInitialize 没有调用(CoInitialize was not called):所以,在使用任何dbGo对象前,必须手 调用CoInitialize和CoUninitialize.调用CoInitialize失败会产生"CoInitialize was not called"例外. 2.画布不允许绘画(Can

[delphi技术]Delphi多线程数据库查询(ADO)

ADO多线程数据库查询通常会出现3个问题: 1.CoInitialize 没有调用(CoInitialize was not called):所以,在使用任何dbGo对象前,必须手 调用CoInitialize和CoUninitialize.调用CoInitialize失败会产生"CoInitialize was not called"例外. 2.画布不允许绘画(Canvas does not allow drawing):所以,必须通过Synchronize过程来通知主线程访问主窗体

CSDN回帖得分大全(近两年)

CSDN回帖得分大全(近两年) √ vs2005调用dll的时候Initialize()函数返回错误[VC/MFC 基础类] √ 为什么我创建登陆框之后,然后获取登陆框的数据时候总是出现非法操作![VC/MFC 界面] √ CFileFind::FindFile   支持通配符么?[VC/MFC 基础类] √ vc++   浮动窗口联动的实现[VC/MFC 界面] √ VC   从数据库中读出数据流后怎么判断文件格式[VC/MFC 数据库] √ windows   7接硬體,不會自動刷新   請

Delphi多线程下的ADO编程

前言: 几个月前接到一个任务:将一后台程序访问数据库的方式从BDE改为ADO,原因是由于业务量的增加,通过BDE不论是向数据库写入数据还是从数据库中读出数据的速度都变得无法忍受,大家都知道ADO在数据库访问速度方面比BDE要快的多了(我写了一个测试程序使用ADO比使用BDE快了近100倍!).这个任务还不简单嘛,只要将BDE的控件更换成ADO的再修改一些代码不就搞定了!我当时确实是这么想的,而且用了不到一个小时就搞定,测试运行一段没问题,大功告成了,我想.谁知道一个恶梦就此开始,我的愚昧无知使我

delphi 多线程 动态创建ADO

delphi 在多线程中动态连接ADO控件 异常:exception class EOleSysError with message '尚未调用CoInitialize' 如果是使用多线程的话那就在 Execute事件的开头加上 CoInitialize(nil); 结尾加上CoUninitialize() unit Unit1;interfaceuses Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Fo

一种利用ADO连接池操作MySQL的解决方案(VC++)

VC++连接MySQL数据库 常用的方式有三种:ADO.mysql++,mysql API ; 本文只讲述ADO的连接方式. 为什么要使用连接池? 对于简单的数据库应用,完全可以先创建一个常连接(此连接永远不关闭,直接数进程退出),但是这样做至少会引起两个问题:(1)资源竞争,多个数据库请求操作不能同时进行,后一请求必须要等到前一请求完成后才能进行:(2)多线程情况下容易出现混乱,甚至出现资源异常释放.还有一种方法,就是使用数据库时创建连接,使用完后关闭连接回收资源.这种方式在数据库操作频繁的情

C#综合揭秘——细说多线程(下)

引言 本文主要从线程的基础用法,CLR线程池当中工作者线程与I/O线程的开发,并行操作PLINQ等多个方面介绍多线程的开发.其中委托的BeginInvoke方法以及回调函数最为常用.而 I/O线程可能容易遭到大家的忽略,其实在开发多线程系统,更应该多留意I/O线程的操作.特别是在ASP.NET开发当中,可能更多人只会留意在客户端使用Ajax或者在服务器端使用UpdatePanel.其实合理使用I/O线程在通讯项目或文件下载时,能尽量降低IIS的压力.并行编程是Framework4.0中极力推广的