TECHNOLOGIES
FORUMS
JOBS
BOOKS
EVENTS
INTERVIEWS
Live
MORE
LEARN
Training
CAREER
MEMBERS
VIDEOS
NEWS
BLOGS
Sign Up
Login
No unread comment.
View All Comments
No unread message.
View All Messages
No unread notification.
View All Notifications
Answers
Post
An Article
A Blog
A News
A Video
An EBook
An Interview Question
Ask Question
Forums
Monthly Leaders
Forum guidelines
Smart Lucky
NA
555
637.8k
Nhibernate Session Issue When Inserting Data in Other DB
Feb 20 2014 5:15 AM
Hi dudes
i am using nhibernate here i want get records from one database and insert them in an other multiple databases i have make following code but it is giving me exception regarding session can nay one help me please how can i do this....
namespace CopyCoupons
{
public class Program
{
static void Main(string[] args)
{
ServiceContextCopyCoupon _contextSource;
ServiceContextCopyCoupon _contextDestination;
NHibernateHelperForConsole _myHelper;
var successFullMovedCouponId=new List<string>();
var unSuccessFullMovedCouponId = new List<string>();
try
{
string[] connections=new[] {"Data Source=.;Initial Catalog=22;Integrated Security=true;","Data Source=.;Initial Catalog=23;Integrated Security=true;","Data Source=.;Initial Catalog=25;Integrated Security=true;"};
var myHelperDefault = new NHibernateHelperForConsole();
myHelperDefault.InitializeSessionFactory();
_contextSource = new ServiceContextCopyCoupon(myHelperDefault);
var coupnsForMove = _contextSource.couponService.Query().Where(x => x.Ismove == false).ToList();
//CurrentSessionContext.Unbind(myHelperDefault.SessionFactory);
foreach (string conn in connections)
{
successFullMovedCouponId.Add(conn);
unSuccessFullMovedCouponId.Add(conn);
_myHelper = new NHibernateHelperForConsole();
_myHelper.InitializeSessionFactory(conn);
_contextDestination = new ServiceContextCopyCoupon(_myHelper);
foreach (var coupon in coupnsForMove)
{
using (var s = _myHelper.SessionFactory.OpenSession())
{
var company2 = _contextDestination.companyService.Query().FirstOrDefault(x => x.Id1 == coupon.Companyid.Id1 || x.Id2 == coupon.Companyid.Id2 || x.Name2 == coupon.Companyid.Name2);
}
// Session session = sessionFactory.openSession();
var company =_contextDestination.companyService.Query().FirstOrDefault(x =>x.Id1 == coupon.Companyid.Id1 ||x.Id2 == coupon.Companyid.Id2 ||x.Name2 == coupon.Companyid.Name2);
coupon.Companyid = company;
coupon.CreateDate = DateTime.Now;
coupon.Ismove = true;
_contextSource.CloseSession();
myHelperDefault.SessionFactory.Close();
if (_contextDestination.couponService.CreateCoupon(coupon))
{
successFullMovedCouponId.Add(coupon.id.ToString());
}
else
{
unSuccessFullMovedCouponId.Add(coupon.id.ToString());
}
}
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
}
Console.ReadKey();
}
}
public class ServiceContextCopyCoupon
{
public CouponService couponService { get; private set; }
public CouponService CouponService { get { return couponService; } }
public CategoryService categoryService { get; private set; }
public CategoryService CategoryService { get { return categoryService; } }
public CompanyService companyService { get; private set; }
public CompanyService CompanyService { get { return companyService; } }
public ISession _session;
public ServiceContextCopyCoupon(NHibernateHelperForConsole pro)
{
//if (CurrentSessionContext.HasBind(pro.SessionFactory))
// CurrentSessionContext.Unbind(pro.SessionFactory);
_session = pro.SessionFactory.OpenSession();
categoryService = new CategoryService(_session);
companyService = new CompanyService(_session);
couponService = new CouponService(_session);
}
public void CloseSession()
{
if (_session != null && _session.IsOpen)
{
_session.Dispose();
}
}
}
}
public class NHibernateHelperForConsole
{
public ISessionFactory _sessionFactory;
public ISessionFactory SessionFactory
{
get
{
if (_sessionFactory == null)
this.InitializeSessionFactory();
return this._sessionFactory;
}
}
public NHibernateHelperForConsole() { }
public void InitializeSessionFactory(string connectionString = "Data Source=.;Initial Catalog=24;Integrated Security=true;")
{
this._sessionFactory = Fluently.Configure()
.Database(MsSqlConfiguration.MsSql2008
.ConnectionString(connectionString)
)
.Mappings(m =>
m.FluentMappings
.AddFromAssemblyOf<Category>())
.ExposeConfiguration(cfg => new SchemaExport(cfg)
.Create(false, false))
.BuildSessionFactory();
//.Conventions.Add( FluentNHibernate.Conventions.Helpers.DefaultLazy.Never() )
}
}
Reply
Answers (
0
)
how to use seagate crystal report 8 in c#
Reference Book to learn ASP.NET MVP/MVC 3.5