Devart Forums

Code: Select all

var recordSet = from m in PPCustomer.Movies
							where m.AssetId == AssetId
							orderby m.MovieId
							select m;

			foreach (var movie in recordSet)
			{
			...
			}

Code: Select all

var recordSet = (from m in PPCustomer.Movies
							where m.AssetId == AssetId
							orderby m.MovieId
							select m).ToList();

Code: Select all

var recordSet = (from m in PPCustomer.Mailings.LoadWith(m => m.User).LoadWith(u => u.MailingRecipients)
				 join u in PPCustomer.Users on m.CreatedByUserId equals u.UserId
				 join mr in PPCustomer.MailingRecipients on m.MailingId equals mr.MailingId
				 join sq in PPCustomer.Users on mr.UserId equals sq.UserId into lj
				 from u2 in lj.DefaultIfEmpty()
				 select new
				 {
					 MailingId = m.MailingId,
					 CreationDate = m.CreationDate,
					 EmailAddress = u.EmailAddress,
					 RecipientEmailAddresses = m.MailingRecipients.Where(mrts => mrts.MailingId == m.MailingId),
					 Subject = m.Subject,
					 State = m.Deleted ? (int)MailingState.Deleted : (m.ExpirationDate  mailingListItem = new List();
foreach (var record in recordSet)
{
...
}

Code: Select all

from rc in MyDB.ReplicationCategories.LoadWith(rc => rc.Category)
select rc;

Code: Select all

from rc in MyDB.ReplicationCategories.LoadWith(rc => rc.Category.LoadWith(c => c.CategoryTranslations))
select rc;

Code: Select all

using System;
using System.Collections.Generic;
using System.Data.Linq;
using System.Linq;
using System.Linq.Expressions;
using Devart.Data.Linq;
using System.Threading;

namespace DevartTest
{
	class Program
	{
		static void Main(string[] args)
		{
			// TODO:
			// - Set the wait_timeout of the MySql instance to 20 seconds
			// - Adjust the connection string
			// - Create a DataContext from any table and use this table for the query

			Console.WriteLine("Creates a connection on the MySql instance");
			Run();

			Console.WriteLine("Waits 10 seconds");
			Thread.Sleep(10*1000);

			Console.WriteLine("Reuses the connection on the MySql instance and resets its idle time back to 0");
			Run();

			Console.WriteLine("Waits 25 seconds until the connection gets killed on the MySql server");
			Thread.Sleep(25 * 1000);

			Console.WriteLine("Tries to reuse the connection on the MySql instance (instead of creating a new one) which throws a \"Lost connection to MySQL server during query\" error");
			Run();

			Thread.Sleep(60 * 1000);
		}

		static void Run()
		{
			try
			{
				DB db = new DB("Server=MyServer;Port=3306;Database=MyDatabase;User=MyUser;Password=MyPassword;Persist Security Info=false;Unicode=true;Pooling=true;Min Pool Size=0;Max Pool Size=100;Connection Lifetime=0;Connection Timeout=15;Compress=false;Protocol=tcp;Direct=true;Embedded=false");
				db.DeferredLoadingEnabled = false;

				var records = (from t in db.MyTable
							 select t).ToList();
			}
			catch (Exception ex)
			{
				Console.WriteLine();
				Console.WriteLine(ex.ToString());
			}
		}
	}
}

Code: Select all

Server=xyz;Port=3306;Database=xyz;User=xyz;Password=xyz;Persist Security Info=false;Unicode=true;Pooling=true;Min Pool Size=0;Max Pool Size=1000;Connection Lifetime=0;Connection Timeout=60;Compress=false;Protocol=tcp;Direct=true;Embedded=false