Changeset 362 for PersistentData/Backend

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.

Location:

PersistentData/Backend

Files:

• UPDClientMemory.pas (modified) (3 diffs)
• UPDClientMySQL.pas (modified) (2 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;
 

PersistentData/Backend/UPDClientMySQL.pas

@@ -50 +50 @@
 resourcestring
   SMissingBaseType = 'Missing base typ for %s';
-  SUndefinedType = 'Undefinned type %s';
-  SCantLoadObjectWithoutId = 'Can''t load object without id';
+  SUndefinedType = 'Undefined type in %0:s.%1:s';
 
 
@@ -172 +171 @@
     for I := 0 to AType.Properties.Count - 1 do
     with AType.Properties do begin
-      RefType := Types.SearchByName(Items[I].Value);
+      RefType := TPDTypeProperty(Items[I]).DbType;
       if not Assigned(RefType) then
-        raise Exception.Create(Format(SUndefinedType, [Items[I].Value]));
+        raise Exception.Create(Format(SUndefinedType, [AType.Name, TPDTypeProperty(Items[I]).Name]));
       if RefType.DbType = '' then
         raise Exception.Create(Format(SMissingBaseType, [RefType.Name]));
 
-      Query := Query + '`' + Items[I].Key + '` ' + RefType.DbType + ' NULL,';
+      Query := Query + '`' + TPDTypeProperty(Items[I]).Name + '` ' + RefType.DbType + ' NULL,';
     end;
     Query := Query + 'PRIMARY KEY (`Id`)' +