Chapter 26.  Connectors

请参见5.7.8节，“拒绝访问错误的原因”。

要想使Microsoft Access能够与MyODBC一起工作，在你的客户端PC上必须完成下述操作。

1.    如果你正在使用Access 2000，应从下述地址获取并安装最新的（2.6版或更高）Microsoft MDAC（Microsoft数据访问组件），http://www.microsoft.com/data/。它更正了Access在将数据导出至MySQL时存在的一个缺陷，未指定表名和列名。另一种解决该缺陷的方法是，升级到MyODBC 2.50.33和MySQL 3.23.x, 它们共同提供了避免该问题的一种方式。

此外，你还应获取并应用Microsoft Jet 4.0 Service Pack 5 (SP5)，可在下述地址找到它：http://support.microsoft.com/default.aspx?scid=kb;EN-US;q239114。它修正了某些情况下在Access中列被标注为“#DELETED#”的问题。

注释： 如果你正使用MySQL 3.22，必须安装MDAC补丁，并使用MyODBC 2.50.32或2.50.34或更高版本以解决该问题。

2.    安装最新版MySQL，http://dev.mysql.com/downloads/。

3.    安装最新版MyODBC 3.51或2.50，http://dev.mysql.com/downloads/connector/odbc/。

4.    对于所有版本的Access，应启用“MyODBC返回匹配行”选项。

5.    通过MyODBC，将Access用作MySQL服务器的前端程序。

除非已安装了MyODBC，否则不能将表或查询导出到MySQL。

要想将表从Access导入MySQL，请遵循下述说明：

1.    打开Access数据库或Access项目时，出现“数据库”窗口。其中显示了用于创建新数据库对象和打开已有对象的快捷方式。

2.    点击打算导出的表名或查询名，然后在“文件”菜单中选择“导出”。

3.    在“导出对象类型对象名至”对话框中，在“另存为类型”框中，选择“ODBC数据库()”，如下图所示：

4.    在“导出”对话框中，输入文件名（或使用建议的文件名），然后选择OK。

5.    显示“选择数据源”对话框，其中列出了为计算机上已安装的各ODBC驱动定义的数据源。点击“文件数据源”或“机器数据源”选项卡，然后双击打算导出至的MyODBC或MyODBC 3.51数据源。关于为MyODBC定义新数据源的方法，请参见26.1.9.2节，“在Windows上配置MyODBC DSN”。

Microsoft Access通过该数据源连接至MySQL服务器，并导出新的表和／或数据。

除非已安装了MyODBC，否则不能将表或查询导出到MySQL数据库。

要想将表从MySQL导入或链接到Access，请采取下述步骤：

1.    打开数据库，或切换到“数据库”窗口以打开数据库。

2.    要想导入表，在“文件”菜单上，将鼠标指针指向“获取外部数据”，然后点击“导入”。要想链接表，在“文件”菜单上，将鼠标指针指向“获取外部数据”，然后点击“链接表”。

3.    在“导入”（或“链接”）对话框中，在“文件类型”框中选择“ODBC Databases ()”。在“选择数据源”对话框中，列出了定义的数据源。显示“选择数据源”对话框，其中列出了为安装在计算机上的任何ODBC驱动定义的数据源。点击“文件数据源”或“机器数据源”选项卡，然后双击打算导出至的MyODBC或MyODBC 3.51数据源。关于为MyODBC或MyODBC 3.51驱动定义新数据源的方法，请参见26.1.9.2节，“在Windows上配置MyODBC DSN”。

4.    如果所选的数据源要求登录，请输入登录ID和密码（可能还需要额外信息），然后点击OK。

5.    Microsoft Access通过ODBC数据源连接到MySQL服务器，并显示可导入或链接的表清单。

6.    点击希望导入或链接的每个表，然后点击OK。如果你正在链接1个表，但它没有唯一识别各条记录的索引，Microsoft Access将显示链接表中的字段列表。点击能唯一标识各记录的字段或字段组合，然后点击OK。

是。当链接表的结构或位置发生变化时，可采取下述步骤查看或刷新链接。“链接表管理器”列出了当前链接的所有表的路径。

要想查看或刷新链接：

1.    打开包含表链接的数据库。

2.    在“工具”菜单上，指向“加载项”（在Access 2000或更新版本中为“数据库实用工具”），然后点击“链接表管理器”。

3.    选中打算刷新链接的表的复选框。

4.    点击OK，刷新链接。

Microsoft Access将确认成功的刷新操作，或者，如果未找到表，将显示“选择<table name>新位置”对话框，在该对话框中，可指定表的新位置。如果你所选择的数个表已被移至你所指定的新位置，链接表管理器将针对所有所选的表搜索该位置，并一次性地更新所有链接。

要想更改链接表集合的路径：

1.    打开包含表链接的数据库。

2.    在“工具”菜单上，指向“加载项”（在Access 2000或更新版本中为“数据库实用工具”），然后点击“链接表管理器”。

3.    选中“对新位置始终提示”复选框。

4.    选中打算更改链接的表的复选框，然后点击OK。

5.    在“选择<table name>新位置”对话框中，指定新位置，点击“打开”，然后点击OK。

如果在Access中插入或更新的记录显示为“#DELETED#”：

·         如果你正在使用Access 2000，应从下述地址获取并安装最新的（2.6版或更高）Microsoft MDAC（Microsoft数据访问组件），http://www.microsoft.com/data/。它更正了Access在将数据导出至MySQL时存在的一个缺陷，未指定表名和列名。另一种解决该缺陷的方法是，升级到MyODBC 2.50.33和MySQL 3.23.x, 它们共同提供了避免该问题的一种方式。

此外，你还应获取并应用Microsoft Jet 4.0 Service Pack 5 (SP5)，可在下述地址找到它：http://support.microsoft.com/default.aspx?scid=kb;EN-US;q239114。它修正了某些情况下在Access中列被标注为“#DELETED#”的问题。

注释： 如果你正使用MySQL 3.22，必须安装MDAC补丁，并使用MyODBC 2.50.32或2.50.34或更高版本以解决该问题。

·         对于所有版本的Access，应启用“MyODBC返回匹配行”选项。对于Access 2.0，还应额外启用“模拟ODBC 1.0”选项。

·         在希望能够更新的所有表中，均应有时间戳。为了获得最大的可移植性，在列声明中不要使用长度规范。也就是说，应使用TIMESTAMP，而不是TIMESTAMP(n), n < 14。

·         在表中应有1个主键。如不然，新的或更新的行可能会显示为“#DELETED#”。

·         仅应使用DOUBLE浮点字段。与单精度浮点进行比较时，Access将失败。其征兆是新的或更新的行可能会显示为“#DELETED#”，或无法找到或更新行。

·         如果你正使用MyODBC来链接到有BIGINT列的表，结果会显示为“#DELETED”。排除它的解决方案是：

o        有1个以TIMESTAMP作为数据类型的虚拟列。

o        在“ODBC DSN管理器”的连接对话框中选择“将BIGINT列更改为INT”选项。

o        删除与Access的表链接，并重新创建它。

旧记录仍将显示为“#DELETED#”，但新增／更新的记录会恰当显示。

对于某些程序，可能会出现该错误： 另一用户更改了你所修改的记录。在大多数情况下，可通过下述措施解决该问题：

·         如果主键不存在，为表添加1个主键。

·         如果时间戳不存在，添加1个时间戳列。

·         仅应使用DOUBLE浮点字段。与单精度浮点值比较时，某些程序会出错。

如果这些措施未能解决问题，首先应从ODBC管理器生成1个日志文件（请求来自ODBC ADMIN的日志时获得的日志文件），以及1个MyODBC日志，使用它们找出出错的原因。具体介绍，请参见26.1.9.7节，“获取ODBC跟踪文件”。

将光标位置指定为adUseServer时，ADO的GetChunk()和AppendChunk()方法不能按预期的方式工作。从另一方面上讲，可使用adUseClient克服该问题。

在http://www.dwam.net/iishelp/ado/docs/adomth02_4.htm上给出了一个简单示例。

下面给出了Mike Hillyer（[email protected]）写的一篇好文章，其中解释了如何在ADO中通过MyODBC插入数据和／或从Blob列获取数据的方法。MySQL BLOB列和Visual Basic 6。

下面给出了ADO、DAO和RDO与VB一起使用的用法示例：

·         ADO示例： 26.1.19节，“MyODBC与VB：ADO、DAO和RDO”

·         DAO示例： 26.1.19节，“MyODBC与VB：ADO、DAO和RDO”

·         RDO示例： 26.1.19节，“MyODBC与VB：ADO、DAO和RDO”

如果你有其他好的例子，或关于ADO/DAO/RDO的基本知识，请将详情发送至[email protected]。

一个常见问题是，如何获取从INSERT语句自动生成的ID的值。使用ODBC，你可以作与以下示例类似的任何事（假定“auto”为AUTO_INCREMENT字段）：

INSERT INTO tbl (auto,text) VALUES(NULL,'text');

SELECT LAST_INSERT_ID();

或者，如果你仅打算将ID插入到另一表中，你可以：

INSERT INTO tbl (auto,text) VALUES(NULL,'text');

INSERT INTO tbl2 (id,text) VALUES(LAST_INSERT_ID(),'text');

请参见25.2.13.3节，“如何获得上次插入行的唯一ID”。

为了使某些ODBC应用程序（至少是Delphi和Access）获得更好的性能，可使用下述查询来找到新插入的行：

SELECT * FROM tbl WHERE auto IS NULL;

是。你可以使用odbc.net，通过MyODBC连接到MySQL。这里给出了一些从VC.NET和VB.NET连接到MySQL的基本示例。

·         请参见26.1.20.1节，“ODBC.NET: CSHARP(C#)”

·         请参见26.1.20.2节，“ODBC.NET: VB”

这里给出了Venu（MyODBC开发人员）撰写的另一篇好文章研究.NET环境下的MySQL，其中，给出了所有的MySQL .NET接口以及一些有用的例子。

注意： 在与MyODBC一起使用ODBC.NET的过程中，在获取空字符串的同时（长度为0），将给出SQL_NO_DATA异常。从站点http://support.microsoft.com/default.aspx?scid=kb;EN-US;q319243，可获取针对它的补丁。

MyODBC比其他ODBC驱动程序快很多。缓慢可能是因未使用下述选项造成的：

·         打开“ODBC跟踪”选项。遵循这里给出的指示说明，交叉检查是否未启用该选项。

如上图所示，“ODBC数据源管理器”“跟踪”选项卡的“何时跟踪”选项应始终指向“现在开始跟踪”，而不是“现在停止跟踪”。

·         使用了驱动程序的调试版本。如果你正在使用驱动DLL的调试版本，也会使查询处理变慢。你可以执行交叉检查，通过驱动DLL属性（在系统目录下，右击驱动DLL并点击“属性”）的“注释”区，检查DLL是否是调试版或发布版，如下图所示：

·         启用了“驱动跟踪和查询日志”。即使你打算使用驱动程序的调试版（在生产环境下总应使用发布版），也应确保禁止了“驱动跟踪和查询日志”选项（OPTION=4,524288），如下图所示：

·         配置MyODBC DSN。

·         连接到MySQL服务器。

·         初始化操作。

·         执行SQL语句。

·         检索结果。

·         执行事务。

·         断开与服务器的连接。

大多数应用程序均使用了这些步骤的某些变体。在下图中，给出了基本的应用步骤：

在下面的ADO（ActiveX数据对象）示例中，创建了表my_ado，并演示了rs.addNew、rs.delete和rs.update的用法。

Private Sub myodbc_ado_Click()

Dim conn As ADODB.Connection

Dim rs As ADODB.Recordset

Dim fld As ADODB.Field

Dim sql As String

'connect to MySQL server using MySQL ODBC 3.51 Driver（使用MySQL ODBC 3.51驱动程序连接到MySQL服务器）

Set conn = New ADODB.Connection

conn.ConnectionString = "DRIVER={MySQL ODBC 3.51 Driver};"_

                      & "SERVER=localhost;"_

                      & " DATABASE=test;"_

                      & "UID=venu;PWD=venu; OPTION=3"

conn.Open

'create table（创建表）

conn.Execute "DROP TABLE IF EXISTS my_ado"

conn.Execute "CREATE TABLE my_ado(id int not null primary key, name varchar(20)," _

                               & "txt text, dt date, tm time, ts timestamp)"

'direct insert（直接插入）

conn.Execute "INSERT INTO my_ado(id,name,txt) values(1,100,'venu')"

conn.Execute "INSERT INTO my_ado(id,name,txt) values(2,200,'MySQL')"

conn.Execute "INSERT INTO my_ado(id,name,txt) values(3,300,'Delete')"

Set rs = New ADODB.Recordset

rs.CursorLocation = adUseServer

'fetch the initial table ..（获取初始表…）

rs.Open "SELECT * FROM my_ado", conn

  Debug.Print rs.RecordCount

  rs.MoveFirst

  Debug.Print String(50, "-") & "Initial my_ado Result Set " & String(50, "-")

  For Each fld In rs.Fields

    Debug.Print fld.Name,

    Next

    Debug.Print

    Do Until rs.EOF

    For Each fld In rs.Fields

    Debug.Print fld.Value,

    Next

    rs.MoveNext

    Debug.Print

  Loop

rs.Close

'rs insert（rs插入）

rs.Open "select * from my_ado", conn, adOpenDynamic, adLockOptimistic

rs.AddNew

rs!Name = "Monty"

rs!txt = "Insert row"

rs.Update

rs.Close

'rs update（rs更新）

rs.Open "SELECT * FROM my_ado"

rs!Name = "update"

rs!txt = "updated-row"

rs.Update

rs.Close

'rs update second time..（rs更新第2次…）

rs.Open "SELECT * FROM my_ado"

rs!Name = "update"

rs!txt = "updated-second-time"

rs.Update

rs.Close

'rs delete（rs删除）

rs.Open "SELECT * FROM my_ado"

rs.MoveNext

rs.MoveNext

rs.Delete

rs.Close

'fetch the updated table ..（获取更新的表…）

rs.Open "SELECT * FROM my_ado", conn

  Debug.Print rs.RecordCount

  rs.MoveFirst

  Debug.Print String(50, "-") & "Updated my_ado Result Set " & String(50, "-")

  For Each fld In rs.Fields

    Debug.Print fld.Name,

    Next

    Debug.Print

    Do Until rs.EOF

    For Each fld In rs.Fields

    Debug.Print fld.Value,

    Next

    rs.MoveNext

    Debug.Print

  Loop

rs.Close

conn.Close

End Sub

在下面的简单示例中创建了表my_odbc_net，并介绍了它在C#中的使用。

/**
* @sample    : mycon.cs
* @purpose   : Demo sample for ODBC.NET using MyODBC
* @author    : Venu, <[email protected]>
*
* (C) Copyright MySQL AB, 1995-2004
*
**/

/* build command
*
*  csc /t:exe
*      /out:mycon.exe mycon.cs
*      /r:Microsoft.Data.Odbc.dll
*/

using Console = System.Console;
using Microsoft.Data.Odbc;

namespace myodbc3
{
class mycon
{
  static void Main(string[] args)
  {
    try
    {
      //Connection string for MyODBC 2.50
      /*string MyConString = "DRIVER={MySQL};" +
                           "SERVER=localhost;" +
                           "DATABASE=test;" +
                           "UID=venu;" +
                           "PASSWORD=venu;" +
                           "OPTION=3";
      */
      //Connection string for MyODBC 3.51
      string MyConString = "DRIVER={MySQL ODBC 3.51 Driver};" +
                           "SERVER=localhost;" +
                           "DATABASE=test;" +
                           "UID=venu;" +
                           "PASSWORD=venu;" +
                           "OPTION=3";

      //Connect to MySQL using MyODBC
      OdbcConnection MyConnection = new OdbcConnection(MyConString);
      MyConnection.Open();

      Console.WriteLine("\n !!! success, connected successfully !!!\n");

      //Display connection information
      Console.WriteLine("Connection Information:");
      Console.WriteLine("\tConnection String:" + MyConnection.ConnectionString);
      Console.WriteLine("\tConnection Timeout:" + MyConnection.ConnectionTimeout);
      Console.WriteLine("\tDatabase:" + MyConnection.Database);
      Console.WriteLine("\tDataSource:" + MyConnection.DataSource);
      Console.WriteLine("\tDriver:" + MyConnection.Driver);
      Console.WriteLine("\tServerVersion:" + MyConnection.ServerVersion);

      //Create a sample table
      OdbcCommand MyCommand = new OdbcCommand("DROP TABLE IF EXISTS my_odbc_net",MyConnection);
      MyCommand.ExecuteNonQuery();
      MyCommand.CommandText = "CREATE TABLE my_odbc_net(id int, name varchar(20), idb bigint)";
      MyCommand.ExecuteNonQuery();

      //Insert
      MyCommand.CommandText = "INSERT INTO my_odbc_net VALUES(10,'venu', 300)";
      Console.WriteLine("INSERT, Total rows affected:" + MyCommand.ExecuteNonQuery());;

      //Insert
      MyCommand.CommandText = "INSERT INTO my_odbc_net VALUES(20,'mysql',400)";
      Console.WriteLine("INSERT, Total rows affected:" + MyCommand.ExecuteNonQuery());

      //Insert
      MyCommand.CommandText = "INSERT INTO my_odbc_net VALUES(20,'mysql',500)";
      Console.WriteLine("INSERT, Total rows affected:" + MyCommand.ExecuteNonQuery());

      //Update
      MyCommand.CommandText = "UPDATE my_odbc_net SET id=999 WHERE id=20";
      Console.WriteLine("Update, Total rows affected:" + MyCommand.ExecuteNonQuery());

      //COUNT(*)
      MyCommand.CommandText = "SELECT COUNT(*) as TRows FROM my_odbc_net";
      Console.WriteLine("Total Rows:" + MyCommand.ExecuteScalar());

      //Fetch
      MyCommand.CommandText = "SELECT * FROM my_odbc_net";
      OdbcDataReader MyDataReader;
      MyDataReader =  MyCommand.ExecuteReader();
      while (MyDataReader.Read())
      {
       if(string.Compare(MyConnection.Driver,"myodbc3.dll") == 0) {
         Console.WriteLine("Data:" + MyDataReader.GetInt32(0) + " " +
                                     MyDataReader.GetString(1) + " " +
                                     MyDataReader.GetInt64(2)); //Supported only by MyODBC 3.51
       }
       else {
         Console.WriteLine("Data:" + MyDataReader.GetInt32(0) + " " +
                                     MyDataReader.GetString(1) + " " +
                                     MyDataReader.GetInt32(2)); //BIGINTs not supported by MyODBC
       }
      }

      //Close all resources
      MyDataReader.Close();
      MyConnection.Close();
    }
    catch (OdbcException MyOdbcException)//Catch any ODBC exception ..
    {
      for (int i=0; i < MyOdbcException.Errors.Count; i++)
      {
        Console.Write("ERROR #" + i + "\n" +
          "Message: " + MyOdbcException.Errors[i].Message + "\n" +
          "Native: " + MyOdbcException.Errors[i].NativeError.ToString() + "\n" +
          "Source: " + MyOdbcException.Errors[i].Source + "\n" +
          "SQL: " + MyOdbcException.Errors[i].SQLState + "\n");
      }
    }
  }
}
}

在下面的简单示例中创建了表my_vb_net，并介绍了它在VB中的用法。

' @sample    : myvb.vb
' @purpose   : Demo sample for ODBC.NET using MyODBC
' @author    : Venu, <[email protected]>
'
' (C) Copyright MySQL AB, 1995-2004
'
'

'
' build command
'
' vbc /target:exe
'     /out:myvb.exe
'     /r:Microsoft.Data.Odbc.dll
'     /r:System.dll
'     /r:System.Data.dll
'

Imports Microsoft.Data.Odbc
Imports System

Module myvb
  Sub Main()
      Try

          'MyODBC 3.51 connection string
          Dim MyConString As String = "DRIVER={MySQL ODBC 3.51 Driver};" & _
                         "SERVER=localhost;" & _
                         "DATABASE=test;" & _
                         "UID=venu;" & _
                         "PASSWORD=venu;" & _
                         "OPTION=3;"

          'Connection
          Dim MyConnection As New OdbcConnection(MyConString)
          MyConnection.Open()

          Console.WriteLine ("Connection State::" & MyConnection.State.ToString)

          'Drop
          Console.WriteLine ("Dropping table")
          Dim MyCommand As New OdbcCommand()
          MyCommand.Connection = MyConnection
          MyCommand.CommandText = "DROP TABLE IF EXISTS my_vb_net"
          MyCommand.ExecuteNonQuery()

          'Create
          Console.WriteLine ("Creating....")
          MyCommand.CommandText = "CREATE TABLE my_vb_net(id int, name varchar(30))"
          MyCommand.ExecuteNonQuery()

          'Insert
          MyCommand.CommandText = "INSERT INTO my_vb_net VALUES(10,'venu')"
          Console.WriteLine("INSERT, Total rows affected:" & MyCommand.ExecuteNonQuery())

          'Insert
          MyCommand.CommandText = "INSERT INTO my_vb_net VALUES(20,'mysql')"
          Console.WriteLine("INSERT, Total rows affected:" & MyCommand.ExecuteNonQuery())

          'Insert
          MyCommand.CommandText = "INSERT INTO my_vb_net VALUES(20,'mysql')"
          Console.WriteLine("INSERT, Total rows affected:" & MyCommand.ExecuteNonQuery())

          'Insert
          MyCommand.CommandText = "INSERT INTO my_vb_net(id) VALUES(30)"
          Console.WriteLine("INSERT, Total rows affected:" & MyCommand.ExecuteNonQuery())

          'Update
          MyCommand.CommandText = "UPDATE my_vb_net SET id=999 WHERE id=20"
          Console.WriteLine("Update, Total rows affected:" & MyCommand.ExecuteNonQuery())

          'COUNT(*)
          MyCommand.CommandText = "SELECT COUNT(*) as TRows FROM my_vb_net"
          Console.WriteLine("Total Rows:" & MyCommand.ExecuteScalar())

          'Select
          Console.WriteLine ("Select * FROM my_vb_net")
          MyCommand.CommandText = "SELECT * FROM my_vb_net"
          Dim MyDataReader As OdbcDataReader
          MyDataReader = MyCommand.ExecuteReader
          While MyDataReader.Read
              If MyDataReader("name") Is DBNull.Value Then
                  Console.WriteLine ("id = " & CStr(MyDataReader("id")) & "  name = " & _
                    "NULL")
              Else
                  Console.WriteLine ("id = " & CStr(MyDataReader("id")) & "  name = " & _
                                        CStr(MyDataReader("name")))
              End If
          End While

      'Catch ODBC Exception
      Catch MyOdbcException As OdbcException
          Dim i As Integer
          Console.WriteLine (MyOdbcException.ToString)

      'Catch program exception
      Catch MyException As Exception
          Console.WriteLine (MyException.ToString)
  End Try
  End Sub
End Module