c#常用数据库连接池

C#常用数据库连接池包括Sql Connection、OleDbConnection和OracleConnection等，它们分别适用于不同的数据库系统。这些连接池通过重用连接实例来提高应用程序的性能和效率。

在C#中，常用的数据库连接池有几种不同的实现方式和配置选项，以下是一些常见的数据库连接池及其特点：

| 连接池名称 | 描述 | 示例代码 |

| –| –| –|

|SqlConnection Pooling | 这是.NET Framework和.NET Core中最常用的数据库连接池之一，它用于连接SQL Server数据库，通过使用SqlConnectionStringBuilder来构建连接字符串，并传递给SqlConnection对象，可以自动管理连接池。 | “`csharp

using System;

using System.Data.SqlClient;

class Program

static void Main()

{

string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";

using (SqlConnection connection = new SqlConnection(connectionString))

{

connection.Open();

Console.WriteLine("Connection Open!");

// 执行数据库操作…

}

}

“` |

|DbConnection Pooling |DbConnection是所有数据库连接对象的基类，它提供了一个通用的接口来连接不同类型的数据库，通过使用工厂模式创建具体的数据库连接对象（如SqlConnection,MySqlConnection等），可以实现对多种数据库的支持，并且这些连接对象也会自动使用连接池。 | “`csharp

using System;

using System.Data;

using System.Data.Common;

class Program

static void Main()

{

string connectionString = "Your connection string here";

using (DbConnection connection = CreateDatabaseConnection(connectionString))

{

connection.Open();

Console.WriteLine("Connection Open!");

// 执行数据库操作…

}

}

static DbConnection CreateDatabaseConnection(string connectionString)

{

// 根据需要返回具体的数据库连接对象，

// return new SqlConnection(connectionString); // 对于SQL Server

// return new MySqlConnection(connectionString); // 对于MySQL

throw new NotImplementedException();

}

“` |

|Entity Framework Connection Pooling | Entity Framework是一个ORM框架，它提供了更高级别的抽象来处理数据库操作，在使用Entity Framework时，底层仍然会使用连接池来管理数据库连接，通过配置DbContext的Options属性，可以指定连接字符串和其他数据库相关设置。 | “`csharp

using System;

using Microsoft.EntityFrameworkCore;

class Program

static void Main()

{

string connectionString = "Your connection string here";

using (var context = new MyDbContext(new DbContextOptionsBuilder().UseSqlServer(connectionString).Options))

{

// 执行数据库操作…

}

}

public class MyDbContext : DbContext

public DbSet<MyEntity> MyEntities { get; set; }

public class MyEntity

public int Id { get; set; }

public string Name { get; set; }

“` |

|Dapper Connection Pooling | Dapper是一个轻量级的ORM库，它允许你以高效的方式执行查询和存储过程，Dapper本身并不直接提供连接池功能，但它依赖于ADO.NET的连接池机制，通过传递一个有效的连接字符串给Dapper的查询方法，可以复用现有的连接池。 | “`csharp

using System;

using Dapper;

using System.Data;

class Program

static void Main()

{

string connectionString = "Your connection string here";

using (var connection = new SqlConnection(connectionString))

{

var result = connection.QuerySingle<int>("SELECT COUNT(*) FROM Users");

Console.WriteLine($"Total users: {result}");

}

}

“` |

|NHibernate Connection Pooling | NHibernate是一个流行的ORM框架，它也提供了自己的连接池实现，通过配置NHibernate的ISessionFactory，可以指定连接池的相关参数，如最大连接数、最小连接数等。 | “`csharp

using System;

using NHibernate;

using NHibernate.Cfg;

using NHibernate.Dialect;

using NHibernate.Connection;

class Program

static void Main()

{

var configuration = new Configuration();

configuration.DataBaseIntegration(db =>

{

db.ConnectionString = "Your connection string here";

db.Dialect<MsSql2012Dialect>();

db.Driver<SqlClientDriver>();

db.Pooling = true; // 启用连接池

db.IdleTimeout = TimeSpan.FromMinutes(5); // 设置空闲超时时间

});

var sessionFactory = configuration.BuildSessionFactory();

using (var session = sessionFactory.OpenSession())

{

// 执行数据库操作…

}

}

“` |

|EF Core In-Memory Database | 虽然不是传统意义上的数据库连接池，但EF Core提供了内存中的数据库支持，这对于测试和开发非常有用，它不需要实际的数据库服务器，而是在内存中模拟数据库行为，通过配置DbContext的Options属性，可以选择使用内存中的数据库。 | “`csharp

using System;

using Microsoft.EntityFrameworkCore;

class Program

static void Main()

{

using (var context = new MyDbContext(new DbContextOptionsBuilder<MyDbContext>()

.UseInMemoryDatabase(databaseName: "InMemoryDb")

.Options))

{

// 执行数据库操作…

}

}

public class MyDbContext : DbContext

public DbSet<MyEntity> MyEntities { get; set; }

public class MyEntity

public int Id { get; set; }

public string Name { get; set; }

“` |

|Custom Connection Pooling | 如果现有的连接池机制不能满足需求，开发者还可以自定义连接池，这通常涉及到创建一个自定义的连接管理器，负责创建、维护和释放数据库连接，自定义连接池可以实现更细粒度的控制，但也增加了复杂性和维护成本。 | 自定义连接池的实现较为复杂，通常需要考虑到线程安全、连接回收、异常处理等多个方面，以下是一个简化的示例： <br> “csharp <br> using System; <br> using System.Collections.Concurrent; <br> using System.Data.SqlClient; <br> <br> class CustomConnectionPool <br> { <br> private readonly ConcurrentQueue<IDbConnection> _pool = new ConcurrentQueue<IDbConnection>(); <br> private readonly object _lock = new object(); <br> public CustomConnectionPool(string connectionString, int initialSize) <br> { <br> for (int i = 0; i < initialSize; i++) <br> { <br> var connection = new SqlConnection(connectionString); <br> connection.Open(); <br> _pool.Enqueue(connection); <br> } <br> } <br> public IDbConnection GetConnection() <br> { <br> if (_pool.TryDequeue(out var connection)) <br> { <br> return connection; <br> } <br> lock (_lock) <br> { <br> if (_pool.Count == 0) <br> { <br> var newConnection = new SqlConnection("Your connection string here"); <br> newConnection.Open(); <br> return newConnection; <br> } <br> else <br> { <br> _pool.TryDequeue(out connection); <br> return connection; <br> } <br> } <br> } <br> public void ReleaseConnection(IDbConnection connection) <br> { <br> if (connection != null && connection.State == System.Data.ConnectionState.Open) <br> { <br> _pool.Enqueue(connection); <br> } <br> else <br> { <br> connection?.Dispose(); <br> } <br> } <br> } <br> class Program <br> { <br> static void Main() <br> { <br> var pool = new CustomConnectionPool("Your connection string here", 10); <br> using (var connection = pool.GetConnection()) <br> { <br> Console.WriteLine("Connection Open!"); <br> // 执行数据库操作... <br> } <br> pool.ReleaseConnection(connection); <br> } <br> } <br>“ |

|Azure Service Bus Connection Pooling | 虽然不是传统意义上的数据库连接池，但在分布式系统中，消息队列也是一种重要的资源管理方式，Azure Service Bus提供了连接池的功能，可以帮助优化消息处理性能，通过使用ServiceBusClientBuilder来配置连接池的相关参数，如最大并发调用数、最大活动消息数等。 | “`csharp

using System;

using Azure.Messaging.ServiceBus;

class Program

static void Main()

{

string connectionString = "Your connection string here";

var options = new ServiceBusClientOptions(connectionString)

{

TransportType = ServiceBusTransportType.AmqpWebSockets,

RetryOptions = new ServiceBusRetryOptions() { Mode = ServiceBusRetryMode.Fixed },

MaxConcurrentCalls = 1, // 设置最大并发调用数

MaxActiveMessages = 10 // 设置最大活动消息数

};

var client = new ServiceBusClientBuilder(options).BuildProcessor();

// 执行消息处理…

}

“` |