本人最近正在进行呼叫中心的座席端和服务器软件开发,座席端登录部分是进行提取主机信息,然后使用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对象都应该使用。线程的关闭时应该使用CoUnInitialize;否则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; &nbs [1] [2] 下一页 [其他]手工升级ACCESS到SQLSERVER方法详解 [Web开发]把ACCESS的数据导入到Mysql中的方法详解 [C语言系列]SQL Server连接ACCESS数据库的实现 [C语言系列]应用 SQLServer 链接服务器访问远程 Access 数据库 [VB.NET程序]WindowsForm登陆窗体的制作(Vb.net+Access) [VB.NET程序]在VB.NET中使用MS Access存储过程 — 第二部份 [VB.NET程序]在VB.NET中使用MS Access存储过程 — 第一部份 [VB.NET程序]如何在Visual Basic 6.0 中连接加密的Access数据库 [Delphi程序]Delphi Access violations 问题的解决之道 [Delphi程序]Delphi操作ACCESS技巧集
|