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 119 by tony, Mon Jan 22 13:58:18 2018 UTC vs.
Revision 209 by tony, Wed Mar 14 12:48:51 2018 UTC

# Line 34 | Line 34
34   unit IBUtils;
35   {$IFDEF MSWINDOWS}
36   {$DEFINE WINDOWS}
37 – {$IF defined(CompilerVersion) and (CompilerVersion >= 28)}
38 – {Delphi XE7 onwards}}
39 – {$define HASREQEX}
40 – {$IFEND}
37   {$ENDIF}
38  
39   {$IFDEF FPC}
# Line 49 | 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 58 | Line 54 | const
54    TAB  = #9;
55    NULL_TERMINATOR = #0;
56  
57 <  sqlReservedWords: array [0..197] of string = (
57 >  sqlReservedWords: array [0..198] of string = (
58    'ADD',
59    'ADMIN',
60    'ALL',
# Line 150 | Line 146 | const
146    'INTO',
147    'IS',
148    'JOIN',
149 +  'KEY',
150    'LEADING',
151    'LEFT',
152    'LIKE',
# Line 271 | Line 268 | function Space2Underscore(s: AnsiString)
268   function SQLSafeString(const s: AnsiString): AnsiString;
269   function IsSQLIdentifier(Value: AnsiString): boolean;
270   function ExtractConnectString(const CreateSQL: AnsiString; var ConnectString: AnsiString): boolean;
271 + function MakeConnectString(ServerName, DatabaseName: AnsiString; Protocol: TProtocol;
272 +              PortNo: AnsiString = ''): AnsiString;
273 + function ParseConnectString(ConnectString: AnsiString;
274 +              var ServerName, DatabaseName: AnsiString; var Protocol: TProtocolAll;
275 +              var PortNo: AnsiString): boolean;
276 + function GetProtocol(ConnectString: AnsiString): TProtocolAll;
277  
278   implementation
279  
# Line 392 | Line 395 | begin
395      RegexObj.Expression := '^ *CREATE +(DATABASE|SCHEMA) +''(.*)''';
396      Result := RegexObj.Exec(CreateSQL);
397      if Result then
398 <      ConnectString := system.copy(CreateSQL,RegexObj.MatchPos[2],RegexObj.MatchLen[2]);
398 >      ConnectString := RegexObj.Match[2];
399    finally
400      RegexObj.Free;
401    end;
402   end;
403 +
404 + function ParseConnectString(ConnectString: AnsiString; var ServerName,
405 +  DatabaseName: AnsiString; var Protocol: TProtocolAll; var PortNo: AnsiString
406 +  ): boolean;
407 + var RegexObj: TRegExpr;
408 +    scheme: AnsiString;
409 + begin
410 +  ServerName := '';
411 +  DatabaseName := ConnectString;
412 +  PortNo := '';
413 +  Protocol := unknownProtocol;
414 +  RegexObj := TRegExpr.Create;
415 +  try
416 +    {extact database file spec}
417 +    RegexObj.ModifierG := false; {turn off greedy matches}
418 +    RegexObj.Expression := '^([a-zA-Z]+)://([a-zA-Z0-9\-\.]+)(|:[0-9a-zA-Z\-]+)/(.*)$';
419 +    Result := RegexObj.Exec(ConnectString);
420 +    if Result then
421 +    begin
422 +      {URL type connect string}
423 +      scheme := AnsiUpperCase(RegexObj.Match[1]);
424 +      ServerName := RegexObj.Match[2];
425 +      if RegexObj.MatchLen[3] > 0 then
426 +        PortNo := system.Copy(ConnectString,RegexObj.MatchPos[3]+1,RegexObj.MatchLen[3]-1);
427 +      DatabaseName := RegexObj.Match[4];
428 +      if scheme = 'INET' then
429 +        Protocol := inet
430 +      else
431 +      if scheme = 'XNET' then
432 +        Protocol := xnet
433 +      else
434 +      if scheme = 'WNET' then
435 +        Protocol := wnet
436 +    end
437 +    else
438 +    begin
439 +      RegexObj.Expression := '^([a-zA-Z]:\\.*)';
440 +      Result := RegexObj.Exec(ConnectString);
441 +      if Result then
442 +        Protocol := Local {Windows with leading drive ID}
443 +      else
444 +      begin
445 +        RegexObj.Expression := '^([a-zA-Z0-9\-\.]+)(|/[0-9a-zA-Z\-]+):(.*)$';
446 +        Result := RegexObj.Exec(ConnectString);
447 +        if Result then
448 +        begin
449 +          {Legacy TCP Format}
450 +          ServerName := RegexObj.Match[1];
451 +          if RegexObj.MatchLen[2] > 0 then
452 +            PortNo := system.Copy(ConnectString,RegexObj.MatchPos[2]+1,RegexObj.MatchLen[2]-1);
453 +          DatabaseName := RegexObj.Match[3];
454 +          Protocol := TCP;
455 +        end
456 +        else
457 +        begin
458 +          RegexObj.Expression := '^\\\\([a-zA-Z0-9\-\.]+)(|@[0-9a-zA-Z\-]+)\\(.*)$';
459 +          Result := RegexObj.Exec(ConnectString);
460 +          if Result then
461 +          begin
462 +            {Netbui}
463 +            ServerName := RegexObj.Match[1];
464 +            if RegexObj.MatchLen[2] > 0 then
465 +              PortNo := system.Copy(ConnectString,RegexObj.MatchPos[2]+1,RegexObj.MatchLen[2]-1);
466 +            DatabaseName := RegexObj.Match[3];
467 +            Protocol := NamedPipe
468 +          end
469 +          else
470 +          begin
471 +            Result := true;
472 +            Protocol := Local; {Assume local}
473 +          end;
474 +        end;
475 +      end;
476 +    end;
477 +  finally
478 +    RegexObj.Free;
479 +  end;
480 + end;
481 +
482 + function GetProtocol(ConnectString: AnsiString): TProtocolAll;
483 + var ServerName,
484 +    DatabaseName: AnsiString;
485 +    PortNo: AnsiString;
486 + begin
487 +  ParseConnectString(ConnectString,ServerName,DatabaseName,Result,PortNo);
488 + end;
489 +
490   {$ELSE}
491 < {cruder version of above for old versions of Delphi}
491 > {cruder version of above for Delphi. Older versions lack regular expression
492 > handling.}
493   function ExtractConnectString(const CreateSQL: AnsiString;
494    var ConnectString: AnsiString): boolean;
495   var i: integer;
# Line 417 | Line 508 | begin
508      end;
509    end;
510   end;
511 +
512 + function GetProtocol(ConnectString: AnsiString): TProtocolAll;
513 + begin
514 +  Result := unknownProtocol; {not implemented for Delphi}
515 + end;
516 +
517 + function ParseConnectString(ConnectString: AnsiString;
518 +              var ServerName, DatabaseName: AnsiString; var Protocol: TProtocolAll;
519 +              var PortNo: AnsiString): boolean;
520 + begin
521 +  Result := false;
522 + end;
523 +
524   {$ENDIF}
525  
526 + {Make a connect string in format appropriate protocol}
527 +
528 + function MakeConnectString(ServerName, DatabaseName: AnsiString;
529 +  Protocol: TProtocol; PortNo: AnsiString): AnsiString;
530 + begin
531 +  if PortNo <> '' then
532 +    case Protocol of
533 +    NamedPipe:
534 +      ServerName := ServerName + '@' + PortNo;
535 +    Local,
536 +    SPX,
537 +    xnet: {do nothing};
538 +    TCP:
539 +      ServerName := ServerName + '/' + PortNo;
540 +    else
541 +      ServerName := ServerName + ':' + PortNo;
542 +    end;
543 +
544 +  case Protocol of
545 +    TCP:        Result := ServerName + ':' + DatabaseName; {do not localize}
546 +    SPX:        Result := ServerName + '@' + DatabaseName; {do not localize}
547 +    NamedPipe:  Result := '\\' + ServerName + '\' + DatabaseName; {do not localize}
548 +    Local:      Result := DatabaseName; {do not localize}
549 +    inet:       Result := 'inet://' + ServerName + '/'+ DatabaseName; {do not localize}
550 +    wnet:       Result := 'wnet://' + ServerName + '/'+ DatabaseName; {do not localize}
551 +    xnet:       Result := 'xnet://' + ServerName + '/'+ DatabaseName;  {do not localize}
552 +  end;
553 + end;
554 +
555   {Format an SQL Identifier according to SQL Dialect with encapsulation if necessary}
556  
557   function QuoteIdentifierIfNeeded(Dialect: Integer; Value: AnsiString): AnsiString;

Diff Legend

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