使用ADO,多线程访问ACCESS数据库的开发。[1]

[入库:2005年8月18日] [更新:2007年3月24日]

本文简介:选择自 wxjh 的 blog

本人最近正在进行呼叫中心的座席端和服务器软件开发,座席端登录部分是进行提取主机信息,然后使用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

本文关键:ADO
 

本站最佳浏览方式为 分辨率 1024x768 IE 6.0(或更高版本的 IE浏览器)

go top