delphi - 如何获取 dbExpress 连接错误的 Winsock 错误代码？

Question

如果出现连接问题，dbExpress 驱动程序会抛出 TDBXError，但不包含套接字错误代码。消息很简单:

Unable to complete network request to host "exampledb.local". Failed to establish a connection

发生此类异常时，是否有办法检索底层套接字错误？

堆栈跟踪是:

main thread ($5934):
0061aa59 +051 example.exe DBXCommon    447  +0 TDBXContext.Error
00817f14 +10c example.exe DBXDynalink  796 +21 TDBXMethodTable.RaiseError
00818553 +013 example.exe DBXDynalink  949  +1 TDBXDynalinkConnection.CheckResult
00818744 +050 example.exe DBXDynalink 1048  +4 TDBXDynalinkConnection.DerivedOpen
0061750f +007 example.exe DBXCommon    447  +0 TDBXConnection.Open
00612fed +0f5 example.exe DBXCommon    447  +0 TDBXConnectionFactory.GetConnection
00612ef1 +005 example.exe DBXCommon    447  +0 TDBXConnectionFactory.GetConnection
0062c08f +26f example.exe SqlExpr              TSQLConnection.DoConnect
005d9019 +039 example.exe DB                   TCustomConnection.SetConnected
005d8fd4 +004 example.exe DB                   TCustomConnection.Open
0062b98f +01b example.exe SqlExpr              TSQLConnection.CheckConnection
0062ebdf +01f example.exe SqlExpr              TCustomSQLDataSet.CheckConnection
0062efe4 +04c example.exe SqlExpr              TCustomSQLDataSet.OpenCursor
005e91d5 +055 example.exe DB                   TDataSet.SetActive
005e901c +004 example.exe DB                   TDataSet.Open

Answer 1

(本答案中使用了 Delphi XE2 和“gds32.dll”10.0.1.335 (ansi))

dbExpress 是一个高级框架，它将提供程序特定的操作委托(delegate)给其驱动程序。所有这些提供程序特定的驱动程序都公开相同的基本通用功能，因此不可能检索超出此通用功能的特定信息。

关于错误报告，驱动程序导出两个函数。无论是mysql、mssql还是任何其他驱动程序，这些函数都是DBXBase_GetErrorMessageLength和DBXBase_GetErrorMessage。驱动程序从客户端库获取大部分错误信息，并通过这些函数将该信息报告给框架。除了已经报告的内容之外，不可能获得有关连接到数据库服务器或任何其他操作时出错的任何更具体的详细信息。

因此，是否包含 Winsock 错误信息取决于客户端库。对于 interbase 驱动程序(问题中包含的错误来自该驱动程序)，此信息已包含(如果有)。

这是一个示例案例，尝试连接到现有服务器以及数据库服务器正在监听但不监听的端口。

  Connection := TSQLConnection.Create(nil);
  Connection.DriverName := 'Interbase';
  Connection.Params.Values['Database'] := 'existingserver/80:database';
  try
    Connection.Open;
  except
    on E: TDBxError do begin
      writeln(E.Message + sLineBreak);

这是输出:

Unable to complete network request to host "existingserver:80".
Failed to establish a connection.

正如您所注意到的，这与问题中的错误消息完全相同。注意文中没有winsock错误。那是因为不存在winsock错误，只要涉​​及网络协议(protocol)，实际上连接是成功的。

这是对现有服务器的尝试，但对非监听端口的尝试。

  Connection := TSQLConnection.Create(nil);
  Connection.DriverName := 'Interbase';
  Connection.Params.Values['Database'] := 'existingserver/81:database';
  try
    Connection.Open;
  except
    on E: TDBxError do begin
      writeln(E.Message + sLineBreak);

这是返回的错误:

Unable to complete network request to host "existingserver:81".
Failed to establish a connection.
unknown Win32 error 10060

这次连接失败，因为没有特定端口的监听器。我不知道为什么客户端库无法解析10060，但这是你的winsock错误。

本地主机、非监听端口的情况:

Unable to complete network request to host "localhost:3051".
Failed to establish a connection.
No connection could be made because the target machine actively refused it.

这里有一个 10061。

当尝试连接到不可解析的主机时，gds32.dll 不会报告任何 api 错误。我不知道该库如何解析主机或为什么它不包含错误代码，但错误消息很详细:

Unable to complete network request to host "nonexistingserver".
Failed to locate host machine.
The specified name was not found in the hosts file or Domain Name Services.

---

如果我们直接使用客户端库，我们只能得到 api 错误。检查以下程序，其中尝试连接到现有服务器和关闭的端口。

program Project1;

{$APPTYPE CONSOLE}

{$R *.res}

uses
  system.sysutils,
  data.dbxcommon,
  data.sqlexpr,
  data.dbxinterbase;

function isc_attach_database(status_vector: PLongint; db_name_length: Smallint;
    db_name: PAnsiChar; db_handle: PPointer; parm_buffer_length: Smallint;
    parm_buffer: PAnsiChar): Longint; stdcall; external 'gds32.dll';

function isc_interprete(buffer: PAnsiChar; var status_vector: Pointer): Longint;
    stdcall; external 'gds32.dll';

var
  Connection: TSQLConnection;

  StatusVector: array[0..19] of Longint;
  Handle: PPointer;
  Error: array[0..255] of AnsiChar;
  IntrStatus: Pointer;
  s: string;
begin
  try
    Connection := TSQLConnection.Create(nil);
    Connection.DriverName := 'Interbase';
    Connection.Params.Values['Database'] := 'server/3051:database'; // closed port
    try
      Connection.Open;
    except
      on E: TDBxError do begin
        writeln(E.Message + sLineBreak);

        if E.ErrorCode = TDBXErrorCodes.ConnectionFailed then begin

          Handle := nil;
          if isc_attach_database(@StatusVector, 0,
                      PAnsiChar(AnsiString(Connection.Params.Values['Database'])),
                      @Handle, 0, nil) <> 0 then begin

            IntrStatus := @StatusVector;
            s := '';
            while isc_interprete(Error, IntrStatus) <> 0 do begin
              s := s + AnsiString(Error) + sLineBreak;
              if PLongint(IntrStatus)^ = 17 then  // isc_arg_win32
                s := s + ' --below is an api error--' + sLineBreak +
                     Format('%d: %s', [PLongint(Longint(IntrStatus) + 4)^,
                     SysErrorMessage(PLongint(Longint(IntrStatus) + 4)^)]) +
                     sLineBreak;
            end;
            Writeln(s);
          end;
        end else
          raise;
      end;
    end;
  except
    on E: Exception do
      Writeln(E.ClassName, ': ', E.Message);
  end;
  readln;
end.

哪些输出:

Unable to complete network request to host "sever:3051".
Failed to establish a connection.
unknown Win32 error 10060

Unable to complete network request to host "server:3051".
Failed to establish a connection.
--below is an api error--
10060: A connection attempt failed because the connected party did not properly
respond after a period of time, or established connection failed because connect
ed host has failed to respond
unknown Win32 error 10060

第一段是 dbx 报告的内容。第二段是我们从'gds32.dll'中得到的内容，包括注入(inject)api错误代码和文本，否则它们是相同的。

以上是一个粗略的演示，为了正确输入，请使用“interbase.h”。有关选择可能的 api 错误的详细信息，请参阅“Parsing the Status Vector”，或一般的“Handling Error Conditions”。

---

无论如何，可以看出，能否获取特定信息完全取决于 dbx 用于连接数据库服务器的客户端库。

对于一般情况，要独立于正在使用的数据库服务器获取 Winsock 错误信息，您可以做的是在尝试打开数据库连接之前尝试将套接字连接到服务器，并且仅当成功关闭时您的测试连接，然后继续附加到数据库。您可以使用任何库或裸 API 来执行此操作。

这是一个简单的例子:

function TestConnect(server: string; port: Integer): Boolean;

  procedure WinsockError(step: string);
  begin
    raise Exception.Create(Format('"%s" fail. %d: %s:',
        [step, WSAGetLastError, SysErrorMessage(WSAGetLastError)]));  
  end;

var
  Error: Integer;
  Data: TWSAData;
  Socket: TSocket;
  SockAddr: TSockAddrIn;
  Host: PHostEnt;
begin
  Result := False;
  Error := WSAStartup(MakeWord(1, 1), Data);
  if Error = 0 then begin
    try
      Socket := winsock.socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
      if Socket <> INVALID_SOCKET then begin
        try
          Host := gethostbyname(PAnsiChar(AnsiString(server)));
          if Host <> nil then begin
            SockAddr.sin_family := AF_INET;
            SockAddr.sin_addr.S_addr := Longint(PLongint(Host^.h_addr_list^)^);
            SockAddr.sin_port := htons(port);
            if connect(Socket, SockAddr,  SizeOf(SockAddr)) <> 0 then
              WinsockError('connect')
            else
              Result := True;
          end else
            WinsockError('gethostbyname');
        finally
          closesocket(Socket);
        end;  
      end else
        WinsockError('socket');
    finally  
      WSACleanup;
    end;  
  end else
    raise Exception.Create('winsock initialization fail');
end;

你可以使用这样的东西:

if TestConnect('server', 3050) then
  //