代码之家 › 专栏 › 技术社区 › user1396423

实体框架代码优先方法的动态连接字符串

entity-framework asp.net-mvc c#

user1396423 · 技术社区 · 9 年前

我正在使用具有代码优先方法和工作单元模式的实体框架6.0。我想动态构建连接字符串并从数据库中获取数据。如果我有网络,数据库连接可以正常工作。连接字符串的配置标记。但是,我不想有一个网站。连接字符串的配置标记。我看到了许多与此相关的问题,但我没有发现与codefirst方法相关的问题。请让我知道如何实现这一点。

-------------------- Repository.cs --------------------

using System;
using System.Collections.Generic;
using System.Linq;
using System.Data.Entity;
using System.Linq.Expressions;
using Commons.DTO;

namespace Repository
{
    public class Repository<TEntity> where TEntity : class
    {
        internal CommonsDbContext context;
        internal DbSet<TEntity> dbSet;

        public Repository(CommonsDbContext context)
        {
            if (context == null)
                throw new ArgumentNullException("context");
            this.context = context;
            this.dbSet = context.Set<TEntity>();
        }

        public virtual IEnumerable<TEntity> Get(Expression<Func<TEntity, bool>> filter = null, Func<IQueryable<TEntity>, IOrderedQueryable<TEntity>> orderBy = null, string includeProperties = "")
        {
            IQueryable<TEntity> query = dbSet;

            if (filter != null)
                query = query.Where(filter);

            string[] properties = includeProperties.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
            foreach (var includeProperty in properties)
                query = query.Include(includeProperty);

            if (orderBy != null)
                return orderBy(query).ToList();
            else
                return query.ToList();
        }

        public virtual TEntity GetByID(object id)
        {
            return dbSet.Find(id);
        }

        public virtual void Insert(TEntity entity)
        {
            dbSet.Add(entity);
        }

        public virtual void Delete(object id)
        {
            TEntity entityToDelete = dbSet.Find(id);
            Delete(entityToDelete);
        }

        public virtual void Delete(TEntity entityToDelete)
        {
            if (context.Entry(entityToDelete).State == EntityState.Detached)
                dbSet.Attach(entityToDelete);
            dbSet.Remove(entityToDelete);
        }

        public virtual void Update(TEntity entityToUpdate)
        {
            dbSet.Attach(entityToUpdate);
            context.Entry(entityToUpdate).State = EntityState.Modified;
        }

        public virtual bool IsValid(TEntity entityToValid, Expression<Func<TEntity, bool>> filter)
        {
            return dbSet.Where(filter).Any();
        }
    }
}

-------------------- UnitOfWork.cs --------------------
using System;
using Commons.DTO;

namespace Repository
{
    public class UnitOfWork : IDisposable
    {
        protected CommonsDbContext dbContext = null;

        public UnitOfWork()
        {
            dbContext = new CommonsDbContext();
        }

        public UnitOfWork(CommonsDbContext context)
        {
            if (context == null)
                throw new ArgumentNullException("context");
            this.dbContext = context;
        }

        public virtual void Save()
        {
            dbContext.SaveChanges();
        }

        #region IDisposable Members
        public void Dispose()
        {
            Dispose(true);
            GC.SuppressFinalize(this);
        }

        protected virtual void Dispose(bool disposing)
        {
            if (disposing)
            {
                dbContext.Dispose();
                dbContext = null;
            }
        }

        ~UnitOfWork()
        {
            Dispose(false);
        }
        #endregion
    }
}
-------------CommonsDbContext.cs
using System.Data.Entity;

namespace Commons.DTO
{
    public class CommonsDbContext : DbContext
    {
        public CommonsDbContext() : base("name=DbContext")
        {
            Database.SetInitializer<CommonsDbContext>(null);
        }

        public CommonsDbContext(string nameOrConnectionString) : base(nameOrConnectionString)
        {

        }

        protected override void OnModelCreating(DbModelBuilder modelBuilder)
        {
            modelBuilder.Configurations.Add(new ApplicationMapper());
        }
        public DbSet<Application> Applications { get; set; }
    }
}

1 回复 | 直到 9 年前

Camilo Terevinto Chase R Lewis 9 年前

您的问题是,您专门传递了一个连接字符串名称,该名称将仅在 web.config 或 app.config . 如果不想使用 :

public class CommonsDbContext : DbContext
{
    //Approach 1:
    private const connectionString = "...";

    public CommonsDbContext() : base(connectionString)
    {
        Database.SetInitializer<CommonsDbContext>(null);
    }

    //Approach 2:

    public static CommonsDbContext GetContext()
    {
        var builder = new SqlConnectionStringBuilder();

        // add data here

        return new CommonsDbContext(builder.ConnectionString);
    }

    private CommonsDbContext(string connString) : base(connString)
    {
        Database.SetInitializer<CommonsDbContext>(null);
    }
}

但是,请注意,将连接字符串放在比其他任何地方都好。