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 117 by tony, Mon Jan 22 13:58:11 2018 UTC vs.
Revision 143 by tony, Fri Feb 23 12:11:21 2018 UTC

# Line 33 | Line 33
33  
34   unit IBUtils;
35   {$IFDEF MSWINDOWS}
36 < {$DEFINE WINDOWS}
36 > {$DEFINE WINDOWS}
37   {$ENDIF}
38  
39   {$IFDEF FPC}
40   {$Mode Delphi}
41   {$codepage UTF8}
42 + {$define HASREQEX}
43   {$ENDIF}
44  
45 +
46   interface
47  
48 < uses Classes, SysUtils;
48 > uses Classes, SysUtils, IB;
49  
50   const
51    CRLF = #13 + #10;
# Line 265 | 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  
279 + {$IFDEF HASREQEX}
280   uses RegExpr;
281 + {$ENDIF}
282  
283   function Max(n1, n2: Integer): Integer;
284   begin
# Line 371 | Line 381 | end;
381  
382   {Extracts the Database Connect string from a Create Database Statement}
383  
384 + {$IFDEF HASREQEX}
385   function ExtractConnectString(const CreateSQL: AnsiString;
386    var ConnectString: AnsiString): boolean;
387   var RegexObj: TRegExpr;
# Line 383 | 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.}
492 + function ExtractConnectString(const CreateSQL: AnsiString;
493 +  var ConnectString: AnsiString): boolean;
494 + var i: integer;
495 + begin
496 +  Result := false;
497 +  i := Pos('''',CreateSQL);
498 +  if i > 0 then
499 +  begin
500 +    ConnectString := CreateSQL;
501 +    delete(ConnectString,1,i);
502 +    i := Pos('''',ConnectString);
503 +    if i > 0 then
504 +    begin
505 +      delete(ConnectString,i,Length(ConnectString)-i+1);
506 +      Result := true;
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