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

Comparing ibx/trunk/fbintf/IBUtils.pas (file contents):
Revision 121 by tony, Mon Jan 22 13:58:23 2018 UTC vs.
Revision 231 by tony, Mon Apr 16 08:32: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 54 | 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 146 | Line 146 | const
146    'INTO',
147    'IS',
148    'JOIN',
149 +  'KEY',
150    'LEADING',
151    'LEFT',
152    'LIKE',
# Line 267 | 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 388 | 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 +
408 +  function GetProtocol(scheme: AnsiString): TProtocolAll;
409 +  begin
410 +    scheme := AnsiUpperCase(scheme);
411 +    if scheme = 'INET' then
412 +      Result := inet
413 +    else
414 +    if scheme = 'INET4' then
415 +      Result := inet4
416 +    else
417 +    if scheme = 'INET6' then
418 +      Result := inet6
419 +    else
420 +    if scheme = 'XNET' then
421 +      Result := xnet
422 +    else
423 +    if scheme = 'WNET' then
424 +      Result := wnet
425 +  end;
426 +
427 + var RegexObj: TRegExpr;
428 + begin
429 +  ServerName := '';
430 +  DatabaseName := ConnectString;
431 +  PortNo := '';
432 +  Protocol := unknownProtocol;
433 +  RegexObj := TRegExpr.Create;
434 +  try
435 +    {extact database file spec}
436 +    RegexObj.ModifierG := false; {turn off greedy matches}
437 +    RegexObj.Expression := '^([a-zA-Z46]+)://([a-zA-Z0-9\-\.]*)(|:[0-9a-zA-Z\-]+)/(.*)$';
438 +    Result := RegexObj.Exec(ConnectString);
439 +    if Result then
440 +    begin
441 +      {URL type connect string}
442 +      Protocol := GetProtocol(RegexObj.Match[1]);
443 +      ServerName := RegexObj.Match[2];
444 +      if RegexObj.MatchLen[3] > 0 then
445 +        PortNo := system.Copy(ConnectString,RegexObj.MatchPos[3]+1,RegexObj.MatchLen[3]-1);
446 +      DatabaseName := RegexObj.Match[4];
447 +      if ServerName = '' then
448 +        DatabaseName := '/' + DatabaseName;
449 +    end
450 +    else
451 +    begin
452 +      {URL type connect string - local loop}
453 +      RegexObj.Expression := '^([a-zA-Z46]+)://(.*)$';
454 +      Result := RegexObj.Exec(ConnectString);
455 +      if Result then
456 +      begin
457 +        Protocol := GetProtocol(RegexObj.Match[1]);
458 +        DatabaseName := RegexObj.Match[2];
459 +      end
460 +      else
461 +      begin
462 +        RegexObj.Expression := '^([a-zA-Z]:\\.*)';
463 +        Result := RegexObj.Exec(ConnectString);
464 +        if Result then
465 +          Protocol := Local {Windows with leading drive ID}
466 +        else
467 +        begin
468 +          RegexObj.Expression := '^([a-zA-Z0-9\-\.]+)(|/[0-9a-zA-Z\-]+):(.*)$';
469 +          Result := RegexObj.Exec(ConnectString);
470 +          if Result then
471 +          begin
472 +            {Legacy TCP Format}
473 +            ServerName := RegexObj.Match[1];
474 +            if RegexObj.MatchLen[2] > 0 then
475 +              PortNo := system.Copy(ConnectString,RegexObj.MatchPos[2]+1,RegexObj.MatchLen[2]-1);
476 +            DatabaseName := RegexObj.Match[3];
477 +            Protocol := TCP;
478 +          end
479 +          else
480 +          begin
481 +            RegexObj.Expression := '^\\\\([a-zA-Z0-9\-\.]+)(|@[0-9a-zA-Z\-]+)\\(.*)$';
482 +            Result := RegexObj.Exec(ConnectString);
483 +            if Result then
484 +            begin
485 +              {Netbui}
486 +              ServerName := RegexObj.Match[1];
487 +              if RegexObj.MatchLen[2] > 0 then
488 +                PortNo := system.Copy(ConnectString,RegexObj.MatchPos[2]+1,RegexObj.MatchLen[2]-1);
489 +              DatabaseName := RegexObj.Match[3];
490 +              Protocol := NamedPipe
491 +            end
492 +            else
493 +            begin
494 +              Result := true;
495 +              Protocol := Local; {Assume local}
496 +            end;
497 +          end;
498 +        end;
499 +      end;
500 +    end;
501 +  finally
502 +    RegexObj.Free;
503 +  end;
504 + end;
505 +
506 + function GetProtocol(ConnectString: AnsiString): TProtocolAll;
507 + var ServerName,
508 +    DatabaseName: AnsiString;
509 +    PortNo: AnsiString;
510 + begin
511 +  ParseConnectString(ConnectString,ServerName,DatabaseName,Result,PortNo);
512 + end;
513 +
514   {$ELSE}
515   {cruder version of above for Delphi. Older versions lack regular expression
516   handling.}
# Line 414 | Line 532 | begin
532      end;
533    end;
534   end;
535 +
536 + function GetProtocol(ConnectString: AnsiString): TProtocolAll;
537 + begin
538 +  Result := unknownProtocol; {not implemented for Delphi}
539 + end;
540 +
541 + function ParseConnectString(ConnectString: AnsiString;
542 +              var ServerName, DatabaseName: AnsiString; var Protocol: TProtocolAll;
543 +              var PortNo: AnsiString): boolean;
544 + begin
545 +  Result := false;
546 + end;
547 +
548   {$ENDIF}
549  
550 + {Make a connect string in format appropriate protocol}
551 +
552 + function MakeConnectString(ServerName, DatabaseName: AnsiString;
553 +  Protocol: TProtocol; PortNo: AnsiString): AnsiString;
554 +
555 +  function FormatURL: AnsiString;
556 +  begin
557 +    if (ServerName = '') and (Pos('/',DatabaseName) <= 1) then
558 +      Result := DatabaseName
559 +    else
560 +      Result := ServerName + '/' + DatabaseName;
561 +  end;
562 +
563 + begin
564 +  if PortNo <> '' then
565 +    case Protocol of
566 +    NamedPipe:
567 +      ServerName := ServerName + '@' + PortNo;
568 +    Local,
569 +    SPX,
570 +    xnet: {do nothing};
571 +    TCP:
572 +      ServerName := ServerName + '/' + PortNo;
573 +    else
574 +      ServerName := ServerName + ':' + PortNo;
575 +    end;
576 +
577 +  case Protocol of
578 +    TCP:        Result := ServerName + ':' + DatabaseName; {do not localize}
579 +    SPX:        Result := ServerName + '@' + DatabaseName; {do not localize}
580 +    NamedPipe:  Result := '\\' + ServerName + '\' + DatabaseName; {do not localize}
581 +    Local:      Result := DatabaseName; {do not localize}
582 +    inet:       Result := 'inet://' + FormatURL; {do not localize}
583 +    inet4:       Result := 'inet4://' + FormatURL; {do not localize}
584 +    inet6:       Result := 'inet6://' + FormatURL; {do not localize}
585 +    wnet:       Result := 'wnet://' + FormatURL; {do not localize}
586 +    xnet:       Result := 'xnet://' + FormatURL;  {do not localize}
587 +  end;
588 + end;
589 +
590   {Format an SQL Identifier according to SQL Dialect with encapsulation if necessary}
591  
592   function QuoteIdentifierIfNeeded(Dialect: Integer; Value: AnsiString): AnsiString;

Diff Legend

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