我在一个单线程理用了个ADOQuery，向sql数据库插入很多数据，现在有2个问题(50分)

mazheng · 2008-03-07

我在一个单线程理用了个ADOQuery，向sql数据库插入很多数据，现在有2个问题，当用户点击‘停止’按钮时，如何在停止线程的同时停止数据的插入，2，为什么程序会自动退出？？

mazheng · 2008-03-07

到底哪里出问题了？？？ ype   Txyz = class(TThread)   published     procedure Execute; override;     procedure displaymemo;   end; var   ClientMainFrm: TClientMainFrm;   XYZThread: Txyz;   Y_Table,B_Table,SqlString:string;   myCursor:tCursor;   myint,MyWay,Sint,Oint,LastTimeSid,ThisTimeSid,LastTimeOid,ThisTimeOid:Integer;   sl:TStringList; implementation //truncate table msg {$R *.dfm} //============================================================================== procedure Txyz.displaymemo; var LocalSourceid,RemoteSourceId:Integer; begin   //Sbool:=False;Obool:=False;   ClientMainFrm.stat1.Panels.Items[0].Text:='正在同步...';   ClientMainFrm.mmoRunTxt.Lines.Add('正在同步...');   ClientMainFrm.mmoRunTxt.Clear;   myCursor:=ClientMainFrm.Cursor;   ClientMainFrm.Cursor:=crHourGlass;   ClientMainFrm.tmr1.Enabled:=False;   ClientMainFrm.btnSet.Enabled:=False;   RemoteSourceId := ClientMainFrm.myini.ReadInteger('Source','远程source',0);   LocalSourceid  := ClientMainFrm.myini.ReadInteger('Source','本地source',0);   Coinitialize(nil);   case MyWay of     0:ClientMainFrm.InstRemote(RemoteSourceId,LocalSourceid); //同步到远程     1:ClientMainFrm.InstLocal(RemoteSourceId,LocalSourceid);  //同步到本地     2:begin         ClientMainFrm.mmoRunTxt.Lines.add('双向同步：');         ClientMainFrm.mmoRunTxt.Lines.add('');         ClientMainFrm.InstLocal(RemoteSourceId,LocalSourceid);//先执行'同步到本地‘         ClientMainFrm.InstRemote(RemoteSourceId,LocalSourceid);//先执行'同步到远程       end;   end;   CoUnInitialize; end; //============================================================================== procedure Txyz.Execute; begin   while not Terminated do   begin     try       displaymemo;       ClientMainFrm.ThreadFree;     except       sl.Add(DateTimeToStr(Now)+'--线程错误');       sl.SaveToFile('c:/测试.txt');     end;   end; end; //============================================================================== procedure TClientMainFrm.InstLocal(const ARemoteSourceId,ALocalSourceid:integer); begin   try     ThisTimeOid:=TopConst(con1,y_Table);     Oint:= ThisTimeOid - LastTimeOid;     LastTimeOid:=ThistimeOid;     if Oint>0 then       if OpenLongDistanceData(y_Table,Oint) then         InPhaseUpdate(qry1,qry2,b_Table,'同步到本地：',ARemoteSourceId,ALocalSourceid,True);   except     sl.Add(DateTimeToStr(Now)+'--InstRemote错误');     sl.SaveToFile('c:/测试.txt');   end; end; //============================================================================== procedure TClientMainFrm.InstRemote(const ARemoteSourceId,ALocalSourceid:integer); begin   try     ThisTimeSid:=TopConst(con2,B_Table);     sint:= ThisTimeSid - LastTimeSid;     LastTimeSid:=ThisTimeSid;     if Sint>0 then       if OpenData(B_Table,Sint) then         InPhaseUpdate(qry2,qry1,Y_Table,'同步到远程：',ALocalSourceid,ARemoteSourceId,False);   except     sl.Add(DateTimeToStr(Now)+'--InstLocal错误');     sl.SaveToFile('c:/测试.txt');   end; end; //============================================================================== function TClientMainFrm.TopConst(Acon:TADOConnection;ATable:string):Integer; var QryTmp:TADOQuery; begin   qrytmp:=TADOQuery.Create(nil);   try     qrytmp.Connection:=Acon;     qrytmp.Close;     qrytmp.SQL.Clear;     qrytmp.SQL.Add('select top 1 id from '+ATable+' order by id desc');     try       QryTmp.Open;       Result:=StrToInt(QryTmp.Fields[0].Text);     except       Result:=0;     end;   finally     qrytmp.Close;     QryTmp.Free;   end; end; //============================================================================== function TClientMainFrm.RunSql(Aqry:TADOQuery;Atext:string;i:Integer; Abool:Boolean):Boolean; var t:string; begin   if Abool then   begin     With AQry Do     Begin       Close;       SQL.Clear ;       SQL.Add('EXECUTE insttext :s1, :s2, :s3, :s4, :s5 Output ') ;       Parameters.Items[0].Value := strFields1;       Parameters.Items[1].Value := strFields2;       Parameters.Items[2].Value := strFields3;       Parameters.Items[3].Value := strFields4;       try         Prepared;         ExecSQL;         T := Parameters.Items[4].Value;         if t='0' then Result:=True         else Result:=False;         Close;       except         Result:=False;         Close;       end;     end;   end else   begin     With AQry Do     Begin       Close;       SQL.Clear ;       SQL.Add(Atext);       try         if i=1 then Open         else ExecSQL;         Result:=True       except         Result:=False;         Close;       end;     end;   end; end; //============================================================================== procedure TClientMainFrm.ThreadFree; begin   stat1.Panels.Items[0].Text:='';   Cursor:=myCursor;   tmr1.Enabled:=True;   pb1.Position:=0;   Sqltxt:='';   strFields1:='';   strFields2:='';   strFields3:='';   strFields4:='';   Threadbool:=False;   XYZThread.Terminate;   qry1.Close;   qry2.Close;   XYZThread.WaitFor;   XYZThread.Free;   XYZThread:=nil; end; //============================================================================== procedure TClientMainFrm.InPhaseUpdate(ASqry,AOqry:TADOQuery;ATable,AstrTxt:string;                                        ASSource,AOSource:Integer;Abool:Boolean); var mSource,nSource,Stmp:string;i:Integer; begin   mmoRunTxt.Lines.Add('');   mmoRunTxt.Lines.Add(AstrTxt);   mmoRunTxt.Lines.Add('');   mSource:=inttostr(ASSource);   pb1.Position:=0;   pb1.Max:=ASqry.RecordCount-1;   ASqry.Last;   while not ASqry.Bof do   begin     try       pb1.Position:=pb1.Position+1;       nSource:=Trim(Asqry.Fields.Fields[4].Text);       if nSource <> mSource then       begin         strFields1:=Asqry.Fields.Fields[1].Text;         strFields2:=Asqry.Fields.Fields[2].Text;         strFields3:=Asqry.Fields.Fields[3].Text;         strFields4:=inttostr(AOSource);         //------------------------------         Sqltxt:='INSERT INTO ' + ATable +' (msg,tel,code,source) VALUES (';         Sqltxt:=Sqltxt+'N'''+Asqry.Fields.Fields[1].Text+''',';         Sqltxt:=Sqltxt+'N'''+ASqry.Fields.Fields[2].Text+''',';         Sqltxt:=Sqltxt+'N'''+ASqry.Fields.Fields[3].Text+''',';         Sqltxt:=Sqltxt+'N'''+inttostr(AOSource)+''')';         //------------------------------         Stmp:=' 插入记录:[ (源库ID:'+Asqry.Fields.Fields[0].Text+') ';         Stmp:=Stmp+Asqry.Fields.Fields[1].Text+',';         Stmp:=Stmp+Asqry.Fields.Fields[2].Text+',';         Stmp:=Stmp+Asqry.Fields.Fields[3].Text+',';         Stmp:=Stmp+inttostr(AOSource)+']';         //-------------------------------         if RunSql(AOqry,Sqltxt,0,Abool) then           mmoRunTxt.Lines.Add(Stmp);         //-------------------------------         for i:=1 to 1000 do ;         //Application.ProcessMessages;         strFields1:='';         strFields2:='';         strFields3:='';         strFields4:='';         Sqltxt:='';       end;     except     end;     ASqry.Prior;   end;   ASqry.Close;   //MsgBox('ok');   pb1.Position:=0; end; //============================================================================== function TClientMainFrm.OpenLongDistanceData(ATable:string;ATopVal:Integer):Boolean; begin                                       //id,msgtime,   Sqltxt:='SELECT top '+inttostr(ATopVal)+'id,msg,tel,code,source FROM '+ATable;   Sqltxt:=Sqltxt + ' order by id desc';   if not RunSql(qry1,Sqltxt,1,False) then   begin     mmoRunTxt.Lines.Add('远程数据表打开失败。');     cltrycnTrayIcon.Hint:='数据同步器';     Result:=False;   end else     Result:=True; end; //============================================================================== function TClientMainFrm.OpenData(ATable:string;ATopVal:Integer):Boolean; begin   Sqltxt:='SELECT top '+inttostr(ATopVal)+'id,msg,tel,code,source FROM '+ATable;   Sqltxt:=Sqltxt + ' order by id desc';   if not RunSql(qry2,Sqltxt,1,False) then   begin     mmoRunTxt.Lines.Add('本地数据表打开失败。');     cltrycnTrayIcon.Hint:='数据同步器';     Result:=False;   end else     Result:=True; end; //============================================================================== function TClientMainFrm.LinkServer:Boolean; begin   Result:=False;   if FileExists(StrUdl) then   begin     try       con2.Close;       con2.ConnectionString:='FILE NAME='+StrUdl;       con2.Open;       Result:=True;     except       mmoRunTxt.Lines.Add('本地数据库链接失败。');       cltrycnTrayIcon.Hint:='数据同步器';     end;   end; end; //============================================================================== function TClientMainFrm.LinkLongDistanceServer:Boolean; var sqlip,sqlUser,sqlkey,sqlName:string; begin   sqlip     := Trim(myini.ReadString('SET','SqlIp',''));   sqlName   := Trim(myini.ReadString('SET','SqlName',''));   sqlUser   := Trim(myini.ReadString('SET','SqlUser',''));   sqlkey    := Trim(myini.ReadString('SET','Sqlkey',''));   Y_Table   := Trim(myini.ReadString('TABLE','远程表',''));   B_Table   := Trim(myini.ReadString('TABLE','本地表',''));   SqlString := 'Provider=SQLOLEDB.1;Password='+sqlkey +';Persist Security Info=True;';   SqlString := SqlString+'User ID='+sqlUser+';';   SqlString := SqlString+'Initial Catalog='+sqlName+';';   SqlString := SqlString+'Data Source='+ sqlip;   try     con1.Close;     con1.ConnectionString:=SqlString;     con1.Open;     Result := True;   except     mmoRunTxt.Lines.Add('远程数据库链接失败。');     cltrycnTrayIcon.Hint:='数据同步器';     Result:=False;   end; end; //============================================================================== procedure TClientMainFrm.SetFrmShow; var SetFrm: TSetFrm; begin   tmr1.Enabled:=False;   SetFrm:= TSetFrm.Create(nil);   try     SetFrm.ShowModal;     if SetFrm.SetBool then     begin       LastTimeSid:=0;       LastTimeOid:=0;     end;   finally     SetFrm.Free;   end; end; //============================================================================== procedure TClientMainFrm.FormCreate(Sender: TObject); var mbool:Boolean; begin //  mbool:=False;   Myint          := 0;   Sint           := 0;   oint           := 0;   LastTimeSid    := 0;   LastTimeOid    := 0;   LocalSourceid  := 0;   RemoteSourceId := 0;   strFields1     := '';   strFields2     := '';   strFields3     := '';   strFields4     := '';   Sqltxt         := '';   Threadbool     := False;   sl:=TStringList.Create;;   sl.Clear;   //--------------------------------   StrUdl:= ExtractFilePath(Application.ExeName)+'nclient.udl';   inifiles:= ExtractFilePath(Application.ExeName)+'NClient.ini';   myini:=tinifile.Create(inifiles);   if not FileExists(StrUdl) then   begin     ErrBox('文件[nclient.udl]丢失，程序无法启动');     Application.Terminate;   end;   if not FileExists(inifiles) then SetFrmShow;   MyInterval     := myini.ReadInteger('TimeWay','time',0)*1000;   MyWay          := myini.ReadInteger('TimeWay','Way',0);   tmr1.Interval  := MyInterval;   mbool:=myini.ReadBool('Automatic','auto',False);   if mbool then     btnStart.Click; end; //============================================================================== procedure TClientMainFrm.btnExtClick(Sender: TObject); begin   Close; end; //============================================================================== procedure TClientMainFrm.btnSetClick(Sender: TObject); begin   SetFrmShow; end; //============================================================================== procedure TClientMainFrm.tmr1Timer(Sender: TObject); begin   try     Threadbool:=True;     XYZThread := Txyz.Create(False);   except     sl.Add(DateTimeToStr(Now)+'--创建线程时错误');     sl.SaveToFile('c:/测试.txt');   end; end; //============================================================================== procedure TClientMainFrm.N1Click(Sender: TObject); begin   cltrycnTrayIcon.ShowMainForm; end; //============================================================================== procedure TClientMainFrm.btnStartClick(Sender: TObject); begin   btnStart.Enabled:=False;   try     if Myint=0 then     begin       if ClientMainFrm.LinkLongDistanceServer and ClientMainFrm.LinkServer then       begin         myint:=1;         stat1.Panels.Items[0].Text:='';         mmoRunTxt.Lines.Clear;         //----------------------------------//         ThisTimeSid:=TopConst(con2,B_Table);         LastTimeSid:=ThisTimeSid;         ThisTimeOid:=TopConst(con1,y_Table);         LastTimeOid:=ThisTimeOid;       end;     end;     if myint=1 then     begin       if btnStart.Caption='开始' then       begin         cltrycnTrayIcon.Hint:='数据同步器-正在同步';         btnStart.Caption:='暂停';         //stat1.Panels.Items[0].Text:='';         btnSet.Enabled:=False;         tmr1.Enabled:=True;       end else       begin         if btnStart.Caption='暂停' then         begin           if Threadbool then XYZThread.Suspend           else tmr1.Enabled:=False;           stat1.Panels.Items[0].Text:='暂停...';           btnStart.Caption:='继续';         end else         begin           if Threadbool then XYZThread.Resume           else tmr1.Enabled:=True;           btnStart.Caption:='暂停';           stat1.Panels.Items[0].Text:='';         end;       end;     end;   finally     btnStart.Enabled:=True;   end; end; //============================================================================== procedure TClientMainFrm.btn3Click(Sender: TObject); begin   if Threadbool then ThreadFree;   cltrycnTrayIcon.Hint:='数据同步器';   stat1.Panels.Items[0].Text:='';   if tmr1.Enabled then tmr1.Enabled:=False;   if btnStart.Caption<>'开始' then btnStart.Caption:='开始';   btnSet.Enabled:=True; end; //============================================================================== procedure TClientMainFrm.FormCloseQuery(Sender: TObject;   var CanClose: Boolean); begin   if not YesNoBox('真的要退出？') then     CanClose := False   else begin     try       btn3.Click;       myini.Free;       sl.Free;     except     end;   end; end; //============================================================================== end.

cqwty · 2008-03-07

你的代码不要贴这么多了，没有人能看完，你把你的程序框架写一下，把主要的框架留下就是了。

kinneng · 2008-03-07

没空看代码，不知道楼主有否注意ADOQuery的线程不安全性，线程是个死循环，线程程序 自己退出，一般是程序有问题，比如资源，内存和其它冲突。

mazheng · 2008-03-07

就是每隔几秒创建一个单线程，在线程里执行对数据库的查询、插入操作！现在有2个问题，当用户点击‘停止’按钮时，如何在停止线程的同时停止数据的插入，2，为什么程序会自动退出？？   //============================================================================== procedure TClientMainFrm.tmr1Timer(Sender: TObject); begin   try     Threadbool:=True;     XYZThread := Txyz.Create(False);   except     sl.Add(DateTimeToStr(Now)+'--创建线程时错误');     sl.SaveToFile('c:/测试.txt');   end; end; //============================================================================== procedure Txyz.displaymemo; var LocalSourceid,RemoteSourceId:Integer; begin   //Sbool:=False;Obool:=False;   ClientMainFrm.stat1.Panels.Items[0].Text:='正在同步...';   ClientMainFrm.mmoRunTxt.Lines.Add('正在同步...');   ClientMainFrm.mmoRunTxt.Clear;   myCursor:=ClientMainFrm.Cursor;   ClientMainFrm.Cursor:=crHourGlass;   ClientMainFrm.tmr1.Enabled:=False;   ClientMainFrm.btnSet.Enabled:=False;   RemoteSourceId := ClientMainFrm.myini.ReadInteger('Source','远程source',0);   LocalSourceid  := ClientMainFrm.myini.ReadInteger('Source','本地source',0);   Coinitialize(nil);   case MyWay of     0:ClientMainFrm.InstRemote(RemoteSourceId,LocalSourceid); //同步到远程     1:ClientMainFrm.InstLocal(RemoteSourceId,LocalSourceid);  //同步到本地     2:begin         ClientMainFrm.mmoRunTxt.Lines.add('双向同步：');         ClientMainFrm.mmoRunTxt.Lines.add('');         ClientMainFrm.InstLocal(RemoteSourceId,LocalSourceid);//先执行'同步到本地‘         ClientMainFrm.InstRemote(RemoteSourceId,LocalSourceid);//先执行'同步到远程       end;   end;   CoUnInitialize; end; //============================================================================== procedure Txyz.Execute; begin   while not Terminated do   begin     try       displaymemo;       ClientMainFrm.ThreadFree;     except       sl.Add(DateTimeToStr(Now)+'--线程错误');       sl.SaveToFile('c:/测试.txt');     end;   end; end; //============================================================================== procedure TClientMainFrm.ThreadFree; begin   stat1.Panels.Items[0].Text:='';   Cursor:=myCursor;   tmr1.Enabled:=True;   pb1.Position:=0;   Sqltxt:='';   strFields1:='';   strFields2:='';   strFields3:='';   strFields4:='';   Threadbool:=False;   XYZThread.Terminate;   qry1.Close;   qry2.Close;   XYZThread.WaitFor;   XYZThread.Free;   XYZThread:=nil; end; //============================================================================== procedure TClientMainFrm.btn3Click(Sender: TObject);//停止按钮 begin   if Threadbool then ThreadFree;   cltrycnTrayIcon.Hint:='数据同步器';   stat1.Panels.Items[0].Text:='';   if tmr1.Enabled then tmr1.Enabled:=False;   if btnStart.Caption<>'开始' then btnStart.Caption:='开始';   btnSet.Enabled:=True; end; //==============================================================================

datafans · 2008-03-08

给你一个思路： 1、定义一个全局变量StopRun，表示是否停止执行； 2、线程创建前StopRun = false（不停止执行）； 3、线程执行过程中检测StopRun是否为true，如果被改为true则线程自己终止运行； 4、不要试图从外部终止线程； 5、此方法只能处理一个线程，否则多个现成将同时终止；

我在一个单线程理用了个ADOQuery，向sql数据库插入很多数据，现在有2个问题(50分)

mazheng

Unregistered / Unconfirmed

mazheng

Unregistered / Unconfirmed

cqwty

Unregistered / Unconfirmed

kinneng

Unregistered / Unconfirmed

mazheng

Unregistered / Unconfirmed

datafans

Unregistered / Unconfirmed

Similar threads