MySQL ohne Komponenten

[Chewie]

Zugriff auf MySQL mit der MySQL-C-API

Fast jeder, der schon mit PHP gearbeitet hat, kennt wohl den Datenbankserver MySQl, und die meisten von euch werden wohl auch schon von PHP aus damit gearbeitet haben.
Während das mit PHP sehr einfach und unkompliziert ist, erscheint es mit Delphi am Anfang recht kompliziert. Gerade wenn man noch keine Datenbankerfahrungen mit Delphi verbuchen kann, erscheint die Benutzung der Zeos-Komponenten oder auch der ODBC-Schnittstelle aufwändig und kompliziert. Ganz zu schweigen von der Tatsache, dass Komponenten, die von Zeos benötigt werden, bei den Standard- und Personal-Versionen von Delphi nicht dabei sind.
Was liegt also näher, als auf diese Komponenten zu verzichten und eine Alternative zu suchen? Besonders, wenn man bereits mit PHP und MySQL gearbeitet hat, dürfte man sehr gut mit der hier vorgestellten Methode zurechtkommen.

Das Tutorial handelt davon, wie man die C-API von MySQL in Delphi einsetzt. Ja, ihr habt richtig gelesen, C-API, so heißt es auf der MySQL-Website. Nichtsdestotrotz kann man diese API (= Application Programming Interface) natürlich auch mit Delphi verwenden.
Anmerkung: SQL-Kenntnisse werden hier nicht vermittelt. Die sind Voraussetzung zum Begreifen dieses Tutorials.
Dafür notwendig sind in erster Linie einmal die Pascal-Übersetzungen der C-Header für die MySQL-Bibliothek (und natürlich die Bibliothek selbst). Die Header findet man unter http://www.audio-data.de/mysql.html, die Bibliothek libmysql.dll ist bei dem MySQL-Server dabei.
Die Pascal-Unit mysql.pas importiert die Funktionen von libmysql.dll und stellt sie Programmmierern zur Verfügung. Um auf die DLL zugreifen zu können, muss sie entweder im Programmverzeichnis liegen oder aber im Verzeichnis Windows, Windows\System oder Windows\System32.

Nachdem das getan ist, können wir die DLL verwenden. Dazu muss die Unit mysql.pas in unser Projektverzeichnis gelegt werden und per uses-Klausel eingebunden werden. Unsere Unit sieht also so aus:

Code:

unit MysqlTest;

interface

uses
  Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs, [b]mySQL[/b];
  
{ ... }

Bevor wir anfangen, mit dem SQL-Server zu arbeiten, kommen einige kleine Anmerkungen.
Eine Übersicht und Dokumentation der Funktion ist auf http://www.mysql.com/documentation/m...ction_overview verfügbar.
Von diesen werden in diesem Tutorial aber nur folgende verwendet:

mysql_close()
mysql_error()
mysql_fetch_row()
mysql_free_result()
mysql_init()
mysql_real_connect()
mysql_real_query()
mysql_store_result()

Die Verwendung der übrigen Funktionen sollte aber kaum Mühe bereiten, schon gar nicht, wenn man sie aus PHP kennt, da, wie man an der Auflistung sehen kann, die C-API und die PHP-API recht ähnlich sind.

Neben den Funktionen werden noch folgende Datentypen, die in mysql.pas definiert sind, benutzt:

PMySQL
PMySQL_Res
PMySQL_Rows


So, es kann nun losgehen.

Im nachfolgenden Beispiel werden wir uns zu einem MySQL-Server verbinden und ihn nach dem aktuellen Datum fragen.
Die einzelnen Schritte werden zunächst erläutert, bevor anschließend ein kurzes Code-Beispiel erklärt wird.

Bevor wir überhaupt eine Verbindung herstellen können, müssen wir unseren Verbindungsdeskriptor initialisieren. Dieser ist vom Typ PMySQL.

Ist dies getan, können wir die Verbindung herstellen.Dafür wird mysql_real_connect() benutzt.

mysql_real_connect() ist folgendermaßen augebaut:
mysql_real_connect: function(_mysql: PMYSQL; const host, user, passwd, db: pChar; port: longword; const unix_socket: pChar; clientflag: longword): PMYSQL; stdcall; Die Erklärung der einzelnen Parameter findet sich auf http://www.mysql.com/documentation/m...l_real_connect.

Als Rückgabe erhalten wir erneut unseren Verbindungsdeskriptor, der jetzt (hoffentlich) eine aktive Verbindung beschreibt.
Dies ist der Fall, wenn er ungleich nil ist.

Mit den eigentlichen Transaktionen beschäftigen wir uns im nächsten Kapitel, deshalb wird jetzt lediglich die Verbindung getrennt.
Das geschieht mittels mysql_close().


Das Beispiel:

Delphi-Quellcode:

var
  _myCon: PMySQL;       //unseren Verbindungsdeskriptor
  host, user, pass, db: PChar;       //die Anmeldedaten
begin
  //wir werden uns als Root-Benutzer in localhost einloggen, ohne eine
  //bestimmte Datenbank auszuwählen
  host := 'localhost';
  user := 'root';
  pass := nil;
  db := nil;
  
  //jetzt wird _myCon initialisiert
  _myCon := mysql_init(nil);
  if _myCon = nil then
  begin
    ShowMessage('Nicht genug freier Speicher, um Verbindungsdeskriptor zu initialisieren');
    Exit;
  end;
  
  //anschließend wird die Verbindung hergestellt
  if mysql_real_connect(_myCon, host, user, pass, db, 3306, nil, 0) = nil then
  begin
    ShowMessage('Die Verbindung konnte nicht hergestellt werden. Ursache: ' + mysql_error(_myCon));
    Exit;
  end;
  
  ShowMessage('Verbindung hergestellt');
  
  //zum Schluss wird die Verbindung wieder geschlossen
  mysql_close(_myCon);
end;

Im nächsten Teil werden wir ein paar einfache SELECT, INSERT, UPDATE und DELETE-Transmissionen durchführen.

[edit=Matze]Link korrigiert. MfG, Matze[/edit]

[MPirnstill]

Hi!

Wollte nur mal fragen, gibt es so etwas auch für Firebird bzw. würde sich dies darauf anwenden lassen?

Gruß

[Chewie]

Das ist die API für MySQl. Andere Datenbanken besitzen andere APIs.
U.a. aus diesem Grund gibt es Abstraktions-Layer

[Chiara87]

Hallo
Ich habe eine Problem.
Ich habe die Unit mysql.pas heruntergeladen und alles gemacht was im Tutorials stand aber wenn ich die Unit compiliere bringt folgende fehler:
Undefinierter Bezeichner: longword, pLongword und Int64.
liegt es daran an das ich Delphi 3 benutze.
Bitte um eine Antwort

[Chiara87]

Problem gelöst?
er war wie ich es vermuten habe.
ich hab mit delphi7 probiert und läuft wunderbar.

[mimi]

also ich habe mir jetzt nicht alle 9 seiten durchlesen aber ich habe einee frage zu deine tutorial:
ich habe nun folgenden qullcode:

Delphi-Quellcode:

procedure MakeTables(_myCon: PMySQL);
var
  query: PChar;
begin
  mysql_select_db(_myCon, 'APITest');     //zu Datenbank "APITest" wechseln
  query:='CREATE TABLE posts(id int, author int, date datetime, entry text)';
  mysql_real_query(_myCon, 'CREATE TABLE posts(id int, author int, date datetime, entry text)', Length(query));
  query:='CREATE TABLE users(id int, name varchar(50), pass varchar(50))';

  mysql_real_query(_myCon, 'CREATE TABLE users(id int, name varchar(50), pass varchar(50))', Length(query));
end;

procedure CreateDB;
var
  Posts: TPostEntries; 
  _myCon: PMySQL;       //unseren Verbindungsdeskriptor
  host, user, pass, db: PChar;       //die Anmeldedaten
  query: PChar;
  _myRes: PMySQL_Res; //hier wird der gesamte Ergebnissatz gespeichert
  _mySubRes: PMySQL_Res;  //benötigt, um Autor zu ermmitteln
  _myRow: PMySQL_Row; //enthält den aktuellen Datensatz
  _mySubRow: PMySQL_Row;  //benötigt, um Autor zu ermmitteln
  i:Integer;
  idAuthor: String; 
begin
  //wir werden uns als Root-Benutzer in localhost einloggen, ohne eine
  //bestimmte Datenbank auszuwählen
  host := 'localhost';
  user := 'root';
  pass := 'test';
  db := nil;
 
  //jetzt wird _myCon initialisiert
  _myCon := mysql_init(nil);
  if _myCon = nil then
  begin
    ShowMessage('Nicht genug freier Speicher, um Verbindungsdeskriptor zu initialisieren');
    Exit;
  end;
 
  //anschließend wird die Verbindung hergestellt
  if mysql_real_connect(_myCon, host, user, pass, db, 3306, nil, 0) = nil then
  begin
    ShowMessage('Die Verbindung konnte nicht hergestellt werden. Ursache: ' + mysql_error(_myCon));
    Exit;
  end;
 
//  ShowMessage('Verbindung hergestellt');

  query := 'CREATE DATABASE APITest';
  mysql_real_query(_myCon, query, Length(query));

  MakeTables(_myCon);


  query := 'SELECT * FROM posts ORDER BY id';
  mysql_real_query(_myCon, query, Length(query));
 
  _myRes := mysql_store_result(_myCon);  //alle Datensätze vom Server anfordern
  
  if _myRes = nil then
  begin
    ShowMessage('Es konnten keine Datensätze zurückgebenen werden. Ursache: ' + mysql_error(_myCon));
    Exit;
  end;
  SetLength(Posts, mysql_num_rows(_myRes));  //Posts-Array-Größe auf Anzahl der Datensätze setzen

  for i := 0 to High(Posts) do
  begin

    _myRow := mysql_fetch_row(_myRes);   //Datensatz abholen
    Posts[i].id := Integer(_myRow[0]);  //ID des Posts ist erstes Feld im Datensatz
    Posts[i].time := _myRow[2];          //Zeitpunkt ist drittes Feld
    Posts[i].text := _myRow[3];          //Text ist viertes Feld
   
    idAuthor := _myRow[1];
    query := PChar('SELECT name FROM users WHERE id=' + idAuthor);
    mysql_real_query(_myCon, query, Length(query));
    _mySubRes := mysql_store_result(_myCon);
    _mySubRow := mysql_fetch_row(_mySubRes);
    Posts[i].author := _mySubRow[0];
   
    mysql_free_result(_mySubRes);        //Ergebnissatz löschen 
  end;
 
  mysql_free_result(_myRes);             //Ergebnissätze löschen
 
  {...}
  {Verbindung schließen oder etwas anderes machen}

//  for i:=0 to
  mysql_close(_myCon);
end;

procedure TForm1.FormCreate(Sender: TObject);
begin
  CreateDB;
end;

aber leider bleibt der Array Posts immer leer wie kann ich ihn füllen ?

[Chewie]

Klar, dass es leer bleibt, es befinden sich ja keine Einträge in den Tabellen!
Die Tabellen werden ja nur erzeugt, nicht befüllt! Dies müsstest du dann selbst mit entsprechenden INSERT-Statements machen.

[mimi]

ich habe jetzt ein insert befehl hinzugefügt, doch sie bleibt immer noch leer:

Delphi-Quellcode:

procedure MakeTables(_myCon: PMySQL);
var
  query: PChar;
begin
  mysql_select_db(_myCon, 'APITest');     //zu Datenbank "APITest" wechseln
  query:='CREATE TABLE posts(id int, author int, date datetime, entry text)';
  mysql_real_query(_myCon, 'CREATE TABLE posts(id int, author int, date datetime, entry text)', Length(query));
  query:='CREATE TABLE users(id int, name varchar(50), pass varchar(50))';

  mysql_real_query(_myCon, 'CREATE TABLE users(id int, name varchar(50), pass varchar(50))', Length(query));
end;
.....
  query := 'CREATE DATABASE APITest';
  mysql_real_query(_myCon, query, Length(query));


  MakeTables(_myCon);

  query := 'SELECT * FROM posts ORDER BY id';
  mysql_real_query(_myCon, query, Length(query));

  // ich bin sicher das muss hier hin doch die db bleibt immer noch leer warum ?
  query:='INSERT INTO posts (id, author, date, entry) VALUES (001, Michael Springwald, 10.10.2006, Dies ist ein test';
  mysql_real_query(_myCon, query, Length(query));

  _myRes := mysql_store_result(_myCon);  //alle Datensätze vom Server anfordern

  if _myRes = nil then
  begin
    ShowMessage('Es konnten keine Datensätze zurückgebenen werden. Ursache: ' + mysql_error(_myCon));
    Exit;
  end;
  SetLength(Posts, mysql_num_rows(_myRes));  //Posts-Array-Größe auf Anzahl der Datensätze setzen
  ShowMessage(IntToStr(High(Posts)));

[Chewie]

Lass dir mal den Fehlertext zurückgeben (mysql_error()) und lies dir die Dokumentation durch, dann wirst du hoffentlich erkennen, dass String-Literale in Hochkommata eingefasst werden müssen.

Tipp: Besorg dir ein Tool wie z.B. phpMyAdmin und teste dort erstmal, ob die Queries an sich richtig sind und versuche sie erst dann, in der Anwendung auszuführen.

[mimi]

es kommt folgende fehlermeldung:

Zitat:

---------------------------
codelib
---------------------------
Commands out of sync; you can't run this command now
---------------------------
OK
---------------------------

ich habe den string so gesetzt:

  query:='INSERT INTO posts (id,author,date,entry) VALUES (001, 5, 10.10.2005 10:35, ''Dies ist ein test'')'; und noch eine kurzte frage wie kann ich die bestehene db abspeichern in eine datei ??? es das Datum bzw. die uhrzeit falschangeben ?

[mimi]

habes hinbekommen(fast):

Delphi-Quellcode:

  MakeTables(_myCon);
                                                                  
  // ich bin sicher das muss hier hin doch die db bleibt immer noch leer warum ?
  query:=PChar('INSERT INTO posts(id,author,date,entry) VALUES(1,Mimi,10-10-2005,''Dies ist ein test'')');
  mysql_real_query(_myCon, query, Length(query));


  query := 'SELECT * FROM posts ORDER BY id';
  mysql_real_query(_myCon, query, Length(query));

es gibt in der forschleife aus deinem tutor nur noch eine fehlermeldung:

Zitat:

---------------------------
codelib
---------------------------
Zugriffsverletzung bei Adresse 00457362 in Modul 'codelib.exe'. Lesen von Adresse 00000000.
---------------------------
OK
---------------------------

und noch eine frage wo wird diese db abgespeichert ??? weil der zähler wird immer erhöt bei jedem hinzufügen und beim programm ende !