Delphi线程恢复SQL Server数据库成功却报‘Object is open’错误排查

1. 跨线程操作非线程安全的VCL控件：你在线程中直接复用主窗体的TMSConnection、TMSQuery、TMSDataSource控件，这类VCL控件并非线程安全，且大概率在主线程中已经处于打开状态，在线程中直接操作会触发状态冲突，导致“Object is open”错误。
2. 错误释放不属于线程的控件：线程执行完毕后调用DataSource.Free、Connection.Free、Query.Free，这些控件由主窗体创建并管理生命周期，线程无权释放它们，且释放时若控件处于打开状态，必然触发对象状态异常。
3. 未确保Query处于关闭状态：修改Query.SQL.Text并执行前，没有先关闭Query，若Query原本处于打开状态，直接修改或执行会引发错误。

1. 线程内部创建独立的数据库组件 #

不要复用主窗体的控件，在线程内部创建专属的TMSConnection和TMSQuery，复制主窗体的连接参数进行配置，操作完成后自行释放。

2. 移除对主窗体控件的释放操作 #

彻底删除线程中DataSource.Free、Connection.Free、Query.Free这三行代码，主窗体控件的生命周期由主窗体负责。

3. 操作Query前强制关闭 #

执行SQL前先调用Query.Close，避免因Query处于打开状态引发错误。

4. 移除线程中对TMSDataSource的操作 #

TMSDataSource用于UI数据绑定，线程中不需要使用它，直接用TMSQuery执行SQL即可。

修改后的代码示例 #

恢复线程定义

type
  TThreadRestoreBackUp = class(TThread)
  protected
    procedure Execute(); override;
  public
    // 只传递业务参数，不传递VCL控件
    DBName, RestorePath: string;
    DifferentDB: Boolean;
    // 复制主连接的配置参数
    ConnServer, ConnUser, ConnPassword: string;
  end;

线程调用代码

procedure TfrmCreateBackUp.btnRestoreClick(Sender: TObject);
var
  RestoreBackUp: BackUpThread.TThreadRestoreBackUp;
begin
  RestoreBackUp := BackUpThread.TThreadRestoreBackUp.Create(True);
  RestoreBackUp.FreeOnTerminate := True;
  try
    // 传递业务参数
    RestoreBackUp.DBName := edtDBName.Text;
    RestoreBackUp.DifferentDB := tcxCheckBoxNewDB.Checked;
    RestoreBackUp.RestorePath := cxbeChoosePath.Text;
    // 复制主连接的配置
    with frmMain.MSConnLyubenAirport do
    begin
      RestoreBackUp.ConnServer := Server;
      RestoreBackUp.ConnUser := UserName;
      RestoreBackUp.ConnPassword := Password;
    end;
    RestoreBackUp.Start;
  except
    on E: Exception do
    begin
      RestoreBackUp.Free;
      ShowMessage('线程启动失败：' + E.Message);
    end;
  end;
end;

线程Execute方法实现

procedure TThreadRestoreBackUp.Execute();
var
  LocalConn: TMSConnection;
  LocalQuery: TMSQuery;
  dbRPath, dbRLogPath, TargetDBName: string;
begin
  dbRPath := 'E:\ClientDBS\';
  dbRLogPath := 'E:\ClientDBS\';

  // 创建线程专属的数据库组件
  LocalConn := TMSConnection.Create(nil);
  LocalQuery := TMSQuery.Create(nil);
  try
    // 配置连接（恢复操作必须连接master库）
    with LocalConn do
    begin
      Server := ConnServer;
      Database := 'master';
      UserName := ConnUser;
      Password := ConnPassword;
      Connected := True;
    end;
    LocalQuery.Connection := LocalConn;

    if DifferentDB then
    begin
      TargetDBName := DBName;
      dbRPath := dbRPath + TargetDBName + '.mdf';
      dbRLogPath := dbRLogPath + TargetDBName + '.ldf';

      LocalQuery.Close;
      LocalQuery.SQL.Text := 'If DB_ID(' + QuotedStr(TargetDBName) + ') IS NOT NULL BEGIN' +
        ' ALTER DATABASE [' + TargetDBName + '] SET OFFLINE WITH ROLLBACK IMMEDIATE;' +
        ' RESTORE DATABASE [' + TargetDBName + '] FROM DISK = ' + QuotedStr(RestorePath) +
        ' WITH REPLACE, RECOVERY;' +
        ' ALTER DATABASE [' + TargetDBName + '] SET ONLINE;' +
        'END ELSE BEGIN' +
        ' RESTORE DATABASE [' + TargetDBName + '] FROM DISK = ' + QuotedStr(RestorePath) +
        ' WITH RECOVERY, MOVE ' + QuotedStr('Test') + ' TO ' + QuotedStr(dbRPath) +
        ', MOVE ' + QuotedStr('Test_log') + ' TO ' + QuotedStr(dbRLogPath) +
        ';END';
      LocalQuery.Execute;
    end
    else
    begin
      TargetDBName := frmMain.MSConnLyubenAirport.Database;

      LocalQuery.Close;
      LocalQuery.SQL.Text := 'ALTER DATABASE [' + TargetDBName + '] SET OFFLINE WITH ROLLBACK IMMEDIATE;' +
        ' RESTORE DATABASE [' + TargetDBName + '] FROM DISK = ' + QuotedStr(RestorePath) +
        ' WITH REPLACE, RECOVERY;' +
        ' ALTER DATABASE [' + TargetDBName + '] SET ONLINE;';
      LocalQuery.Execute;
    end;

    // 恢复完成后同步更新UI（可选）
    Synchronize(procedure
    begin
      ShowMessage('数据库恢复完成');
    end);
  finally
    // 释放线程自行创建的组件
    LocalQuery.Free;
    LocalConn.Free;
  end;
end;

内容的提问来源于stack exchange，提问作者Ineffable21