[D6] [Api] [MySql]

**Archibald29** · 17/09/2008, 11h38

Bonjour à tous,

J'ai pris connaissance l'article de LFE sur l'utilisation de l'api mysql avec delphi, et je l'ai trouvé trés clair avec des exemples directement opérationnels.

Il y a seulement une chose que je ne parviens pas à faire dans l'exemple, c'est lister la structure de la base. (

violation d'accés...)

Dans le même ordre d'idée j'ai tenté de lister les noms des champs pour renseigner les entêtes de colonnes sur mes grilles, mais pas moyen...(

violation d'accés...)

Je suis sous XP et j'utilise D6 Entreprise et une version de libMySQL.dll récente (taille 1712Ko).

Est ce un problème de bibliothéque ?

Quelqu'un a t il une idée de la façon de procéder (si possible en conservant cette méthode d'accés via api) ?

**ShaiLeTroll** · 17/09/2008, 14h45

Pas évident de connaitre l'erreur que tu as, mais j'ai fait cela avec une très vieille DLL (3.23.49 - 2002 - 228Ko), tu y trouveras peut-être un bout de code que tu as omis de mettre, n'hésite pas à nous faire bénéficier de ton code par la suite ...

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
class function TepcMySQLAssistantPassThrough.InternalExecuteSQL(CallType: TTypeSQLExecute; const SQLText: string; out Error: String; out Latency: Int64): TDataSet;
 
  function TypeMySQLToTypeDB(FieldType: enum_field_types): TFieldType;
  begin
      case FieldType of
         FIELD_TYPE_DECIMAL     : Result := ftString; // Unpacked fixed-point number
         FIELD_TYPE_TINY        : Result := ftSmallint;
         FIELD_TYPE_SHORT       : Result := ftSmallint;
         FIELD_TYPE_LONG        : Result := ftInteger;
         FIELD_TYPE_FLOAT       : Result := ftFloat;
         FIELD_TYPE_DOUBLE      : Result := ftFloat;
         FIELD_TYPE_NULL        : Result := ftBlob;
         FIELD_TYPE_TIMESTAMP   : Result := ftString;
         FIELD_TYPE_LONGLONG    : Result := ftLargeint;
         FIELD_TYPE_INT24       : Result := ftInteger;
         FIELD_TYPE_DATE        : Result := ftDate;
         FIELD_TYPE_TIME        : Result := ftTime;
         FIELD_TYPE_DATETIME    : Result := ftDateTime;
         FIELD_TYPE_YEAR        : Result := ftString;
         FIELD_TYPE_NEWDATE     : Result := ftDate;
         FIELD_TYPE_ENUM        : Result := ftBlob;
         FIELD_TYPE_SET         : Result := ftBlob;
         FIELD_TYPE_TINY_BLOB   : Result := ftBlob;
         FIELD_TYPE_MEDIUM_BLOB : Result := ftBlob;
         FIELD_TYPE_LONG_BLOB   : Result := ftBlob;
         FIELD_TYPE_BLOB        : Result := ftBlob;
         FIELD_TYPE_VAR_STRING  : Result := ftBlob;
         FIELD_TYPE_STRING      : Result := ftString;
      else
         Result := ftString;
      end;
  end;
 
  function ValueMySQLToDB(FieldType: enum_field_types; const Value: string): string;
  begin
      Result := Value;
      case FieldType of
         FIELD_TYPE_FLOAT       : TepcDBEntiteToolHelp.SQLToLocaleStringFloat(Result);
         FIELD_TYPE_DOUBLE      : TepcDBEntiteToolHelp.SQLToLocaleStringFloat(Result);
         FIELD_TYPE_DATE        : TepcDBEntiteToolHelp.HyphenToSlashStringDate(Result);
      end;
  end;
 
  function GetLengthTypeMySQL(FieldType: enum_field_types; MaxLength: Integer): Integer;
  begin
      case FieldType of
         FIELD_TYPE_DECIMAL     : Result := MaxLength; // Unpacked fixed-point number
         FIELD_TYPE_YEAR        : Result := MaxLength;
         FIELD_TYPE_TINY_BLOB   : Result := MaxLength;
         FIELD_TYPE_MEDIUM_BLOB : Result := MaxLength;
         FIELD_TYPE_LONG_BLOB   : Result := MaxLength;
         FIELD_TYPE_BLOB        : Result := MaxLength;
         FIELD_TYPE_VAR_STRING  : Result := MaxLength;
         FIELD_TYPE_STRING      : Result := MaxLength;
      else
         Result := 0;
      end;
  end;
 
var
  Connexion: TepcMySQLConnexionPassThrough;
  Result_RES: PMYSQL_RES;
  Field_RES: PMYSQL_FIELD;
  Record_RES: PMYSQL_ROW;
  iCol: Integer;
begin
   Error := '';
   Result := nil;
   Result_RES := nil;
   Latency := 0;
 
   Connexion:= TepcMySQLConnexionPassThrough.Create();
   try
      Connexion.ServerName := GetDB().Connection.Server;
      Connexion.Login      := GetDB().Connection.Username;
      Connexion.PW         := GetDB().Connection.Password;
      Connexion.DataBaseName :=  GetDB().Connection.Database;
 
      Connexion.Connect();
 
      if Connexion.Connected then
      begin
         IncExecuteCount();
         DebugExecuteSQL(CallType, SQLText);
 
         if not GetSimulated(CallType) then
         begin
 
            if mysql_real_query(Connexion.FConnexion , PChar(SQLText), Length(SQLText)) <> 0 then
            begin
               // raise EMyError.CreateFmt('Echec de la Requête : %d - %s ', [mysql_errno(Connexion.FConnexion), mysql_error(Connexion.FConnexion)]);
               Error := Format('Echec de la Requête : %d - %s ', [mysql_errno(Connexion.FConnexion), mysql_error(Connexion.FConnexion)]);
               Exit;
            end;
 
            Result_RES := mysql_store_result(Connexion.FConnexion);
 
            if not Assigned(Result_RES) then
            begin
               // Erreur sur un select ou un script ?
               if mysql_field_count(Connexion.FConnexion) > 0 then
               begin
                  // raise EMyError.CreateFmt('%d - %s ', [mysql_errno(Connexion.FConnexion), mysql_error(Connexion.FConnexion)]);
                  Error := Format('%d - %s ', [mysql_errno(Connexion.FConnexion), mysql_error(Connexion.FConnexion)]);
                  Exit;
               end else
               begin
                  Result := TClientDataSet.Create(nil);
                  with TClientDataSet(Result) do
                  begin
                     AddField('Affected_Rows', ftInteger);
                     Open();
                     Append();
                     Fields[0].AsInteger := mysql_affected_rows(Connexion.FConnexion);
                     Post();
                  end;
                  Exit; // C'est un Script
               end;
            end;
 
            // traitement des données
 
            if CallType = tsQuery then
            begin
               if mysql_field_count(Connexion.FConnexion) > 0 then
               begin
                  Result := TClientDataSet.Create(nil);
 
                  with TClientDataSet(Result) do
                  begin
 
                     // initialisation des colonnes
                     mysql_field_seek(Result_RES, 0);
                     for iCol := 0 to mysql_num_fields(Result_RES)-1 do
                     begin
                        Field_RES := mysql_fetch_field(Result_RES);
                        AddField(Field_RES.name,
                                 TypeMySQLToTypeDB(Field_RES._type),
                                 GetLengthTypeMySQL(Field_RES._type, Field_RES.max_length));
                     end;
 
                     Open();
 
                     // Remplissage des Champs
                     Record_RES := mysql_fetch_row(Result_RES);
 
 
                     while Assigned(Record_RES) do
                     begin
                        mysql_field_seek(Result_RES,0);
 
                        Append();
                        for iCol := 0 to mysql_num_fields(Result_RES)-1 do
                        begin
                           Field_RES := mysql_fetch_field(Result_RES);
                           if Assigned(Record_RES[iCol]) then
                           begin
                              Fields[iCol].AsString := ValueMySQLToDB(Field_RES._type, Record_RES[iCol]);
                           end;
                        end;
                        Post();
 
                        Record_RES := mysql_fetch_row(Result_RES);
                     end;
                  end;
               end;
            end;
         end;
      end else
      begin
         Result := inherited InternalExecuteSQL(CallType, SQLText, Error, Latency);
      end;
   finally
      if Assigned(Result_RES) then
         mysql_free_result(Result_RES);
 
      Connexion.Free();
   end;
end;

**Archibald29** · 17/09/2008, 18h41

Merci de ta réponse

Je teste dans les meilleurs délais et je te tiens au courant

Archibald

**Archibald29** · 18/09/2008, 10h27

Aprés une première prise de connaissance du code contenu dans ta réponse j'avoue être un peu perdu : comment le mettre en oeuvre ?
Peut être peux tu également me conseiller qq tutoriaux éventuels ?

+++
Archibald

[D6] [Api] [MySql]

Bases de données Delphi

Discussions similaires

Partager

Partager