* Implemented Port property (bug 10533)

git-svn-id: trunk@10344 -

packages/fcl-db/src/sqldb/mysql/mysqlconn.inc

@@ -134,6 +134,7 @@ Type
     property KeepConnection;
     property LoginPrompt;
     property Params;
+    property Port stored false;
     property OnLogin;
   end;
 
@@ -213,12 +214,12 @@ end;
 procedure TConnectionName.ConnectMySQL(var HMySQL : PMySQL;H,U,P : pchar);
 
 Var
-  Port : Cardinal;
+  APort : Cardinal;
 
 begin
   HMySQL := mysql_init(HMySQL);
-  Port:=Abs(StrToIntDef(Params.Values['Port'],0));
-  HMySQL:=mysql_real_connect(HMySQL,PChar(H),PChar(U),Pchar(P),Nil,Port,Nil,0);
+  APort:=Abs(StrToIntDef(Params.Values['Port'],0));
+  HMySQL:=mysql_real_connect(HMySQL,PChar(H),PChar(U),Pchar(P),Nil,APort,Nil,0);
   If (HMySQL=Nil) then
     MySQlError(Nil,SErrServerConnectFailed,Self);
 end;

packages/fcl-db/src/sqldb/sqldb.pp

@@ -85,7 +85,9 @@ type
     FHostName            : string;
     FCharSet             : string;
     FRole                : String;
-
+    
+    function GetPort: cardinal;
+    procedure Setport(const AValue: cardinal);
   protected
     FConnOptions         : TConnOptions;
     procedure GetDBInfo(const SchemaType : TSchemaType; const SchemaObjectName, ReturnField : string; List: TStrings);
@@ -119,6 +121,7 @@ type
     function GetSchemaInfoSQL(SchemaType : TSchemaType; SchemaObjectName, SchemaPattern : string) : string; virtual;
     procedure LoadBlobIntoBuffer(FieldDef: TFieldDef;ABlobBuf: PBufBlobField; cursor: TSQLCursor; ATransaction : TSQLTransaction); virtual; abstract;
     function RowsAffected(cursor: TSQLCursor): TRowsCount; virtual;
+    property port: cardinal read GetPort write Setport;
   public
     property Handle: Pointer read GetHandle;
     destructor Destroy; override;
@@ -543,6 +546,19 @@ begin
   end;
 end;
 
+function TSQLConnection.GetPort: cardinal;
+begin
+  result := StrToIntDef(Params.Values['Port'],0);
+end;
+
+procedure TSQLConnection.Setport(const AValue: cardinal);
+begin
+  if AValue<>0 then
+    params.Values['Port']:=IntToStr(AValue)
+  else with params do if IndexOfName('Port') > -1 then
+    Delete(IndexOfName('Port'));
+end;
+
 procedure TSQLConnection.GetDBInfo(const SchemaType : TSchemaType; const SchemaObjectName, ReturnField : string; List: TStrings);
 
 var qry : TCustomSQLQuery;