ViewVC Help
View File | Revision Log | Show Annotations | Download File | View Changeset | Root Listing
root/public/ibx/branches/journaling/fbintf/IBUtils.pas
(Generate patch)

Comparing ibx/trunk/fbintf/IBUtils.pas (file contents):
Revision 142 by tony, Mon Jan 22 13:58:23 2018 UTC vs.
Revision 143 by tony, Fri Feb 23 12:11:21 2018 UTC

# Line 45 | Line 45 | unit IBUtils;
45  
46   interface
47  
48 < uses Classes, SysUtils;
48 > uses Classes, SysUtils, IB;
49  
50   const
51    CRLF = #13 + #10;
# Line 267 | Line 267 | function Space2Underscore(s: AnsiString)
267   function SQLSafeString(const s: AnsiString): AnsiString;
268   function IsSQLIdentifier(Value: AnsiString): boolean;
269   function ExtractConnectString(const CreateSQL: AnsiString; var ConnectString: AnsiString): boolean;
270 + function MakeConnectString(ServerName, DatabaseName: AnsiString; Protocol: TProtocol;
271 +              PortNo: AnsiString = ''): AnsiString;
272 + function ParseConnectString(ConnectString: AnsiString;
273 +              var ServerName, DatabaseName: AnsiString; var Protocol: TProtocolAll;
274 +              var PortNo: AnsiString): boolean;
275 + function GetProtocol(ConnectString: AnsiString): TProtocolAll;
276  
277   implementation
278  
# Line 388 | Line 394 | begin
394      RegexObj.Expression := '^ *CREATE +(DATABASE|SCHEMA) +''(.*)''';
395      Result := RegexObj.Exec(CreateSQL);
396      if Result then
397 <      ConnectString := system.copy(CreateSQL,RegexObj.MatchPos[2],RegexObj.MatchLen[2]);
397 >      ConnectString := RegexObj.Match[2];
398    finally
399      RegexObj.Free;
400    end;
401   end;
402 +
403 + function ParseConnectString(ConnectString: AnsiString; var ServerName,
404 +  DatabaseName: AnsiString; var Protocol: TProtocolAll; var PortNo: AnsiString
405 +  ): boolean;
406 + var RegexObj: TRegExpr;
407 +    scheme: AnsiString;
408 + begin
409 +  ServerName := '';
410 +  DatabaseName := ConnectString;
411 +  PortNo := '';
412 +  Protocol := unknownProtocol;
413 +  RegexObj := TRegExpr.Create;
414 +  try
415 +    {extact database file spec}
416 +    RegexObj.ModifierG := false; {turn off greedy matches}
417 +    RegexObj.Expression := '^([a-zA-Z]+)://([a-zA-Z0-9\-\.]+)(|:[0-9a-zA-Z\-]+)/(.*)$';
418 +    Result := RegexObj.Exec(ConnectString);
419 +    if Result then
420 +    begin
421 +      {URL type connect string}
422 +      scheme := AnsiUpperCase(RegexObj.Match[1]);
423 +      ServerName := RegexObj.Match[2];
424 +      if RegexObj.MatchLen[3] > 0 then
425 +        PortNo := system.Copy(ConnectString,RegexObj.MatchPos[3]+1,RegexObj.MatchLen[3]-1);
426 +      DatabaseName := RegexObj.Match[4];
427 +      if scheme = 'INET' then
428 +        Protocol := inet
429 +      else
430 +      if scheme = 'XNET' then
431 +        Protocol := xnet
432 +      else
433 +      if scheme = 'WNET' then
434 +        Protocol := wnet
435 +    end
436 +    else
437 +    begin
438 +      RegexObj.Expression := '^([a-zA-Z]:\\.*)';
439 +      Result := RegexObj.Exec(ConnectString);
440 +      if Result then
441 +        Protocol := Local {Windows with leading drive ID}
442 +      else
443 +      begin
444 +        RegexObj.Expression := '^([a-zA-Z0-9\-\.]+)(|/[0-9a-zA-Z\-]+):(.*)$';
445 +        Result := RegexObj.Exec(ConnectString);
446 +        if Result then
447 +        begin
448 +          {Legacy TCP Format}
449 +          ServerName := RegexObj.Match[1];
450 +          if RegexObj.MatchLen[2] > 0 then
451 +            PortNo := system.Copy(ConnectString,RegexObj.MatchPos[2]+1,RegexObj.MatchLen[2]-1);
452 +          DatabaseName := RegexObj.Match[3];
453 +          Protocol := TCP;
454 +        end
455 +        else
456 +        begin
457 +          RegexObj.Expression := '^\\\\([a-zA-Z0-9\-\.]+)(|@[0-9a-zA-Z\-]+)\\(.*)$';
458 +          Result := RegexObj.Exec(ConnectString);
459 +          if Result then
460 +          begin
461 +            {Netbui}
462 +            ServerName := RegexObj.Match[1];
463 +            if RegexObj.MatchLen[2] > 0 then
464 +              PortNo := system.Copy(ConnectString,RegexObj.MatchPos[2]+1,RegexObj.MatchLen[2]-1);
465 +            DatabaseName := RegexObj.Match[3];
466 +            Protocol := NamedPipe
467 +          end
468 +          else
469 +          begin
470 +            Result := true;
471 +            Protocol := Local; {Assume local}
472 +          end;
473 +        end;
474 +      end;
475 +    end;
476 +  finally
477 +    RegexObj.Free;
478 +  end;
479 + end;
480 +
481 + function GetProtocol(ConnectString: AnsiString): TProtocolAll;
482 + var ServerName,
483 +    DatabaseName: AnsiString;
484 +    PortNo: AnsiString;
485 + begin
486 +  ParseConnectString(ConnectString,ServerName,DatabaseName,Result,PortNo);
487 + end;
488 +
489   {$ELSE}
490   {cruder version of above for Delphi. Older versions lack regular expression
491   handling.}
# Line 414 | Line 507 | begin
507      end;
508    end;
509   end;
510 +
511 + function GetProtocol(ConnectString: AnsiString): TProtocolAll;
512 + begin
513 +  Result := unknownProtocol; {not implemented for Delphi}
514 + end;
515 +
516 + function ParseConnectString(ConnectString: AnsiString;
517 +              var ServerName, DatabaseName: AnsiString; var Protocol: TProtocolAll;
518 +              var PortNo: AnsiString): boolean;
519 + begin
520 +  Result := false;
521 + end;
522 +
523   {$ENDIF}
524  
525 + {Make a connect string in format appropriate protocol}
526 +
527 + function MakeConnectString(ServerName, DatabaseName: AnsiString;
528 +  Protocol: TProtocol; PortNo: AnsiString): AnsiString;
529 + begin
530 +  if PortNo <> '' then
531 +    case Protocol of
532 +    NamedPipe:
533 +      ServerName := ServerName + '@' + PortNo;
534 +    Local,
535 +    SPX,
536 +    xnet: {do nothing};
537 +    TCP:
538 +      ServerName := ServerName + '/' + PortNo;
539 +    else
540 +      ServerName := ServerName + ':' + PortNo;
541 +    end;
542 +
543 +  case Protocol of
544 +    TCP:        Result := ServerName + ':' + DatabaseName; {do not localize}
545 +    SPX:        Result := ServerName + '@' + DatabaseName; {do not localize}
546 +    NamedPipe:  Result := '\\' + ServerName + '\' + DatabaseName; {do not localize}
547 +    Local:      Result := DatabaseName; {do not localize}
548 +    inet:       Result := 'inet://' + ServerName + '/'+ DatabaseName; {do not localize}
549 +    wnet:       Result := 'wnet://' + ServerName + '/'+ DatabaseName; {do not localize}
550 +    xnet:       Result := 'xnet://' + ServerName + '/'+ DatabaseName;  {do not localize}
551 +  end;
552 + end;
553 +
554   {Format an SQL Identifier according to SQL Dialect with encapsulation if necessary}
555  
556   function QuoteIdentifierIfNeeded(Dialect: Integer; Value: AnsiString): AnsiString;

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines