mysql - Delphi - TSQLQuery 即使在被释放后也会在 MySQL 上留下进程

Question

我在 Delphi 2007 中使用 DBExpress 连接到网络上的 MySQL5 数据库服务器。

一切正常，直到我尝试上传大量数据。我正在尝试将 8000 多条记录插入数据库，一次一个循环，在循环中我将 TSQLConection 对象与要插入的数据一起传递给函数。

该函数创建一个 TSQLQuery 对象并运行插入查询，然后释放 TSQLQuery。当我在大量数据上运行它时，我收到一条消息说 MySQL 服务器有很多连接。查看 MySQL 服务器的进程列表，我看到了这一点。

+---------+------+-------------------------------+--------+---------+------+--------+-----------------------+
| Id      | User | Host                          | db     | Command | Time | State  | Info                  |
+---------+------+-------------------------------+--------+---------+------+--------+-----------------------+
| 2962500 | name | myispdomain.co.uk:27812       | data   | Sleep   |    3 |        | [NULL]                |
+---------+------+-------------------------------+--------+---------+------+--------+-----------------------+

我创建的每个 TSQLQuery 对象都有一个条目，如果我单步执行代码，我可以在运行 ExecSQL() 时看到一个新条目进入。我在 TSQLQuery 上调用 FreeAndNil，并尝试在释放它之前调用 Close。

我的MySQL连接设置如下

   ConnectionName := 'MySQLConnection';
   DriverName     := 'MySQL';
   GetDriverFunc  := 'getSQLDriverMYSQL';
   KeepConnection := TRUE;
   LibraryName    := 'dbxmys30.dll';
   LoadParamsOnConnect := False ;
   LoginPrompt := FALSE;
   Name := 'mySQLConnection';
   VendorLib := 'LIBMYSQL.DLL';
   TableScope := [tsTable,tsView];

    Params.Add('DriverName=MySQL');
    Params.Add('HostName=www.sample.com');
    Params.Add('Database=data'); 
    Params.Add('User_Name=myuser'); 
    Params.Add('Password=mypassword'); 
    Params.Add('BlobSize=-1');
    Params.Add('ErrorResourceFile=');
    Params.Add('LocaleCode=0000');
    Params.Add('Compressed=False');
    Params.Add('Encrypted=True');

如果我将 KeepConnection 设置为 False，问题就会消失，但运行查询的时间会增加。

有办法解决这个问题吗？

Answer 1

不要一遍又一遍地重新创建您的连接，也不要重新创建您的查询。使用参数进行查询；打开一次连接，填充查询参数，执行它，关闭查询(但不是连接)，再次填充查询参数，然后再次执行。

类似这样的东西(使用 Advantage Database Server，但概念是一样的):

// Both Create() calls should be followed by try..finally to ensure they're 
// cleaned up after. Omitted for brevity.
Conn := TAdsConnection.Create(nil);
// Configure connection parameters here
Conn.Open;

Qry := TAdsQuery.Create(nil);
Qry.AdsConnection := Conn;
Qry.SQL.Add('INSERT INTO SOMETABLE (COL1, COL2, COL3)');
Qry.SQL.Add('VALUES (:COL1, :COL2, :COL3)');
while not OtherTable.Eof do
begin
  Qry.ParamByName('COL1').AsInteger := OtherTable.FieldByName('COL1').AsInteger;
  Qry.ParamByName('COL2').AsString := OtherTable.FieldByName('COL2').AsString;
  Qry.ParamByName('COL3').AsDateTime := OtherTable.FieldByName('COL3').AsDateTime;
  Qry.ExecSQL;
  Qry.Close;
  OtherTable.Next;
end;
// Free query
Conn.Close;
// Free connection.