Changeset 43 for trunk/Application/Clients/UChronisClientMySQL.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/Clients/UChronisClientMySQL.pas (modified) (5 diffs)

trunk/Application/Clients/UChronisClientMySQL.pas

@@ -14 +14 @@
   TChronisClientMySQL = class(TChronisClient)
   protected
+    procedure InitSystemTypes; override;
     function GetConnected: Boolean; override;
   public
@@ -23 +24 @@
     procedure ListLoad(AList: TListProxy); override;
     procedure ListSave(AList: TListProxy); override;
-    procedure DefineType(AType: TChronisType); override;
-    procedure UndefineType(AType: TChronisType); override;
+    procedure TypeDefine(AType: TChronisType); override;
+    procedure TypeUndefine(AType: TChronisType); override;
     procedure Install;
     procedure Uninstall;
@@ -35 +36 @@
 implementation
 
+
+resourcestring
+  SMissingBaseType = 'Missing base typ for %s';
+  SUndefinedType = 'Undefinned type %s';
+
+
 { TChronisClientMySQL }
+
+procedure TChronisClientMySQL.InitSystemTypes;
+begin
+  inherited InitSystemTypes;
+  Types.AddType('Integer', 'int(11)');
+  Types.AddType('String', 'varchar(255)');
+  Types.AddType('RelationOne', 'int(11)');
+  Types.AddType('Double', 'double');
+  Types.AddType('DateTime', 'datetime');
+  Types.AddType('Date', 'date');
+  Types.AddType('Time', 'time');
+  Types.AddType('Text', 'text');
+  Types.AddType('Boolean', 'bool');
+end;
 
 function TChronisClientMySQL.GetConnected: Boolean;
@@ -103 +124 @@
 end;
 
-procedure TChronisClientMySQL.DefineType(AType: TChronisType);
+procedure TChronisClientMySQL.TypeDefine(AType: TChronisType);
 var
-  Data: TDictionaryStringString;
+  DbRows: TDbRows;
   I: Integer;
+  Query: string;
+  RefType: TChronisType;
 begin
   try
-    Data := TDictionaryStringString.Create;
-    Data.Add('Name', AType.Name);
-    Database.Insert('Type', Data);
+    DbRows := TDbRows.Create;
+    Query := 'CREATE TABLE IF NOT EXISTS `' + AType.Name + '` ( ' +
+      '`Id` int(11) NOT NULL AUTO_INCREMENT,';
+    for I := 0 to AType.Properties.Count - 1 do
+    with AType.Properties do begin
+      RefType := Types.SearchByName(Items[I].Value);
+      if not Assigned(RefType) then
+        raise Exception.Create(Format(SUndefinedType, [Items[I].Value]));
+      if RefType.DbType = '' then
+        raise Exception.Create(Format(SMissingBaseType, [RefType.Name]));
+
+      Query := Query + '`' + Items[I].Key + '` ' + RefType.DbType + ' NOT NULL,';
+    end;
+    Query := Query + 'PRIMARY KEY (`Id`)' +
+      ') ENGINE=InnoDB  DEFAULT CHARSET=utf8';
+    Database.Query(DbRows, Query);
   finally
-    Data.Free;
-  end;
-  if AType is TChronisTypeRecord then begin
-    for I := 0 to TChronisTypeRecord(AType).Items.Count - 1 do
-      try
-        Data := TDictionaryStringString.Create;
-        Data.Add('Name',
-          TChronisTypeRecordItem(TChronisTypeRecord(AType).Items[I]).Name);
-        Data.Add('Type', IntToStr(
-          TChronisTypeRecordItem(TChronisTypeRecord(AType).Items[I]).ItemType.OID));
-        Database.Insert('TypeRecordItem', Data);
-      finally
-        Data.Free;
-      end;
-  end;
-end;
-
-procedure TChronisClientMySQL.UndefineType(AType: TChronisType);
+    DbRows.Free;
+  end;
+end;
+
+procedure TChronisClientMySQL.TypeUndefine(AType: TChronisType);
 begin
 
@@ -156 +179 @@
 constructor TChronisClientMySQL.Create;
 begin
+  inherited;
   Database := TSqlDatabase.Create(nil);
 end;