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 209 by tony, Wed Mar 14 12:48:51 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 52 | 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 144 | Line 146 | const
146    'INTO',
147    'IS',
148    'JOIN',
149 +  'KEY',
150    'LEADING',
151    'LEFT',
152    'LIKE',
# Line 265 | 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  
280 + {$IFDEF HASREQEX}
281   uses RegExpr;
282 + {$ENDIF}
283  
284   function Max(n1, n2: Integer): Integer;
285   begin
# Line 371 | Line 382 | end;
382  
383   {Extracts the Database Connect string from a Create Database Statement}
384  
385 + {$IFDEF HASREQEX}
386   function ExtractConnectString(const CreateSQL: AnsiString;
387    var ConnectString: AnsiString): boolean;
388   var RegexObj: TRegExpr;
# Line 383 | 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 Delphi. Older versions lack regular expression
492 + handling.}
493 + function ExtractConnectString(const CreateSQL: AnsiString;
494 +  var ConnectString: AnsiString): boolean;
495 + var i: integer;
496 + begin
497 +  Result := false;
498 +  i := Pos('''',CreateSQL);
499 +  if i > 0 then
500 +  begin
501 +    ConnectString := CreateSQL;
502 +    delete(ConnectString,1,i);
503 +    i := Pos('''',ConnectString);
504 +    if i > 0 then
505 +    begin
506 +      delete(ConnectString,i,Length(ConnectString)-i+1);
507 +      Result := true;
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