5154

在Delphi的开发实践中，与数据库的交互是核心环节之一，无论是桌面应用还是多层架构，高效、稳定地查询和管理数据库连接都是程序员必须掌握的技能，这里的“查询数据库连接”通常包含两层含义：一是检查连接本身的状态（是否已连接、是否可用），二是通过已建立的连接执行SQL查询语句以获取数据，本文将围绕这两个核心点,详细阐述在Delphi中实现这些功能的方法与最佳实践。

检查数据库连接状态

在进行任何数据库操作之前，确认连接处于健康状态至关重要，这可以避免因网络中断、数据库服务器关闭或连接超时等问题引发的运行时错误。

使用 Connected 属性

最直接的方法是检查连接组件的 Connected 属性，这是所有数据库连接组件（如 TADOConnection, TFDConnection, TUniConnection 等）都具备的基础布尔属性。

• True：表示组件已成功连接到数据库。
• False：表示未连接。

示例代码 (以 FireDAC 的 TFDConnection 为例):

procedure TForm1.CheckConnectionStatus;
begin
  if FDConnection1.Connected then
    ShowMessage('数据库连接已建立。')
  else
    ShowMessage('数据库未连接。');
end;

注意： Connected 属性反映的是上一次操作成功时的状态，它并不能保证此刻网络是通畅的，连接成功后，网线被拔掉，Connected 属性可能仍为 True。

使用 Ping 方法（推荐）

为了更准确地判断连接的实时有效性，现代数据库连接库（如 FireDAC）提供了 Ping 方法，该方法会向数据库服务器发送一个轻量级的测试包，并等待响应，从而真实地验证连接的“活性”。

示例代码 (以 FireDAC 的 TFDConnection 为例):

procedure TForm1.PingDatabase;
begin
  try
    if FDConnection1.Connected then
    begin
      FDConnection1.Ping; // 执行Ping操作
      ShowMessage('数据库连接正常，响应良好。');
    end
    else
    begin
      ShowMessage('数据库未连接，无法Ping。');
    end;
  except
    on E: Exception do
      ShowMessage('数据库连接已失效！错误信息：' + E.Message);
  end;
end;

通过 try...except 结构捕获异常，可以优雅地处理连接中断的情况，这是比单纯检查 Connected 属性更健壮的方案。

执行SQL查询

一旦确认连接可用，我们就可以使用它来执行SQL查询，这通常通过查询组件完成，如 TADOQuery, TFDQuery, TUniQuery 等,其基本流程如下：

1. 设置连接：将查询组件的 Connection 属性指向一个已配置好的连接组件。
2. 编写SQL：将SQL语句赋值给查询组件的 SQL 属性（TStrings 类型）。
3. 执行查询：
   • 对于返回数据集的查询（如 SELECT），调用 Open 方法或设置 Active 属性为 True。
   • 对于不返回数据集的操作（如 INSERT, UPDATE, DELETE），调用 ExecSQL 方法。

示例代码 (使用 TFDQuery 查询数据):

procedure TForm1.QueryEmployeeData;
var
  vEmployeeName: string;
  vEmployeeSalary: Double;
begin
  // 1. 确保 FDQuery1 已关联到 FDConnection1
  // 2. 清空之前的SQL语句
  FDQuery1.SQL.Clear;
  // 3. 添加新的SQL查询语句
  FDQuery1.SQL.Add('SELECT Name, Salary FROM Employees WHERE Department = :Dept');
  // 4. 参数化查询，防止SQL注入
  FDQuery1.ParamByName('Dept').AsString := 'Sales';
  try
    // 5. 执行查询并打开数据集
    FDQuery1.Open;
    // 6. 遍历结果集
    if not FDQuery1.Eof then
    begin
      ShowMessage('查询到销售部员工信息：');
      while not FDQuery1.Eof do
      begin
        vEmployeeName := FDQuery1.FieldByName('Name').AsString;
        vEmployeeSalary := FDQuery1.FieldByName('Salary').AsFloat;
        Memo1.Lines.Add(Format('姓名: %s, 薪资: %.2f', [vEmployeeName, vEmployeeSalary]));
        FDQuery1.Next; // 移动到下一条记录
      end;
    end
    else
    begin
      ShowMessage('未找到销售部的员工。');
    end;
  finally
    // 7. 关闭查询，释放资源
    FDQuery1.Close;
  end;
end;

常用数据库连接组件对比

Delphi生态中有多种数据库访问技术,选择合适的组件对项目性能和维护性至关重要。

相关问答FAQs

问题1：连接已建立，但执行查询时却报错“无效的连接句柄”，是什么原因？

解答： 这个错误通常意味着查询组件所引用的连接对象在执行时处于无效状态,常见原因包括：

1. 连接被提前关闭：在调用 Query.Open 之前，Connection.Connected 被意外设置为 False。
2. 连接对象被销毁：连接组件（如 FDConnection1）在查询执行前被 Free 或 FreeAndNil 了,但查询组件仍指向它。
3. 多线程问题：在一个线程中创建了连接和查询，但试图在另一个线程中执行查询,而该连接组件并非线程安全的。
4. 连接超时或服务器断开：虽然 Connected 属性可能为 True，但服务器端已主动断开连接，导致句柄失效，使用 Ping 方法可以有效检测这种情况。

问题2：如何在程序运行时，让用户动态切换数据库？

解答： 动态切换数据库是一个非常实用的功能，可以通过修改连接组件的连接字符串（ConnectionString）或相关属性来实现,基本步骤如下：

1. 关闭当前连接：Connection.Connected := False; 这一步是必须的,不能在连接状态下修改关键参数。
2. 修改连接信息：根据用户输入（如新的服务器地址、数据库名、用户名等），更新连接组件的 ConnectionString，或者分别设置 Params 属性中的 Server, Database, User_Name, Password 等值。
3. 重新建立连接：Connection.Connected := True; 尝试用新的配置连接数据库。
4. 错误处理：将重新连接的代码放入 try...except 块中，如果连接失败,可以恢复到旧的连接配置或提示用户检查输入信息。

示例代码片段：

procedure TForm1.SwitchDatabase(NewServer, NewDB: string);
begin
  // 保存旧连接信息，以便失败时恢复
  var OldServer := FDConnection1.Params.Values['Server'];
  var OldDB := FDConnection1.Params.Values['Database'];
  try
    FDConnection1.Connected := False; // 1. 关闭连接
    FDConnection1.Params.Values['Server'] := NewServer; // 2. 修改参数
    FDConnection1.Params.Values['Database'] := NewDB;
    FDConnection1.Connected := True; // 3. 尝试重连
    ShowMessage('数据库切换成功！');
  except
    on E: Exception do
    begin
      // 连接失败，恢复旧配置
      FDConnection1.Connected := False;
      FDConnection1.Params.Values['Server'] := OldServer;
      FDConnection1.Params.Values['Database'] := OldDB;
      try
        FDConnection1.Connected := True;
      except
        // 即使恢复也失败了，说明问题严重
      end;
      ShowMessage('数据库切换失败！已恢复原配置，错误：' + E.Message);
    end;
  end;
end;