trunk/AnywhereTS.DBSupport/SqlMdfConnector.cs

using System;
using System.Collections.Generic;
using System.Text;
using System.Data.SqlClient;
using System.Linq;
using System.Text.RegularExpressions;
namespace AnywhereTS.DBSupport
{
    public class SqlMdfConnector : DBConnector<SqlParameter, SqlCommand, SqlConnection, SqlDataAdapter>
    {        
        public SqlMdfConnector(string DBServerAddress, string DBServerInstance, string SqlMdf) : base(DBServerAddress, DBServerInstance, SqlMdf) { }

        public override void CreateConnection(out Exception ErrorInfo)
        {
            ErrorInfo = null;
            try
            {
                string connetionString = null;
                connetionString = GetConnectionString();
                connection = new SqlConnection();
                connection.ConnectionString = connetionString;
            }
            //catch (SqlException ex) { Console.WriteLine(ex.ToString()); ErrorInfo = ex;  throw ErrorInfo;}
            catch (Exception ex) { Console.WriteLine(ex.ToString()); ErrorInfo = ex; throw ErrorInfo; }
        }

        new public static string GetConnectionString()
        {
            return string.Format(@"Data Source={0}\{1};AttachDbFilename=|DataDirectory|\{2};Integrated Security=SSPI", DBServerAddress, DBServerInstance, DBDatabase);
        }

        protected override bool ClientRunScript(string strFile, out Exception ErrorInfo)
        {
            ErrorInfo = null;
            try
            {
                var commands = Regex.Split(strFile, string.Format(@"^GO{0}", System.Environment.NewLine), RegexOptions.IgnoreCase | RegexOptions.Multiline);
                foreach (var command in commands)
                {
                    Logging.DatabaseLog.DebugFormat("Current Command={0}", command);
                    SqlCommand sqlcmd = this.CreateCommandInstance(command, new List<SqlParameter>(), out ErrorInfo);
                    sqlcmd.CommandType = System.Data.CommandType.Text;
                    if (ErrorInfo != null)
                        throw ErrorInfo;
                    sqlcmd.ExecuteNonQuery();
                }
                return true;
            }
            catch (Exception ex)
            {
                ErrorInfo = ex;
                return false;
            }
        }
    }
}
1	william	85	using System;
2			using System.Collections.Generic;
3			using System.Text;
4			using System.Data.SqlClient;
5	william	125	using System.Linq;
6			using System.Text.RegularExpressions;
7	william	85	namespace AnywhereTS.DBSupport
8			{
9			public class SqlMdfConnector : DBConnector<SqlParameter, SqlCommand, SqlConnection, SqlDataAdapter>
10			{
11			public SqlMdfConnector(string DBServerAddress, string DBServerInstance, string SqlMdf) : base(DBServerAddress, DBServerInstance, SqlMdf) { }
12
13			public override void CreateConnection(out Exception ErrorInfo)
14			{
15			ErrorInfo = null;
16			try
17			{
18			string connetionString = null;
19	william	89	connetionString = GetConnectionString();
20	william	85	connection = new SqlConnection();
21			connection.ConnectionString = connetionString;
22			}
23			//catch (SqlException ex) { Console.WriteLine(ex.ToString()); ErrorInfo = ex; throw ErrorInfo;}
24			catch (Exception ex) { Console.WriteLine(ex.ToString()); ErrorInfo = ex; throw ErrorInfo; }
25			}
26	william	89
27			new public static string GetConnectionString()
28			{
29	william	119	return string.Format(@"Data Source={0}\{1};AttachDbFilename=\|DataDirectory\|\{2};Integrated Security=SSPI", DBServerAddress, DBServerInstance, DBDatabase);
30	william	89	}
31	william	119
32	william	123	protected override bool ClientRunScript(string strFile, out Exception ErrorInfo)
33	william	119	{
34			ErrorInfo = null;
35			try
36	william	128	{
37	william	129	var commands = Regex.Split(strFile, string.Format(@"^GO{0}", System.Environment.NewLine), RegexOptions.IgnoreCase \| RegexOptions.Multiline);
38	william	125	foreach (var command in commands)
39			{
40	william	129	Logging.DatabaseLog.DebugFormat("Current Command={0}", command);
41	william	125	SqlCommand sqlcmd = this.CreateCommandInstance(command, new List<SqlParameter>(), out ErrorInfo);
42	william	128	sqlcmd.CommandType = System.Data.CommandType.Text;
43	william	125	if (ErrorInfo != null)
44			throw ErrorInfo;
45			sqlcmd.ExecuteNonQuery();
46			}
47	william	119	return true;
48			}
49			catch (Exception ex)
50			{
51			ErrorInfo = ex;
52			return false;
53			}
54			}
55	william	85	}
56			}