Changeset 37 for trunk/Application/Clients/UChronisClientMySQL.pas

Timestamp:

Mar 8, 2012, 3:11:10 PM (13 years ago)

Author:

chronos

Message:

• Modified: Direct acces using Database: TSqlDatabase replaced by TChronisClient interface.

File:

• trunk/Application/Clients/UChronisClientMySQL.pas (modified) (7 diffs)

trunk/Application/Clients/UChronisClientMySQL.pas

@@ -13 +13 @@
 
   TChronisClientMySQL = class(TChronisClient)
+  protected
+    function GetConnected: Boolean; override;
+  public
     Database: TSqlDatabase;
     procedure ObjectLoad(AObject: TObjectProxy); override;
@@ -20 +23 @@
     procedure ListLoad(AList: TListProxy); override;
     procedure ListSave(AList: TListProxy); override;
-    constructor Create;
+    procedure DefineType(AType: TChronisType); override;
+    procedure UndefineType(AType: TChronisType); override;
+    procedure Install;
+    procedure Uninstall;
+    constructor Create; override;
     destructor Destroy; override;
+    procedure Connect; override;
+    procedure Disconnect; override;
   end;
 
@@ -27 +36 @@
 
 { TChronisClientMySQL }
+
+function TChronisClientMySQL.GetConnected: Boolean;
+begin
+  Result := Database.Connected;
+end;
 
 procedure TChronisClientMySQL.ObjectLoad(AObject: TObjectProxy);
@@ -52 +66 @@
   DbRows: TDbRows;
   Filter: string;
-  Condition: string;
+  DbCondition: string;
   I: Integer;
   NewObject: TObjectProxy;
+  Table: string;
 begin
   try
@@ -64 +79 @@
       Delete(Filter, Length(Filter) - 1, 2);
     end else Filter := '*';
-    if AList.ConditionUse then Condition := '`' + AList.ConditionColumn + '` = "' +
-      AList.ConditionValue + '"'
-      else Condition := '1';
-    Database.Query(DbRows, 'SELECT ' + Filter + ' FROM `' + AList.SchemaName + '`.`' +
-      AList.ObjectName + '` WHERE ' + Condition);
+    if AList.Condition <> '' then DbCondition := ' WHERE ' + AList.Condition
+      else DbCondition := '';
+    Table := '`' + AList.ObjectName + '`';
+    if AList.SchemaName <> '' then Table := '`' + AList.SchemaName + '`.' + Table;
+    Database.Query(DbRows, 'SELECT ' + Filter + ' FROM ' + Table + DbCondition);
     AList.Objects.Clear;
     for I := 0 to DbRows.Count - 1 do begin
@@ -86 +101 @@
 end;
 
+procedure TChronisClientMySQL.DefineType(AType: TChronisType);
+var
+  Data: TDictionaryStringString;
+  I: Integer;
+begin
+  try
+    Data := TDictionaryStringString.Create;
+    Data.Add('Name', AType.Name);
+    Database.Insert('Type', Data);
+  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);
+begin
+
+end;
+
+procedure TChronisClientMySQL.Install;
+begin
+(*  if Tables.IndexOf(InformationTable) = -1 then begin
+    Database.Query(DbRows, 'CREATE TABLE IF NOT EXISTS `' + InformationTable + '` ( ' +
+'`Version` varchar(255) NOT NULL,' +
+'`LastUpdateTime` datetime NOT NULL' +
+') ENGINE=InnoDB DEFAULT CHARSET=utf8;');
+    Database.Query(DbRows, 'INSERT INTO `' + InformationTable + '` (`Version`, `LastUpdateTime`) VALUES ' +
+'("0.1", "0000-00-00 00:00:00");');
+  end;
+  Database.Select(DbRows, InformationTable);
+  StructureVersion := DbRows[0].Values['Version'];*)
+end;
+
+procedure TChronisClientMySQL.Uninstall;
+begin
+
+end;
+
 constructor TChronisClientMySQL.Create;
 begin
@@ -97 +163 @@
 end;
 
+procedure TChronisClientMySQL.Connect;
+begin
+  Database.Port := Port;
+  Database.UserName := User;
+  Database.Password := Password;
+  Database.HostName := Host;
+  Database.Database := Schema;
+  Database.Connect;
+end;
+
+procedure TChronisClientMySQL.Disconnect;
+begin
+  Database.Disconnect;
+end;
+
 end.