使用 PetaPoco 与 StructureMap 的共享连接

Question

这是我当前在 Global.asax 中实现的 StructureMap：

var container = (IContainer)IOCContainer.Initialize();
DependencyResolver.SetResolver(new StructureMapDependencyResolver(container));

下面是上面提到的代码：

public static class IOCContainer
    {
        public static IContainer Initialize()
        {
            ObjectFactory.Initialize(x =>
            {
                x.Scan(scan =>
                {
                    scan.TheCallingAssembly();
                    scan.WithDefaultConventions();
                    scan.AddAllTypesOf<IController>();
                });

                x.For<IConfigRepository>().Use<ConfigRepository>();
            });
            return ObjectFactory.Container;
        }

    }

public class StructureMapDependencyResolver : IDependencyResolver
    {
        public StructureMapDependencyResolver(IContainer container)
        {
            _container = container;
        }

        public object GetService(Type serviceType)
        {
            if (serviceType.IsAbstract || serviceType.IsInterface)
            {
                return _container.TryGetInstance(serviceType);
            }
            else
            {
                return _container.GetInstance(serviceType);
            }
        }

        public IEnumerable<object> GetServices(Type serviceType)
        {
            return _container.GetAllInstances<object>()
                .Where(s => s.GetType() == serviceType);
        }

        private readonly IContainer _container;
    }

我读到使用共享连接可能会稍微提高性能，所以我想知道如何在我的 MVC 应用程序中使用它。我想我必须将新创建的 PetaPoco.Database 对象传递给我的存储库的构造函数？

谢谢

Answer 1

我只能代表 Autofac，因为这是我在项目中使用的。这可能不适用于您想要做的事情，但我不妨分享一下。为了根据http请求获取petapoco数据库对象，我在global.asax.cs中有这个配置，

builder.RegisterType<MyProject.ObjectRelationalMapper.PetaPoco.Database>()
                .As<MyProject.ObjectRelationalMapper.PetaPoco.Database>()
                .WithParameters( new List<NamedParameter>() {new NamedParameter( "connectionStringName", "MyProjectConnectionString")})
                .InstancePerHttpRequest();

MyProject.ObjectRelationalMapper.PetaPoco只是我重命名的petapoco.cs。

在 Autofac 中，您可以通过 WithParameters() 告诉它要传入哪些参数，从而告诉它要调用哪个版本的构造函数。构造对象时，它会找到具有匹配参数的构造函数。

每次构造函数注入其依赖项时，它都会在整个 http 请求中使用相同的 petapoco 数据库对象，因为这就是我告诉 Autofac 要做的事情 (InstancePerHttpRequest)

我的控制器构造函数采用 INextMatchService 作为依赖项，而后者又采用 INextMatchRepository 作为依赖项：

public NextMatchRepository( Database database, ISessionWrapper sessionWrapper)
{
    this._database = database;
    this._sessionWrapper = sessionWrapper;
}

“Database”类型是MyProject.ObjectRelationalMapper.PetaPoco.Database，它是在上面的代码片段中构造的。现在我的存储库可以使用共享数据库连接。当您使用 Petapoco 函数时，它会检查是否已存在要使用的连接，如果存在，则会增加计数器并使用该对象：

// Open a connection (can be nested)
public void OpenSharedConnection()
{
    if (_sharedConnectionDepth == 0)
    {
        _sharedConnection = _factory.CreateConnection();
        _sharedConnection.ConnectionString = _connectionString;
        _sharedConnection.Open();

        if (KeepConnectionAlive)
            _sharedConnectionDepth++;// Make sure you call Dispose
    }
    _sharedConnectionDepth++;
}

Answer 2

如果有人想知道的话我就这么做了：

x.For<PetaPoco.Database>().Singleton().Use(() => new PetaPoco.Database("DBConnection"));

Answer 3

当您运行 PetaPoco 获得的 T4 时，您将获得以下可用信息。

{yourmodel}.ConnectionStringDB.GetInstance();

我会查找一个实例，如果有，则使用它，如果没有，则创建另一个实例。

不过我可能是错的……我不记得了。