Changeset 43 for trunk/Application/UChronisClient.pas

Timestamp:

Mar 9, 2012, 1:09:52 PM (13 years ago)

Author:

chronos

Message:

• Fixed: Selection of available protocols in profile manager.
• Modified: Initialization of persistent data structures rewrited to more native structures.

File:

• trunk/Application/UChronisClient.pas (modified) (8 diffs)

trunk/Application/UChronisClient.pas

@@ -9 +9 @@
 
 type
+  EClientNotSet = class(Exception);
+
   TChronisClient = class;
 
@@ -52 +54 @@
   end;
 
+  { TChronisType }
+
   TChronisType = class
-    OID: Integer;
+    Client: TChronisClient;
     Name: string;
-  end;
-
-  TChronisTypeRecordItem = class
-    Name: string;
-    ItemType: TChronisType;
-  end;
-
-  { TChronisTypeRecord }
-
-  TChronisTypeRecord = class(TChronisType)
-    Items: TListObject; // TListObject<TChronisTypeRecordItem>
+    DbType: string;
+    Properties: TDictionaryStringString;
+    procedure Define;
+    procedure Undefine;
     constructor Create;
     destructor Destroy; override;
   end;
 
+  { TChronisTypeList }
+
+  TChronisTypeList = class(TListObject)
+    Client: TChronisClient;
+    function AddType(Name: string; DbType: string = ''): TChronisType;
+    function SearchByName(Name: string): TChronisType;
+  end;
+
   { TChronisClient }
 
   TChronisClient = class
+  private
   protected
+    procedure InitSystemTypes; virtual;
     function GetConnected: Boolean; virtual;
   public
@@ -81 +88 @@
     User: string;
     Password: string;
+    Types: TChronisTypeList;
     procedure ObjectLoad(AObject: TObjectProxy); virtual; abstract;
     procedure ObjectSave(AObject: TObjectProxy); virtual; abstract;
@@ -87 +95 @@
     procedure ListLoad(AList: TListProxy); virtual; abstract;
     procedure ListSave(AList: TListProxy); virtual; abstract;
-    procedure DefineType(AType: TChronisType); virtual; abstract;
-    procedure UndefineType(AType: TChronisType); virtual; abstract;
+    procedure TypeDefine(AType: TChronisType); virtual; abstract;
+    procedure TypeUndefine(AType: TChronisType); virtual; abstract;
+    procedure CheckTypes;
     constructor Create; virtual;
+    destructor Destroy; override;
     procedure Connect; virtual; abstract;
     procedure Disconnect; virtual; abstract;
@@ -95 +105 @@
   end;
 
+
 implementation
 
-{ TChronisTypeRecord }
-
-constructor TChronisTypeRecord.Create;
-begin
-  Items := TListObject.Create;
-end;
-
-destructor TChronisTypeRecord.Destroy;
-begin
-  Items.Free;
+resourcestring
+  SClientNotSet = 'Client not set';
+
+{ TChronisTypeList }
+
+function TChronisTypeList.AddType(Name: string; DbType: string = ''): TChronisType;
+begin
+  Result := TChronisType(AddNew(TChronisType.Create));
+  Result.Client := Client;
+  Result.Name := Name;
+  Result.DbType := DbType;
+end;
+
+function TChronisTypeList.SearchByName(Name: string): TChronisType;
+var
+  I: Integer;
+begin
+  I := 0;
+  while (I < Count) and (TChronisType(Items[I]).Name <> Name) do Inc(I);
+  if I < Count then Result := TChronisType(Items[I])
+    else Result := nil;
+end;
+
+procedure TChronisType.Define;
+begin
+  if Assigned(Client) then Client.TypeDefine(Self)
+    else raise EClientNotSet.Create(SClientNotSet);
+end;
+
+procedure TChronisType.Undefine;
+begin
+  if Assigned(Client) then Client.TypeUndefine(Self)
+    else raise EClientNotSet.Create(SClientNotSet);
+end;
+
+constructor TChronisType.Create;
+begin
+  Properties := TDictionaryStringString.Create;
+end;
+
+destructor TChronisType.Destroy;
+begin
+  Properties.Free;
   inherited Destroy;
 end;
@@ -114 +158 @@
 procedure TObjectProxy.Load;
 begin
-  Client.ObjectLoad(Self);
+  if Assigned(Client) then Client.ObjectLoad(Self)
+    else raise EClientNotSet.Create(SClientNotSet);
 end;
 
 procedure TObjectProxy.Save;
 begin
-  Client.ObjectSave(Self);
+  if Assigned(Client) then Client.ObjectSave(Self)
+    else raise EClientNotSet.Create(SClientNotSet);
 end;
 
 procedure TObjectProxy.Delete;
 begin
-  Client.ObjectDelete(Self);
+  if Assigned(Client) then Client.ObjectDelete(Self)
+    else raise EClientNotSet.Create(SClientNotSet);
 end;
 
 procedure TObjectProxy.Add;
 begin
-  Client.ObjectAdd(Self);
+  if Assigned(Client) then Client.ObjectAdd(Self)
+    else raise EClientNotSet.Create(SClientNotSet);
 end;
 
@@ -168 +216 @@
 procedure TListProxy.Load;
 begin
-  Client.ListLoad(Self);
+  if Assigned(Client) then Client.ListLoad(Self)
+    else raise EClientNotSet.Create(SClientNotSet);
 end;
 
 procedure TListProxy.Save;
 begin
-  Client.ListSave(Self);
+  if Assigned(Client) then Client.ListSave(Self)
+    else raise EClientNotSet.Create(SClientNotSet);
 end;
 
 { TChronisClient }
 
+procedure TChronisClient.InitSystemTypes;
+begin
+end;
+
 function TChronisClient.GetConnected: Boolean;
 begin
@@ -183 +237 @@
 end;
 
+procedure TChronisClient.CheckTypes;
+var
+  StructureVersion: string;
+  Data: TDictionaryStringString;
+  ObjectId: Integer;
+  Tables: TListString;
+  I: Integer;
+  NewProxy: TListProxy;
+begin
+  try
+    Tables := TListString.Create;
+    Data := TDictionaryStringString.Create;
+
+    NewProxy := TListProxy.Create;
+    NewProxy.Client := Self;
+    NewProxy.SchemaName := 'information_schema';
+    NewProxy.ObjectName := 'TABLES';
+    NewProxy.Condition := 'TABLE_SCHEMA = "' + Schema + '"';
+    NewProxy.Load;
+    //Database.Query(DbRows, 'SHOW TABLES');
+    Tables.Count := NewProxy.Objects.Count;
+    for I := 0 to NewProxy.Objects.Count - 1 do
+      Tables[I] := TObjectProxy(NewProxy.Objects[I]).Properties.Values['TABLE_NAME'];
+
+    for I := 0 to Types.Count - 1 do
+    with TChronisType(Types[I]) do begin
+      if (DbType = '') and (Tables.IndexOf(Name) = -1) then begin
+        Define;
+      end;
+    end;
+  finally
+    NewProxy.Free;
+    Data.Free;
+    Tables.Free;
+  end;
+end;
+
 constructor TChronisClient.Create;
 begin
+  Types := TChronisTypeList.Create;
+  Types.Client := Self;
+  InitSystemTypes;
+end;
+
+destructor TChronisClient.Destroy;
+begin
+  Types.Free;
+  inherited Destroy;
 end;