Changeset 362 for PersistentData/Backend/UPDClientMemory.pas

Timestamp:

May 10, 2012, 1:18:25 PM (12 years ago)

Author:

chronos

Message:

• Modified: PersistentData Memory backend partial implementation.
• Modified: Some persistent type system modifications.

File:

• PersistentData/Backend/UPDClientMemory.pas (modified) (3 diffs)

PersistentData/Backend/UPDClientMemory.pas

@@ -14 +14 @@
   TPDClientMemory = class(TPDClient)
   protected
+    FLastObjectId: Integer;
     procedure InitSystemTypes; override;
     function GetConnected: Boolean; override;
     procedure Init; override;
+    function GetNewObjectId: Integer;
+    function SearchObject(Id: Integer): TObjectProxy;
   public
     Objects: TListObject;
@@ -35 +38 @@
   end;
 
+resourcestring
+  SObjectNotFound = 'Object with id %s not found';
+
 implementation
 
@@ -54 +60 @@
 end;
 
+function TPDClientMemory.GetNewObjectId: Integer;
+begin
+  Inc(FLastObjectId);
+  Result := FLastObjectId;
+end;
+
+function TPDClientMemory.SearchObject(Id: Integer): TObjectProxy;
+var
+  I: Integer;
+begin
+  I := 0;
+  while (I < Objects.Count) and
+    (TObjectProxy(Objects[I]).Id <> Id) do Inc(I);
+  if I < Objects.Count then Result := TObjectProxy(Objects[I])
+    else Result := nil;
+end;
+
 procedure TPDClientMemory.ObjectLoad(AObject: TObjectProxy);
-begin
-
+var
+  Obj: TObjectProxy;
+begin
+  if AObject.Id = 0 then raise Exception.Create(SCantLoadObjectWithoutId);
+  Obj := SearchObject(AObject.Id);
+  if Assigned(Obj) then AObject.Assign(Obj)
+    else raise Exception.CreateFmt(SObjectNotFound, [AObject.Id]);
 end;
 
 procedure TPDClientMemory.ObjectSave(AObject: TObjectProxy);
-begin
-
+var
+  I: Integer;
+  Obj: TObjectProxy;
+begin
+  if AObject.Id = 0 then raise Exception.Create(SCantLoadObjectWithoutId);
+  Obj := SearchObject(AObject.Id);
+  if Assigned(Obj) then Obj.Assign(AObject)
+    else begin
+      AObject.Id := GetNewObjectId;
+      Obj := TObjectProxy(Objects.AddNew(TObjectProxy.Create));
+      Obj.Assign(AObject);
+    end;
 end;
 
 procedure TPDClientMemory.ObjectDelete(AObject: TObjectProxy);
-begin
-
+var
+  Obj: TObjectProxy;
+begin
+  Obj := SearchObject(AObject.Id);
+  if Assigned(Obj) then Objects.Delete(Objects.IndexOf(Obj))
+    else raise Exception.CreateFmt(SObjectNotFound, [AObject.Id])
 end;
 
 procedure TPDClientMemory.ListLoad(AList: TListProxy);
-begin
-
+var
+  Filter: string;
+  DbCondition: string;
+  I: Integer;
+  P: Integer;
+  NewObject: TObjectProxy;
+  Table: string;
+begin
+  AList.Objects.Clear;
+  for I := 0 to Objects.Count - 1 do
+  with TObjectProxy(Objects[I]) do begin
+    if 1 = 1 then begin
+      NewObject := TObjectProxy.Create;
+      NewObject.Properties.Assign(Properties);
+      NewObject.Client := AList.Client;
+      NewObject.ObjectName := AList.ObjectName;
+      NewObject.Path := AList.Path;
+      AList.Objects.Add(NewObject);
+
+      if AList.ColummsFilterUse then begin
+        for P := 0 to Properties.Count - 1 do
+        if AList.ColumnsFilter.IndexOf(Properties.Keys[I]) <> -1 then
+          NewObject.Properties.Add(Properties.Keys[I], Properties[I].Value);
+      end else NewObject.Properties.Assign(Properties);
+    end;
+  end;
+  if AList.OrderUse then begin
+
+  end;
+  if AList.PageUse then begin
+  end;
 end;