Changeset 12 for trunk/DbEngines/UEngineMySQL.pas

Timestamp:

Feb 16, 2015, 11:37:47 PM (9 years ago)

Author:

chronos

Message:

• Added: Connection to MySQL host and loading list of available tables.

File:

• trunk/DbEngines/UEngineMySQL.pas (modified) (1 diff)

trunk/DbEngines/UEngineMySQL.pas

@@ -6 +6 @@
 
 uses
-  Classes, SysUtils, UDatabase;
+  Classes, SysUtils, UDatabase, USqlDatabase, UHtmlClasses, SpecializedDictionary;
 
 type
+
+  { TDatabaseMySQL }
+
   TDatabaseMySQL = class(TDatabaseClient)
-
+  private
+    procedure LoadTables;
+  public
+    SqlDatabase: TSqlDatabase;
+    constructor Create; override;
+    destructor Destroy; override;
+    procedure Load; override;
+    procedure Save; override;
   end;
 
 implementation
 
+{ TDatabaseMySQL }
+
+procedure TDatabaseMySQL.LoadTables;
+var
+  DbRows: TDbRows;
+  NewTable: TTable;
+  I: Integer;
+begin
+  DbRows := TDbRows.Create;
+  try
+    SqlDatabase.Query(DbRows, 'SELECT `TABLE_NAME` FROM `information_schema`.`TABLES` WHERE `TABLE_SCHEMA` = "' + SqlDatabase.Database + '"');
+    for I := 0 to DbRows.Count - 1 do begin
+      NewTable := TTable.Create;
+      NewTable.Database := Database;
+      NewTable.Name := (TDictionaryStringString(DbRows[I])[0]).Value;
+      NewTable.Caption := NewTable.Name;
+      Database.Tables.Add(NewTable);
+    end;
+  finally
+    DbRows.Free;
+  end;
+end;
+
+constructor TDatabaseMySQL.Create;
+begin
+  inherited Create;
+  SqlDatabase := TSqlDatabase.Create(nil);
+end;
+
+destructor TDatabaseMySQL.Destroy;
+begin
+  SqlDatabase.Free;
+  inherited Destroy;
+end;
+
+procedure TDatabaseMySQL.Load;
+var
+  URL: TURL;
+begin
+  URL := TURL.Create;
+  try
+    URL.AsString := Database.ConnectionString;
+    if URL.Scheme <> 'mysql' then
+      raise Exception.Create('Wrong connection string. Required mysql protocol.');
+
+    SqlDatabase.HostName := URL.Host.AsString;
+    if URL.Port <> 0 then
+      SqlDatabase.Port := URL.Port;
+    SqlDatabase.UserName := URL.UserName;
+    SqlDatabase.Password := URL.Password;
+    if Copy(URL.Path, 1, 1) = '/' then
+      SqlDatabase.Database := Copy(URL.Path, 2, High(Integer));
+    SqlDatabase.Connect;
+    LoadTables;
+  finally
+    URL.Free;
+  end;
+  inherited Load;
+end;
+
+procedure TDatabaseMySQL.Save;
+begin
+  SqlDatabase.Disconnect;
+  inherited Save;
+end;
+
 end.