ADO.NET 扩展

ADO.NET 成功地提供了一组基类和接口，为通过其他类和接口访问关系型数据库提供了一种选择，因此，从 F# 中访问大多数关系型数据库不用太多的努力。我们已经讨论了大部分这样的类，或者至少这些类实现了它们打算提供的功能。表 9-2 汇总了其中的关键类。

表 9-2 ADO.NET 中的关键类

在表 9-2 中的类，除了 System.Data.DataSet 类以外，都是抽象的，因此，必须使用类的具体实现。例如，这个示例演示了如何创建 System.Data.SqlClient.SqlConnection 类的实例，它是System.Data.Common.DbConnection 类的实现，它用于访问 SQL Server 数据库：

Use connection = newSqlConnection(connectionString)

如果想访问Oracle 数据库，只要把SqlConnection 类简单地替换成 OracleConnection。表 9-3 汇总了最流行的库，经及实现这些类的命名空间。这个表并不完整，因为提供程序的范围很广。

表 9-3  .NET 版本的数据库提供程序

为演示如何使用其他的 .NET 版本的提供程序，连接到关系型数据库管理系统，现在给出一个例子，连接到 Firebird 的employee 示例数据库。运行这个示例，需要安装 Firebird 数据库引擎和 Firebird 的 .NET 版本的提供程序组件，可从 http://www.firebirdsql.org 下载；还需要在本地运行 Firebird 数据库服务。

open System.Configuration

open System.Collections.Generic

open System.Data

open FirebirdSql.Data.FirebirdClient

open System.Data.Common

open System

// firebird connection string

let connectionString =

  @"Database=C:\ProgramFiles\Firebird\" +

  @"Firebird_2_0\examples\empbuild\EMPLOYEE.FDB;"+

  @"User=SYSDBA;"+ "Password=masterkey;" +

  @"Dialect=3;"+ "Server=localhost";

// open firebird connection

let openFBConnection() =

  letconnection = new FbConnection (connectionString)

  connection.Open();

  connection

// create a reader to read all theinformation

let openConnectionReader cmdString =

  letconn = openFBConnection()

  letcmd = conn.CreateCommand(CommandText = cmdString,

                             CommandType =CommandType.Text)

  letreader = cmd.ExecuteReader(CommandBehavior.CloseConnection)

  reader

// read a row from the database and convertinto a dictionary

let readOneRow (reader: #DbDataReader) =

  ifreader.Read() then

    letdict = new Dictionary<string, obj>()

    forx = 0 to (reader.FieldCount - 1) do

    dict.Add(reader.GetName(x),reader.Item(x))

    Some(dict)

  else

    None

// execute a database command creating asequence of the results

let execCommand cmdString =

  Seq.generate

    //This function gets called to open a conn and create a reader

    (fun() -> openConnectionReader cmdString)

    //This function gets called to read a single item in

    //the enumerable for a reader/conn pair

     (funreader -> readOneRow(reader))

     (fun reader -> reader.Dispose())

// select all from the Employee‘s table

let employeeTable =

  execCommand

    "select* from Employee"

// print out the Employee‘s information

for row in employeeTable do

  forcol in row.Keys do

    printfn"%s = %O " col (row.Item(col))

前面示例的运行结果如下：

...

EMP_NO = 145

FIRST_NAME = Mark

LAST_NAME = Guckenheimer

PHONE_EXT = 221

HIRE_DATE = 02/05/1994 00:00:00

DEPT_NO = 622

JOB_CODE = Eng

JOB_GRADE = 5

JOB_COUNTRY = USA

SALARY = 32000

FULL_NAME = Guckenheimer, Mark

注意

只有非常小的变化，把 SQL Server AdventureWorks 的 contact 表转换成对Firebird employee 数据库表employee 的查询。